import json
import logging
import azure.functions as func

app = func.FunctionApp()

@app.service_bus_queue_trigger(arg_name="message", queue_name="orders",
                              connection="OrdersBus")
def order_received(message: func.ServiceBusMessage):
    order = json.loads(message.get_body().decode("utf-8"))
    order_id = order.get("orderId")
    if not isinstance(order_id, str) or not order_id:
        raise ValueError("Training message needs a non-empty orderId")
    logging.info("Training order received: %s", order_id)