def lambda_handler()

in sam/app-order-management/functions/sqscallbackfunction/app.py [0:0]


def lambda_handler(event, context):
    print(event)
    for record in event['Records']:
        payload=record["body"]
        obj = json.loads(payload)

        output = {'shipping_status': 'successful'}
        print("Task token is {}".format(obj['token']))
        response = client.send_task_success(
            taskToken=obj['token'],
            output=json.dumps(output)
        )
        print(response)