in services/publish-reading.py [0:0]
def handler(event,context):
service = event["service"] # The Service to be sent to
topic = event["topic"] # The topic the message will be sent to
messagePayload = {}
response = {}
try:
if (service == "sns"):
messagePayload["gaugeReading"] = event["gaugeReading"]
sendSNSMessage(topic,messagePayload)
else :
messagePayload["s3ObjectKey"] = event["s3ObjectKey"]
messagePayload["s3BucketName"] = event["s3BucketName"]
messagePayload["gaugeType"] = event["gaugeType"]
messagePayload["gaugeID"] = event["gaugeID"]
messagePayload["gaugeReading"] = event["gaugeReading"]
messagePayload["timeStamp"] = event["timeStamp"]
messagePayload["errorCode"] = event["errorCode"]
messagePayload["errorMessage"] = event["errorMessage"]
sendIoTMessage(topic,messagePayload)
response = messagePayload
except Exception as e:
logger.error('Error: {}'.format(e))
response['errorMessage'] = e
return response