merege

Author: nhsdevws

recordprocessor/src/utils_for_recordprocessor.py

@@ -3,7 +3,7 @@
 import os
 from csv import DictReader
 from io import TextIOWrapper
-from clients import s3_client
+from clients import s3_client, logger
 
 
 def get_environment() -> str:
@@ -28,3 +28,19 @@ def get_csv_content_dict_reader(file_key: str) -> DictReader:
 def create_diagnostics_dictionary(error_type, status_code, error_message) -> dict:
     """Returns a dictionary containing the error_type, statusCode, and error_message"""
     return {"error_type": error_type, "statusCode": status_code, "error_message": error_message}
+
+
+def invoke_filename_lambda(file_key: str, message_id: str) -> None:
+    """Invokes the filenameprocessor lambda with the given file key and message id"""
+    try:
+        lambda_payload = {
+            "Records": [
+                {"s3": {"bucket": {"name": SOURCE_BUCKET_NAME}, "object": {"key": file_key}}, "message_id": message_id}
+            ]
+        }
+        lambda_client.invoke(
+            FunctionName=FILE_NAME_PROC_LAMBDA_NAME, InvocationType="Event", Payload=json.dumps(lambda_payload)
+        )
+    except Exception as error:
+        logger.error("Error invoking filename lambda: %s", error)
+        raise