groups/lambda/ArmErrorDetector/error_detector.py [18:44]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
gg_client = greengrasssdk.client('iot-data')


def check_obstruction(datum):
    present_speed = datum['present_speed']
    present_position = datum['present_position']
    present_load = datum['present_load']
    goal_position = datum['goal_position']
    moving = datum['moving']

    print("[check_obstruction] present speed:{0} position:{1} load:{2}".format(
        present_speed, present_position, present_load
    ))
    print("[check_obstruction] goal_position:{0} moving:{1}".format(
        goal_position, moving
    ))


# Handler for processing lambda work items
def handler(event, context):
    # Unwrap the message
    msg = json.loads(event)
    print("[error_detector] looking for errors")

    if 'data' in msg:
        for datum in msg['data']:
            check_obstruction(datum)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



groups/lambda/MasterErrorDetector/error_detector.py [18:44]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
gg_client = greengrasssdk.client('iot-data')


def check_obstruction(datum):
    present_speed = datum['present_speed']
    present_position = datum['present_position']
    present_load = datum['present_load']
    goal_position = datum['goal_position']
    moving = datum['moving']

    print("[check_obstruction] present speed:{0} position:{1} load:{2}".format(
        present_speed, present_position, present_load
    ))
    print("[check_obstruction] goal_position:{0} moving:{1}".format(
        goal_position, moving
    ))


# Handler for processing lambda work items
def handler(event, context):
    # Unwrap the message
    msg = json.loads(event)
    print("[error_detector] looking for errors")

    if 'data' in msg:
        for datum in msg['data']:
            check_obstruction(datum)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -