def lambda_handler()

in functions/start_stateMachine/app.py [0:0]


def lambda_handler(event, context):
    print(event)

    for record in event['Records']:
        s3BucketName = record['s3']['bucket']['name']
        s3ObjectKey = unquote_plus(record['s3']['object']['key'])
        s3_object_extension = record['s3']['object']['key'].split('.')[-1]
        guid = str(uuid.uuid4())
        uploadDate = dateutil.parser.parse(record['eventTime'])

        jsonStateMachine = {
            "originalFile":{
                "s3BucketName":s3BucketName,
                "s3ObjectKey": s3ObjectKey,
                "s3ObjectExtension": s3_object_extension,
                "uploadDate": uploadDate.strftime("%Y-%m-%d %H:%M")
            },
            "guid": guid
        }

        stepFunction_cli.start_execution(
            stateMachineArn= STATE_MACHINE_ARN,
            input= json.dumps(jsonStateMachine),
            name= guid
        )

    return True