def lambda_handler()

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!")}