basic lambda

Author: nhsdevws

id_sync/poetry.lock

@@ -1,9 +1,7 @@
 import os
 import logging
-import redis
 from boto3 import client as boto3_client
 
-
 logging.basicConfig(level="INFO")
 logger = logging.getLogger()
 logger.setLevel("INFO")
@@ -13,8 +11,5 @@
 REGION_NAME = os.getenv("AWS_REGION", "eu-west-2")
 REDIS_HOST = os.getenv("REDIS_HOST", "")
 REDIS_PORT = os.getenv("REDIS_PORT", 6379)
-
 s3_client = boto3_client("s3", region_name=REGION_NAME)
 firehose_client = boto3_client("firehose", region_name=REGION_NAME)
-logger.info(f"Connecting to Redis at {REDIS_HOST}:{REDIS_PORT}")
-redis_client = redis.StrictRedis(host=REDIS_HOST, port=REDIS_PORT, decode_responses=True)

id_sync/src/clients.py

@@ -1,9 +1,7 @@
 from clients import logger
-from s3_event import S3Event
-from record_processor import process_record
-from event_read import read_event
 from log_decorator import logging_decorator
-from clients import redis_client
+from record_processor import process_record
+
 '''
     Event Processor
     The Business Logic for the Redis Sync Lambda Function.
@@ -14,21 +12,17 @@
 def handler(event, _):
 
     try:
-        # check if the event requires a read, ie {"read": "my-hashmap"}
-        if "read" in event:
-            return read_event(redis_client, event, logger)
-        elif "Records" in event:
+        if "Records" in event:
             logger.info("Processing S3 event with %d records", len(event.get('Records', [])))
-            s3_event = S3Event(event)
-            record_count = len(s3_event.get_s3_records())
+            record_count = len(event.get('Records', []))
             if record_count == 0:
                 logger.info("No records found in event")
                 return {"status": "success", "message": "No records found in event"}
             else:
                 error_count = 0
                 file_keys = []
-                for record in s3_event.get_s3_records():
-                    record_result = process_record(record)
+                for record in event.get('Records', []):
+                    record_result = process_record(record, None)
                     file_keys.append(record_result["file_key"])
                     if record_result["status"] == "error":
                         error_count += 1

id_sync/src/constants.py

@@ -1,36 +1,7 @@
-from clients import logger
-from s3_event import S3EventRecord
-from redis_cacher import RedisCacher
 '''
-    Record Processor
-    This module processes individual S3 records from an event.
-    It is used to upload data to Redis ElastiCache.
+    record Processor
 '''
 
 
-def process_record(record: S3EventRecord) -> dict:
-    try:
-        logger.info("Processing S3 r bucket: %s, key: %s",
-                    record.get_bucket_name(), record.get_object_key())
-        bucket_name = record.get_bucket_name()
-        file_key = record.get_object_key()
-
-        base_log_data = {
-            "file_key": file_key
-        }
-
-        try:
-            result = RedisCacher.upload(bucket_name, file_key)
-            result.update(base_log_data)
-            return result
-
-        except Exception as error:  # pylint: disable=broad-except
-            logger.exception("Error uploading to cache for filename '%s'", file_key)
-            error_data = {"status": "error", "message": str(error)}
-            error_data.update(base_log_data)
-            return error_data
-
-    except Exception:  # pylint: disable=broad-except
-        msg = "Error processing record"
-        logger.exception(msg)
-        return {"status": "error", "message": msg}
+def process_record(record, _):
+    return "hello world"