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
