in workflow1_endpointbuilder/sam-app/functions/function3_processobjectsandupdaterows/index.py [0:0]
def lambda_handler(event, context):
for record in event["Records"]:
if record["eventName"] == "INSERT":
new_image = record["dynamodb"]["NewImage"]
key = new_image["objectKey"]["S"]
datetime_id, bucket_name = parse_info(record["eventSourceARN"])
process_file(key, datetime_id, bucket_name)