与 EMQX Broker 集成
通过 EMQX Broker 的数据集成，可以将 MQTT 消息字段写入 EMQX Tables。本页介绍集成的工作原理和配置入口。
工作原理
Broker 接收设备消息后，规则引擎按 MQTT 主题匹配消息并提取字段，再由写入动作通过 Arrow Flight SQL 将数据写入 Tables。无需自行安装数据库或部署额外的数据转发服务。
- 设备将 JSON 遥测消息发布到 Broker。
- 规则匹配主题并提取设备标识、时间和测量值。
- 写入动作将规则输出绑定到 SQL 模板参数。
- Tables 将数据写入预先创建的目标表。
- 使用控制台或数据库客户端查询数据。
数据写入动作使用 SQL 模板，目标表必须预先创建。
配置流程
| 步骤 | 操作 | 验证结果 |
|---|---|---|
| 1. 创建目标表 | 在 Tables 的数据查询中执行建表 SQL | 数据表列表可见目标表 |
| 2. 创建连接器 | 在 Broker 数据集成中选择 EMQX Tables，使用快速配置 | 连接测试成功 |
| 3. 创建规则 | 根据 MQTT 主题提取业务字段 | 规则测试输出包含所需字段 |
| 4. 配置动作 | 选择连接器并填写 INSERT 模板 | 模板字段与表结构、规则输出一致 |
| 5. 发布并查询 | 发布样例消息，查看动作统计和 Tables 查询结果 | 动作成功数增加，数据库出现记录 |
配置数据集成
连接器、规则、写入动作和验证步骤属于 EMQX Broker 的数据集成功能。完整配置说明参见将 MQTT 数据写入 EMQX Tables。
如需从创建 Broker 和 Tables 部署开始完成一个端到端示例，参见快速开始。