in src/iot/subscribe.py [0:0]
def customCallback(deprecated_0, deprecated_1, message):
payload_dict = json.loads(message.payload)
alarm_ID = payload_dict['alarm_ID']
camera_ID = payload_dict['camera_ID']
if alarm_ID == CLIENT_ID:
logger.info('Alert: worker without PPE caught on %s', camera_ID)
play_controlled_alarm()
else:
logger.debug('Alert: worker without PPE caught on %s', camera_ID)