python实现MQTT数据驱动

### 使用Python实现基于MQTT协议的数据驱动应用

为了创建一个数据驱动的应用程序，使用 `gmqtt` 库可以简化 MQTT 协议的客户端开发工作流。下面展示了一个简单的例子来说明如何设置并运行一个订阅者和发布者的应用程序。

#### 订阅者代码示例
此部分展示了怎样配置一个 MQTT 客户端去监听特定主题的消息：

import gmqtt

broker_host = 'test.mosquitto.org'
topic = 'data/driven/topic'

def on_message(client, topic, payload, qos, properties):
    print(f"Received message: {payload.decode()} from topic: {topic}")

async def main():
    client = gmqtt.Client("subscriber")
    client.on_message = on_message
    
    await client.connect(broker_host)
    await client.subscribe(topic)

if __name__ == '__main__':
    import asyncio
    asyncio.run(main())

这段代码定义了当接收到新消息时触发的方法，并设置了连接到公共测试代理服务器以及订阅指定话题的操作[^1]。

#### 发布者代码示例
这里提供了另一个脚本来发送信息给之前提到的主题：

import gmqtt

broker_host = 'test.mosquitto.org'
topic = 'data/driven/topic'
message = "This is a data-driven application test"

async def main():
    client = gmqtt.Client("publisher")

    await client.connect(broker_host)
    await client.publish(topic, message)

if __name__ == '__main__':
    import asyncio
    asyncio.run(main())

在这个案例里，同样地初始化了一个新的客户端实例并向选定的话题发布了字符串形式的信息。

这两个片段共同构成了一个完整的循环，在这个过程中发布的任何内容都会被相应的订阅方捕获处理。这种模式非常适合构建实时响应型的服务或是物联网设备之间的通信机制。