Dify MQTT Trigger Plus

项目概览

为什么需要它？

传统 IoT 平台只能做「数据采集与展示」…

核心特性

技术架构

技术选型 · Tech Stack

数据流 · Data Flow

MQTT Broker
     │
     │  subscribe (long-lived connection)
     ▼
[MQTT Client Process]
     │  push message
     ▼
[Redis Queue]  ◄─── dedup by (device-id, ts-window, payload-hash)
     │
     ▼
[Celery Worker Pool]  ─── rate-limit hot topics
     │
     │  trigger workflow API
     ▼
[Dify Workflow Engine]
     │
     ▼
LLM · RAG · Tool calls · External API

关键挑战与解法

长连接生命周期

Dify 插件默认是「请求 - 响应」模型…

消息背压

当 MQTT 消息瞬时并发数高于工作流处理能力时…

幂等性

同一台设备可能因为 QoS 1 重传导致工作流被多次触发…

交付成果

IoT 事件从「通知」升级为「决策 + 行动」 —— 这就是这个插件的存在意义。