@@ -23,18 +23,11 @@ def send_message(record):
2323 # Create a message
2424 message_body = record
2525 try :
26- print ("send_message 1..." )
2726 sqs_client = boto3 .client ("sqs" )
28- print ("send_message 2..." )
2927 sqs_client .send_message (QueueUrl = failure_queue_url , MessageBody = json .dumps (message_body ))
30- print ("send_message 3..." )
3128 logger .info ("Record saved successfully to the DLQ" )
32- print ("send_message 4..." )
3329 except ClientError as e :
34- print ("send_message error 1..." )
3530 logger .error (f"Error sending record to DLQ: { e } " )
36- print ("send_message error 2..." )
37- print ("send_message end" )
3831
3932def get_vaccine_type (patientsk ) -> str :
4033 parsed = [str .strip (str .lower (s )) for s in patientsk .split ("#" )]
@@ -163,9 +156,7 @@ def handler(event, context):
163156 log_data ["function_name" ] = "delta_sync"
164157 try :
165158 dynamodb = boto3 .resource ("dynamodb" , region_name = "eu-west-2" )
166- print ("handler 1...." )
167159 delta_table = dynamodb .Table (delta_table_name )
168- print ("handler 2...." )
169160 for record in event ["Records" ]:
170161 log_data ["date_time" ] = str (datetime .now ())
171162
@@ -175,23 +166,15 @@ def handler(event, context):
175166 ret = False
176167
177168 except Exception as e :
178- print ("handler error 1..." )
179169 ret = False
180170 operation_outcome = {
181171 "statusCode" : "500" ,
182172 "statusDesc" : "Exception" ,
183173 "diagnostics" : f"Delta Lambda failure: Incorrect invocation of Lambda"
184174 }
185- print ("handler error 2..." )
186175 logger .exception (operation_outcome ["diagnostics" ])
187- print ("handler error 3..." )
188176 send_message (event ) # Send failed records to DLQ
189- print ("handler error 4..." )
190177 log_data ["operation_outcome" ] = operation_outcome
191- print ("handler error 5..." )
192178 firehose_log ["event" ] = log_data
193- print ("handler error 6..." )
194179 firehose_logger .send_log (firehose_log )
195- print ("handler error 7..." )
196- print (f"handler returning { ret } !" )
197180 return ret
0 commit comments