如何修改Plotly Dash的display_Output函数以获取展示订阅的MQTT响应

你当前界面输出的是on_message函数对象的内存地址，本质是两个核心错误导致的：一是你直接把on_message函数本身作为结果返回给了Dash界面，没有捕获它异步触发时收到的MQTT payload；二是MQTT的回调逻辑和Dash的同步渲染逻辑天然割裂，无法直接在Dash回调中获取on_message的返回值。

针对display_Output函数的具体修改步骤 #

1. 先定义全局共享变量存储MQTT消息 #

因为on_message是MQTT客户端触发的异步回调，只有收到消息时才会执行，需要用共享变量中转收到的内容：

# 放在代码顶部全局位置
latest_mqtt_msg = "暂无MQTT消息"

2. 重写display_Output内部逻辑 #

修改on_message函数的赋值逻辑，同时启动MQTT非阻塞订阅循环，不要返回on_message函数本身：

def display_Output(mqtt_client, subscribe_topic):
    # 定义on_message回调，收到消息时更新全局变量
    def on_message(client, userdata, msg):
        global latest_mqtt_msg
        # 按实际编码格式解码payload，一般默认是utf-8
        latest_mqtt_msg = msg.payload.decode("utf-8")
    
    # 绑定回调到MQTT客户端
    mqtt_client.on_message = on_message
    # 订阅目标主题
    mqtt_client.subscribe(subscribe_topic)
    # 启动非阻塞的MQTT后台循环，不要用loop_forever()，会阻塞Dash主线程
    mqtt_client.loop_start()

3. 搭配Dash定时组件更新界面 #

不要直接把on_message或者MQTT相关逻辑塞到Dash的渲染回调里，用dcc.Interval定时拉取全局变量的值更新界面：
首先在布局中添加对应组件：

app.layout = html.Div([
    # 你的其他界面组件
    dcc.Interval(id='mqtt-refresh', interval=1000, n_intervals=0), # 每1秒刷新一次
    html.Div(id='mqtt-content') # 展示MQTT消息的容器
])

再写对应的更新回调：

@app.callback(
    Output('mqtt-content', 'children'),
    Input('mqtt-refresh', 'n_intervals')
)
def refresh_mqtt_content(n):
    return latest_mqtt_msg

注意事项 #

• 确保你的MQTT客户端连接逻辑没有问题，连接失败、权限不足、主题名写错都会导致收不到消息
• 上述方案仅适用于本地单进程测试场景，如果是多进程部署的Dash服务，需要改用Redis等第三方存储做消息中转
• 不需要MQTT订阅时记得调用mqtt_client.loop_stop()关闭后台线程，避免资源泄漏

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