Блог

Я новичок в Python. Я получил сообщение от служебной шины Azure, как показано на скриншоте ниже и ниже кода.

Код для получения сообщений от служебной шины является:

 import logging
import json

import azure.functions as func


def main(message: func.ServiceBusMessage):

    message_content_type = message.content_type
    message_body = message.get_body().decode("utf-8")
    logging.info(message_body)
    message = "MSG Received"
    logging.info(message)
 

Теперь я хочу преобразовать message_body строку в JSON, и после этого я проверяю приведенное ниже условие:

 If error = null and MSG_TYPE_TAG != Null
 

Как я могу запустить этот сценарий?

Преобразование строки в JSON

 message_body = json.loads(message_body)
 

Теперь проверьте состояние

 if message_body['error'] == {} and message_body['MSG_TYPE_TAG'] != '':
    # write your logic here
 

Код

 import json

message_body = json.loads(message_body)

if message_body['error'] == {} and message_body['MSG_TYPE_TAG'] != '':
    # write your logic here