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}