in workshops/Sagemaker_Pipelines_Automated_Retraining/kick_off_pipeline_lambda.py [0:0]
def lambda_handler(event, context):
# uncomment to log event info
# logging.info(json.dumps(event))
filename = event["Records"][0]["s3"]["object"]["key"]
filename_basename = os.path.basename(filename)
the_s3uri = convert_to_s3uri(NOTIFICATION_BUCKET_NAME, filename)
the_response = kick_off_sagemaker_pipeline(
pipelinename=SAGEMAKER_PIPELINE_NAME, s3uri=the_s3uri
)
# logging.info(json.dumps(content_4))
# put_file_in_s3(f'''{filename_basename}_out''',json.dumps(content_4),OUTPUT_BUCKET_NAME)
return {"statusCode": 200, "body": json.dumps("Hello from Lambda!")}