将 MQTT 数据流式传输到 MongoDB

MongoDB 以 BSON 文档的形式存储遥测数据，支持嵌套对象、数组以及因设备而异的元数据。EMQX 负责接入 MQTT 消息并预处理数据，再由 MongoDB Sink 将数据插入集合。本页展示的数据流为单向，即从 EMQX 写入 MongoDB。

先使用 EMQX SQL 规则提取和整理字段，再通过 Sink 的有效载荷模板映射处理结果。二进制或自定义格式的载荷需要先使用合适的解码器解析。在模板中，字符串需加引号，数字不加引号，以保留原有类型。请使用具有代表性的设备消息进行测试。

可以，前提是部署规模与业务负载相匹配。系统容量取决于消息大小和速率、文档结构、索引以及数据库资源。MongoDB 副本集提供冗余和故障切换能力，分片则将数据分布到多个分片上。建议使用具有代表性的流量和查询，对整条数据管道进行基准测试。

EMQX 可以缓存待发送的请求，并对可恢复的错误进行重试。缓冲容量和请求过期时间决定了投递最长可以延迟多久。请监控失败和被丢弃的请求，测试中断和重启后的恢复情况，并根据数据持久性要求配置 MongoDB 的写入确认。

您需要支持 MongoDB 集成的 EMQX、可访问数据库的网络，以及具有写入权限的凭证。先根据 MongoDB 部署方式配置连接器，再创建 SQL 规则和 Sink，并指定集合与有效载荷模板。启用 TLS 以加密连接，最后写入一条测试文档验证结果。