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)