in gg_group_setup/mock_device.py [0:0]
def handler(event, context):
# Unwrap the message
msg = json.loads(event)
logging.info("[handler] thinking about message: {0}".format(msg))
error_val = None
for item in msg:
if item['device'] is 'mock-01':
for d in item['data']:
if d['value'] > 70:
error_val = d['value']
break
if error_val:
publish_error(
get_shadow_state(),
json.dumps({
"error_message": "found an error in telemetry",
"error_value": error_val
})
)
else:
logging.info("[handler] no error found.")