武器级MQTT客户端。

haka-mqtt的Python项目详细描述


haka_mqtt包是可靠的“武器级”mqtt客户端库。 它包含一个核心mqtt反应堆类,该类具有可证明的可靠性, 以可重复性为基本目标。副作用是 图书馆也很快。

状态

该项目的核心反应堆是稳定的。它已经在系统上测试过了 在困难的现场条件下,有成千上万的分布式节点。这个 QoS=1数据路径经过现场测试。QoS=0和QoS=2不是 彻底的现场测试。

虽然核心反应堆经过了很好的测试,但前端的数量较少 经过测试。你应该注意不同正面的注释 关于它们的地位和用途。

haka库主要是在linux衍生物上测试的。可能会起作用 其他平台,但这还没有经过作者的测试 已经向作者报告了成功的确切报告。

安装

可以从pypi.org安装haka mqtt包 使用pip

pip install haka-mqtt

用法

如何使用软件包的快速示例:

# Standard python Packagesimportlogging# 3rd-Party Packagesfromhaka_mqtt.frontends.pollimport(MqttPollClientProperties,BlockingMqttClient)fromhaka_mqtt.reactorimportACTIVE_STATESfrommqtt_codec.packetimportMqttTopicLOG_FMT='%(asctime)s%(name)s%(levelname)s%(message)s'logging.basicConfig(format=LOG_FMT,level=logging.INFO)properties=MqttPollClientProperties()properties.host='test.mosquitto.org'properties.port=1883properties.ssl=FalseTOPIC='haka'c=BlockingMqttClient(properties)c.start()sub_ticket=c.subscribe([MqttTopic(TOPIC,1)])c.on_suback=lambdac,suback:c.publish(TOPIC,'payload',1)c.on_publish=lambdac,publish:c.stop()whilec.stateinACTIVE_STATES:c.poll(5.)

项目基础设施

该项目通过公共基础设施进行协调,可在 几个地方:

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

推荐PyPI第三方库


热门话题
java生成随机浮点,包括两个边界   java三层体系结构风格是如何工作的?一些简单的例子   多线程可以使用线程。在Java中,在循环中使用sleep(),以便定期执行某些操作?   读取循环上的java HibernateMysql异常   java使用带有Apache Ivy的自定义存储库,未找到解析程序   filenotfoundexception在读取时出现问题。Java中的txt文件   嵌入式tomcat 8.0.21中的java Spring websocket   java为什么我需要创建一个类的引用,然后创建一个B类的对象   java Splashscreen动画在Mac OS中更新时闪烁   JavaSpring3。名为“zoneManagerDelegate”的x Bean必须是[com.ms.adsp.delegate.sapi.zoneManagerDelegate]类型,但实际上是[$Proxy20]类型   java SQLite:没有这样的专栏;不明错误   java将JTable定位到JFrame中JPanel中的(x,y)位置   java在导入组织方面面临挑战。知道。xchart*   xml读取Java中的SVG元素并跳过某些包含文本的元素   java Spring Redis问题:Redis缓存中的GetAllCacheNames不能与RedisCacheManager一起使用   java Vertex Hazelcast:集群问题   java如何编辑osgi托管服务实现使用的属性文件?   java Android活动并行启动?   java AWS Lambda用于将excel转储到数据库中