基于MQTT Paho库在Fiware中发布消息未达预期的问题排查

• 对齐消息格式
  你用Docker客户端发送的是AGV_Th|25这种竖线分隔的键值对格式，而Python客户端发送的是JSON格式。Fiware的MQTT代理（如IoT Agent）可能仅配置为识别竖线分隔格式，而非JSON。先修改Python代码的消息格式，和Docker客户端保持一致：

  import paho.mqtt.client as mqtt
  client = mqtt.Client()
  client.connect("172.31.85.246", 31624)
  # 改用竖线分隔的键值对格式
  client.publish("/ul/5jggokgpepnvsb2uv4s40d59ov/agv001/attrs", "agv_th|65")
  

• 确保消息发送完成
  Paho-MQTT的connect和publish是异步操作，程序可能在消息发送完成前就退出。添加网络循环和等待逻辑，保证消息成功投递：

  import paho.mqtt.client as mqtt
  import time
  
  client = mqtt.Client()
  client.connect("172.31.85.246", 31624)
  # 启动客户端网络循环处理消息
  client.loop_start()
  # 发布消息并指定QoS（与Docker客户端默认值一致，通常为0）
  publish_result = client.publish("/ul/5jggokgpepnvsb2uv4s40d59ov/agv001/attrs", "agv_th|65", qos=0)
  # 等待消息发布完成
  publish_result.wait_for_publish()
  # 停止循环并断开连接
  client.loop_stop()
  client.disconnect()
  

• 检查IoT Agent配置
  确认Fiware IoT Agent的MQTT适配器配置，是否允许JSON格式的消息。如果原本仅支持竖线分隔格式，需要修改IoT Agent的配置文件，添加JSON格式支持，或者通过Paho的properties参数设置消息的Content-Type头。

• 启用调试日志排查问题
  在Python代码中添加日志和回调函数，查看连接、发布过程中的错误信息：

  import paho.mqtt.client as mqtt
  import logging
  import time
  
  # 开启调试级日志
  logging.basicConfig(level=logging.DEBUG)
  
  def on_connect(client, userdata, flags, rc):
      print(f"连接结果码: {rc}")
  
  def on_publish(client, userdata, mid):
      print(f"消息已发布，消息ID: {mid}")
  
  client = mqtt.Client()
  client.on_connect = on_connect
  client.on_publish = on_publish
  client.connect("172.31.85.246", 31624)
  client.loop_start()
  client.publish("/ul/5jggokgpepnvsb2uv4s40d59ov/agv001/attrs", "agv_th|65")
  time.sleep(2)
  client.loop_stop()
  

  通过日志可以排查连接失败、消息被拒绝等异常情况。

• 对比MQTT消息元数据
  使用mosquitto_sub等工具监听目标主题，对比Docker客户端和Python客户端发送的消息的QoS、保留标志、Payload编码等是否完全一致，确保Python客户端的参数配置与Docker端匹配。

内容的提问来源于stack exchange，提问作者sfl0r3nz05