MQTT的协调生产者消费者

mqtt-coordinated的Python项目详细描述


##MQTT协调消费者。

卡夫卡激励的MQTT协调消费者

pip安装mqtt coordinated

##MQTT用户协调管理器

CoordinatorManager类是MQTT使用者的管理器类。它允许您连接到mqtt服务器并订阅多个主题。它会在收到新消息后为操作提供on-u消息回调。

` >>> from mqtt import CoordinatorManager >>> >>> manager = CoordinatorManager('my-manager', 'iot.eclipse.org') >>> manager.start() >>> >>> consumer = manager.coordinated_consumer >>> consumer.on_message = on_message  # Pass callback name here. >>> consumer.subscribe("house/bulb") >>> consumer.poll(100)    # Batch message reading construct for streaming purpose `

` # Disconnect and stop consuming >>> consumer.disconnect() >>> manager.stop() `

有两种消费事件的方法, -正在注册on-u消息 -分批阅读邮件。批处理存储在内存中,暂时不存储在永久性磁盘上。

##MQTT生产者协调生产者

coordinatedproducer类是mqtt producer,它将在mqtt主题上创建多个分区。您可以将分区号或分区密钥传递给此生产者。具有相同分区密钥的消息被允许在同一分区上生成。

` >>> from mqtt import CoordinatedProducer >>> producer = CoordinatedProducer('iot.eclipse.org') >>> producer.publish_on_partition("house/bulb", "on") # Message will be published on random partition >>> producer.publish_on_partition("house/bulb", "on", partition=5) # Message will be published on 5th partition >>> producer.publish_on_partition("house/bulb", "on", partition_key='message_key') # All messages with partition_key will be published on same partition. `

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
Java性能为什么响应时间会随着时间的推移而增加?   java如何在Eclipse中忽略特定异常   java如何在安卓中通过显示安卓获得屏幕截图   java如何访问struts if标记的test属性中的属性   java新线程不使用JFrame   java我应该检查一个文本字段是否有文本,然后清理它还是直接清理它?   数组在java中每隔三个整数打印一行   java如何在querydsl中加入外键   从src/main/resources读取java会产生NullPointerException   java h2db按字段排序   java如何使用Tomcat7在Spring中提供的JNDI数据源?   java更新整数不起作用为什么?   java Orika通用集合自定义映射   在java中使用csvreader类读取csv文件时出现opencsv反斜杠问题   java SonarQube中同一项目的多个视图   如何在Java中使用“start with”变量查找文件   java如何在活动之间传递整数?   清除Android应用程序缓存的java反射方法   java无法从领事处注销服务(Spring boot app)