AWS IoT Python SDK和asyncio

我需要使用AWS IoT MQTT服务。我正在做一些实验 https://github.com/aws/aws-iot-device-sdk-python 目前。

我的应用程序将使用WebSocket与另一个服务通信,然后发布/订阅MQTT主题以转发/接收消息。

这个库是否可能会阻止代码执行?我仍然试着了解asyncio,不确定应该注意什么。我怎么知道它是否会引起问题?

我相信我只需要使用 AWSIoTMQTTClient 从图书馆上方。

这是我的工作代码摘录:

class AWSIoTClient:

    def __init__():
        ...
        self.client = AWSIoTMQTTClient(...)

    def subscribe(self, callback):
        self.client.subscribe(f'{self.TOPIC}/subscribe/', 0, callback)

    def publish(self, message):
        self.client.publish(self.TOPIC, message, 0)


class MyWSProtocol(WebSocketClientProtocol):

    def set_aws_client(self, client: AWSIoTClient):
        client.subscribe(self.customCallback)
        self.client = client

    def customCallback(self, client, userdata, message):
        # This will be called when we send message from AWS
        if message.payload:
            message = json.loads(message.payload.decode('utf-8').replace("'", '"'))
            message['id'] = self.next_id()
            self.sendMessage(json.dumps(message).encode('utf-8'))

    def onMessage(self, payload, isBinary):
        message = json.loads(payload)

        # This will forward message to AWS
        self.client.publish(str(payload))