def clean_s3()

in lib/integration-test/lambda/delete_s3_objects.py [0:0]


def clean_s3(event, context):
    LOGGER.info("Received event: %s", event)
    try:
        d = event
        delete_s3_objects(d['FirehoseOutputBucket'])
        return event
    except Exception as e:
        # Trace error
        LOGGER.exception("Error while deleting data from S3.")
        return {"status": "FAILED", "error_message": str(e), "guid": event}