def handler()

in services/s3-new-image-event.py [0:0]


def handler(event, context):
    responseData = {}
    try:
        response = {}
        bucketName = event['Records'][0]['s3']['bucket']['name']
        objectKey = event['Records'][0]['s3']['object']['key']
        objectUrl = "url"
        response["bucketName"] = bucketName
        response["objectKey"] = objectKey
        response["objectUrl"] = objectUrl
        response["snsTopicArn"] = os.environ['SNS_TOPIC_ARN']
        insertRecordIntoSqs(response)
        time.sleep(20) #Sleep for 10 seconds giving the SQS message the chance to become readable
        publishToIoTTopic(response)
        return {
            'statusCode': 200,
            'body': json.dumps(response)
        }
    except Exception as e:
        logger.error('Error: {}'.format(e)) 
        print(e)