python - 为什么paho python客户端发短消息而不发长消息
问题描述
这有效:
while True:
print('')
command_input = input()
if command_input == 'q':
break
mcp = Mqtt_command_publisher
mcp.publish_command(device_ids, command_input)
但这不会:
class Mqtt_command_bl:
def update_minutes_to_run_at(json):
if not json['device_ids']:
return 'Request must contain device ids'
device_ids = json['device_ids']
minutes_to_run_at = json['minutes_to_run_at']
minutes_to_run_at_command_section = ''
for i in minutes_to_run_at:
m = '"{}",'.format(i)
if i == minutes_to_run_at[len(minutes_to_run_at) - 1]:
m = '"{}"'.format(i)
minutes_to_run_at_command_section += m
#command_input = 'jq \'.+{{minutes_to_run_at:[{}]}}\' /home/pi/hallmonitor_lite/config.json > /home/pi/hallmonitor_lite/tmp.json && mv /home/pi/hallmonitor_lite/tmp.json /home/pi/hallmonitor_lite/new_config.json'.format(minutes_to_run_at_command_section)
command_input = 'mkdir /home/pi/hallmonitor_lite/hello_world'
mcp = Mqtt_command_publisher
mcp.publish_command(device_ids, command_input)
return 'Success'
他们都调用的类:
class Mqtt_command_publisher:
def publish_command(device_ids, command_input):
mqtt_msg = json.dumps({'device_ids':device_ids,'command':command_input})
print('\n{}'.format(mqtt_msg))
client = mqtt.Client()
client.connect('********', ****, 30)
client.publish('topic/commands', mqtt_msg)
client.disconnect()
查看从 Mqtt_command_publisher 输出的打印语句,输出可能完全相同,但是,只有其中一个会执行,我不明白为什么一个有效而另一个无效。
我尝试了这个命令进行测试:mkdir /home/pi/hallmonitor_lite/hello_world
这是接收部分:
device_id = 0
with open('/home/pi/hallmonitor_lite/config.json') as json_data_file:
data = json.load(json_data_file)
device_id = data['device_id']
def on_connect(client, userdata, flags, rc):
print("Connected with result code: " + str(rc))
client.subscribe("topic/commands")
def on_message(client, userdata, msg):
mqtt_message = msg.payload.decode()
print(mqtt_message)
ids_and_command = json.loads(mqtt_message)
if str(device_id) in ids_and_command['device_ids'] or not ids_and_command['device_ids']:
print(('Executing: {}').format(ids_and_command['command']))
os.system(ids_and_command['command'])
client = mqtt.Client()
client.connect("********", ****, 30)
client.on_connect = on_connect
client.on_message = on_message
client.loop_forever()
有任何想法吗?
解决方案
这个问题很可能是因为第二组代码正在创建一个比单个 TCP 数据包更大的消息。
这是一个问题,因为您没有运行客户端网络循环,因此该client.publish
命令只能发送一个数据包,其余消息将由网络循环发送,但即使它正在运行,您也会在发布通话。
客户端不应该为这样的单个消息而启动,它应该被启动然后继续运行,您只需publish
在您想要发送消息时调用该方法。如果您不想这样做或由于某种原因不能这样做,那么 paho python 包中有一个特定的帮助程序类,它将完成启动客户端、发送消息然后很好地拆除所有内容的所有繁重工作。单一发布的文档在这里。
import paho.mqtt.publish as publish
publish.single("paho/test/single", "payload", hostname="mqtt.eclipse.org")
推荐阅读
- python - 如何为 CNN 训练准备通道图像?
- android-studio - 如何为在Android中分配了多个角色的用户实现登录?
- javascript - 如何创建离线工作的网络应用程序?(例如,bulkresizephoto)
- javascript - 直接从相机上传图像到谷歌云存储
- java - 双向 jpa 休眠关系 @OneToMany @ManyToOne 失败,因为未存储父 ID
- bash - 签名错误阻止上传到 S3 存储桶
- python-3.x - TensorFlow 1.15 中的 Autograph 在条件语句中给出 TypeError,在一个分支中赋值
- c# - Update() 和 FixedUpdate() 之间有什么区别,应该如何将这些区别应用于控制运动?
- javascript - 如何禁用滚动功能?
- r - R:使用经度/纬度的散点