asyncio_mqtt 异步循环发送消息

首先，你需要安装 `asyncio-mqtt` 库，可以使用以下命令进行安装：

pip install asyncio-mqtt

接下来，你需要使用 `async with` 语句创建一个 MQTT 连接，并发送消息。以下是一个示例代码：

import asyncio
from asyncio_mqtt import Client, MqttError

async def send_message():
    client = Client('mqtt://test.mosquitto.org')

    try:
        await client.connect()
        await client.publish('topic', 'message')
    except MqttError as e:
        print(f'Error: {e}')

    await client.disconnect()

asyncio.run(send_message())

在上面的示例代码中，我们使用 `async with` 语句创建了一个 MQTT 客户端，并连接到了 `mqtt://test.mosquitto.org` 服务器。然后，我们使用 `await client.publish()` 方法发送了一条消息到 `topic` 主题。最后，我们使用 `await client.disconnect()` 方法关闭了连接。