def process_alerts()

in functions/source/alerts/alerts.py [0:0]


def process_alerts(event, context):
    """Surface and publish device telemetry."""
    logger.debug(event)

    sns.publish(
        Subject='Watts threshold excess',
        Message='The wattage recorded for device with serial {0} is {1}'.
        format(event['serial'], event['watts']),
        TopicArn=os.environ['TOPIC_ARN'],
    )

    return {'statusCode': 200}