MQTT 连接资源
集中管理 Broker、认证、TLS 与客户端参数，供 MQTT Source 和 Sink 复用。
输入连接配置与 Secret 引用
输出具名 MQTT Connector Resource
23 official plugins · v1.0.0
从协议接入到数据落地。
每个插件都是独立目录、独立 manifest 和独立构建产物。下列输入/输出描述的是事件语义；精确字段以对应插件 manifest 为准。
PostgreSQL 连接资源
为关系型 Source 和 Sink 提供共享 PostgreSQL 连接配置。
输入DSN、连接池与 Secret
输出PostgreSQL Connector Resource
Redis 连接资源
管理 Redis 地址、数据库、认证和连接参数，供 Stream、Hash 与映射插件使用。
输入Redis 连接配置
输出Redis Connector Resource
Siemens S7 连接资源
按采集需求建立会话，批量读取，高频窗口复用，空闲或故障时快速释放。
输入PLC 地址、机架/槽位、会话策略
输出串行化 S7 Device Resource
TDengine 连接资源
管理 TDengine 3.0 数据库连接，供时序写入插件绑定。
输入DSN、数据库与认证
输出TDengine Connector Resource
TimescaleDB 连接资源
使用 PostgreSQL 协议管理 TimescaleDB 连接，服务轮询与写入节点。
输入DSN、连接池与认证
输出TimescaleDB Connector Resource
MQTT 订阅源
通过 Connector 订阅主题，将解码后的消息载荷原样发布为事件。
输入connector_ref、topic、QoS、解码选项
输出消息 Payload 与主题元数据
PostgreSQL 轮询源
按计划通过 Connector 执行查询，将新增或变更行转为事件。
输入connector_ref、查询、游标、周期
输出每行一个结构化 Row Event
Redis Stream 源
从 Redis Stream 消费记录并转换为规则事件。
输入connector_ref、stream、消费组
输出Stream 字段对象与消息标识
S7 多点采集源
按配置周期批量读取点位，支持 JSON、Excel 导入导出、精度、范围和越界默认值。
输入connector_ref、点位表、采集周期、变化策略
输出
{device_code,data,time} 遥测事件TimescaleDB 时序源
按时间游标轮询时序数据，将查询结果转换为事件。
输入connector_ref、查询、时间游标、周期
输出时间序列 Row Event
变化检测
按分组键比较前后值，识别值变化、差值、百分比和趋势。
输入任意带监视字段的 Event
输出变化事件；未变化可过滤
JavaScript 转换
在隔离、限时的运行环境执行主函数，用代码完成自定义转换。
输入
main(event) 接收 Event 副本输出返回新 Event；超时或异常报错
进程状态事件
把 snake_case 状态字段规范化为启动、运行、停止等生命周期事件。
输入包含状态字段的设备事件
输出规范化生命周期事件
Redis 关系映射
从 Redis Hash 读取通用关系表，为事件字段补充名称、编码或业务属性。
输入Event、connector_ref、键与字段映射
输出增加关系字段后的 Event
映射转换
使用字段映射、Go Template 和字段展开重组结构化事件。
输入Event 与映射模板
输出按目标结构生成的 Event
通用转换
通过复制、对象映射、JSONPath 与 Go Template 完成声明式转换。
输入Event 与转换规则
输出新 Payload / Metadata Event
MQTT 发布目标
通过 Connector 将事件编码后发布到配置主题。
输入Event、connector_ref、主题、QoS
输出MQTT 消息与发送结果
PostgreSQL 关系写入
把结构化事件映射为关系表写入或更新操作。
输入Row Event、表和列映射
输出INSERT / UPSERT 执行结果
Redis 写入
将事件写入 Redis Stream 或 Hash。
输入Event、connector_ref、目标模式
输出Redis 写入确认
S7 点位写入
通过 S7 Connector 串行写入配置点位，不对写操作做不透明重试。
输入Event data 与点位映射
输出PLC 写入结果或明确错误
TDengine 时序写入
将行式时序载荷写入 TDengine 3.0。
输入时间戳、标签与字段 Row Event
输出TDengine 写入结果
TimescaleDB 时序写入
通过 Connector 将时序行写入 TimescaleDB hypertable。
输入时间戳、标签与字段 Row Event
输出TimescaleDB 写入结果
没有匹配的插件。请尝试协议名或插件 ID。