Add richer logs to the record forwarder

Author: dlzhry2nhs

lambdas/recordforwarder/src/forwarding_batch_lambda.py

@@ -81,8 +81,11 @@ def forward_lambda_handler(event, _):
         kinesis_payload = record["kinesis"]["data"]
         decoded_payload = base64.b64decode(kinesis_payload).decode("utf-8")
         incoming_message_body = json.loads(decoded_payload, use_decimal=True)
+        file_key = incoming_message_body.get("file_key")
+        local_id = incoming_message_body.get("local_id")
 
         if is_eof_message(incoming_message_body):
+            logger.info("Received EOF message for file key: %s", file_key)
             filename_to_events_mapper.add_event(incoming_message_body)
             continue
 
@@ -95,6 +98,7 @@ def forward_lambda_handler(event, _):
             "supplier": incoming_message_body.get("supplier"),
             "vaccine_type": incoming_message_body.get("vax_type"),
         }
+        logger.info("Received message for file %s with local id: %s", file_key, local_id)
 
         try:
             if incoming_diagnostics := incoming_message_body.get("diagnostics"):
@@ -119,7 +123,8 @@ def forward_lambda_handler(event, _):
             else:
                 array_of_identifiers.append(identifier)
 
-            forward_request_to_dynamo(incoming_message_body, table, identifier_already_present, controller)
+            imms_pk = forward_request_to_dynamo(incoming_message_body, table, identifier_already_present, controller)
+            logger.info("Successfully processed message. Local id: %s, PK: %s", local_id, imms_pk)
 
         except Exception as error:  # pylint: disable = broad-exception-caught
             filename_to_events_mapper.add_event(