def lambda_handler()

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)