def handler()

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