python mqtt publish_mqtt异步publish

以下是使用HBMQTT库进行异步mqtt publish的示例代码：

import asyncio
from hbmqtt.client import MQTTClient

async def publish_mqtt(topic, message):
    client = MQTTClient()
    await client.connect('mqtt://localhost:1883')
    await client.publish(topic, message)
    await client.disconnect()

async def main():
    topic = 'test/topic'
    message = 'Hello, MQTT!'
    await publish_mqtt(topic, message)

asyncio.run(main())

在上述代码中，我们首先导入了`asyncio`和`MQTTClient`类。然后，我们定义了一个`publish_mqtt`函数，该函数接受一个主题和消息作为参数，并使用`MQTTClient`对象连接到MQTT代理，然后发布消息到指定的主题。最后，我们定义了一个`main`函数，该函数调用`publish_mqtt`函数来发布消息。

要运行上述代码，您需要先安装HBMQTT库。您可以使用以下命令来安装：

pip install hbmqtt

请注意，您需要将`mqtt://localhost:1883`替换为您实际使用的MQTT代理的地址和端口。