Функция обратного вызова IoT Azure для запуска в новом потоке

Я использую Azure IoT Hub Python API для отправки сообщения в облако с помощью send_event_async (msg, send_callback, cntr). Есть ли способ заставить функцию обратного вызова обрабатываться в новом потоке, чтобы не прерывать основной поток?

Вот мой код:

from iothub_client import IoTHubTransportProvider, IoTHubMessage

CON_STR = "<con_str>"
PRT = IoTHubTransportProvider.MQTT
TIMEOUT = 10000
MSG_TXT = "{\"deviceId\": \"MyDevice\"}"

def send_callback(message, result, user_context):
    # do some logic
    pass

client = IoTHubClient(CON_STR, PRT)
client.set_option("messageTimeout", TIMEOUT)
cntr = 0
msg = IoTHubMessage(MSG_TXT)
client.send_event_async(msg, send_callback, cntr)
Источник

0 ответов

Другие вопросы по тегам