in ml_ops/visualization_blog/lambdas/s3lambda/parse.py [0:0]
def lambda_handler(event, context):
bucket_name = event['Records'][0]['s3']['bucket']['name']
return dumps(
STEP_FUNCTIONS_CLI.start_execution(
stateMachineArn=os.environ['STEP_FUNCTIONS_ARN'],
name=datetime.now().strftime("%Y_%m_%d_%H_%M_%S"),
input=dumps(
{
'bucket': bucket_name,
'currentDate': datetime.now().strftime("%Y_%m_%d_%H_%M_%S"),
'params':
get_params(bucket_name, os.environ['PARAMS_FILE'])
}
)
),
default=str
)