我正在运行一个交通灯(π-停止)解决方案,我的项目与MQTT集成。因此,发布者将向订阅者发送计数的数量,而订阅者将控制和更改交通灯。然而,我无法从出版商中发出任何点票。请指教,谢谢
MQTT_pub.py (出版商)
import paho.mqtt.client as mqtt
import paho.mqtt.publish as publish
sub_topic = "light" #recieve message on this topic
pub_topic = "light" #send message to this topic
Broke
我已经编写了一些python3代码来按顺序执行以下操作;
检查互联网是否已上网
如果因特网连接到MQTT代理
每30分钟向pub_topic发布一次消息
循环到第一步&重复
另外,我希望MQTT连接是持久的,这样就可以接收到传入的消息。
正在发生的情况是,经过几次迭代之后,MQTT连接退出,最终程序崩溃。
下面是我的while循环代码片段;
while True:
try:
if not internet_up():
time.sleep(20)
我正在使用MQTT发送和接收消息从谷歌的IoT核心(遥测信息)。然后将消息传递到不同的Pub/Sub主题。
我想在我的消息中添加自定义属性。
目标是在我的主题上使用不同的订阅。然后,根据我的自定义属性过滤传入的消息,最后在我的数据流管道上通过“主题”获取我的消息。
我知道当我们使用Pub/Sub客户端时我们可以做到这一点,但是我无法从mqtt客户端成功地做到这一点。
我正在使用python客户端。
因此,根据要求,我补充了一些细节。这是一种非常经典的情况。我使用的是一个MQTT客户端,如这里的谷歌示例:。然后使用相同文档中的发布代码: (我只是替换了
for i in range(0,
我想使用Perl模块Net::MQTT::Simple向MQTT服务器发送MQTT消息。这是一个基于的简单MVP脚本
#!/usr/bin perl
use warnings;
use strict;
use autodie;
use Net::MQTT::Simple;
# Allow unencrypted connection with credentials
$ENV{MQTT_SIMPLE_ALLOW_INSECURE_LOGIN} = 1;
# Connect to broker
my $mqtt = Net::MQTT::Simple->new('local
我在覆盆子服务器上安装了一台蚊虫服务器。
这个服务器运行良好:我使用mosquitto_sub和mosquitto_pub命令进行了测试。
我已经编写了这个python脚本:
import paho.mqtt.client as mqtt
import time
client = mqtt.Client('module_test_4')
client.connect('127.0.0.1', 1883, 10)
client.loop_start()
for i in range(10):
client.publish('topic_2
我下载了Mosquitto代理,并尝试使用Arduino UNO +以太网盾作为客户端,在桌面上实现MQTT协议。只要我运行名为“蚊子”的代理的.exe文件,就会弹出一个命令行提示符,并且保持不变,没有任何行!这种情况会发生吗?还是应该显示一些消息?
另外,蚊子(.exe)的pub和sub文件在运行时,打开一个命令propmpt并立即关闭!它们根本不会停滞不前!我使用带有以太网屏的Arduino UNO来发布数据,但是代理造成了上面提到的问题。