# 与 EMQX Broker 集成

通过 EMQX Broker 的数据集成，可以将 MQTT 消息字段写入 EMQX Tables。本页介绍集成的工作原理和配置入口。

## 工作原理

Broker 接收设备消息后，规则引擎按 MQTT 主题匹配消息并提取字段，再由写入动作通过 Arrow Flight SQL 将数据写入 Tables。无需自行安装数据库或部署额外的数据转发服务。

1. 设备将 JSON 遥测消息发布到 Broker。
2. 规则匹配主题并提取设备标识、时间和测量值。
3. 写入动作将规则输出绑定到 SQL 模板参数。
4. Tables 将数据写入预先创建的目标表。
5. 使用控制台或数据库客户端查询数据。

数据写入动作使用 SQL 模板，目标表必须预先创建。

## 配置流程

| 步骤 | 操作 | 验证结果 |
| --- | --- | --- |
| 1. 创建目标表 | 在 Tables 的数据查询中执行建表 SQL | 数据表列表可见目标表 |
| 2. 创建连接器 | 在 Broker 数据集成中选择 EMQX Tables，使用快速配置 | 连接测试成功 |
| 3. 创建规则 | 根据 MQTT 主题提取业务字段 | 规则测试输出包含所需字段 |
| 4. 配置动作 | 选择连接器并填写 INSERT 模板 | 模板字段与表结构、规则输出一致 |
| 5. 发布并查询 | 发布样例消息，查看动作统计和 Tables 查询结果 | 动作成功数增加，数据库出现记录 |

## 配置数据集成

连接器、规则、写入动作和验证步骤属于 EMQX Broker 的数据集成功能。完整配置说明参见[将 MQTT 数据写入 EMQX Tables](../../data_integration/emqx_tables.md)。

如需从创建 Broker 和 Tables 部署开始完成一个端到端示例，参见[快速开始](../emqx_tables_quick_start.md)。