数据库与 MQTT 连接:MySQL DSN、SQLite 和 Broker
连接定义如何访问数据服务,数据源定义具体读取内容。完成连接后,还需要创建 SQL 查询或 MQTT 订阅。
MySQL 与 SQLite3
进入项目「数据库连接」,新建数据库连接,填写连接名称、驱动类型和 DSN。当前数据库驱动选项包括 mysql 与 sqlite3。
MySQL DSN 示例:
dav_reader:YOUR_PASSWORD@tcp(db.example.internal:3306)/dav?charset=utf8mb4
| 部分 | 含义 |
|---|---|
| dav_reader | 数据库账号示例 |
| YOUR_PASSWORD | 替换为实际密码 |
| tcp(...) | 数据库地址和端口 |
| /dav | 数据库名称 |
| charset=utf8mb4 | 字符集参数示例 |
这里的地址应能从实际取数服务所在环境访问。把本机数据库迁到服务器时,需要重新核对主机地址与访问权限。
SQLite3 使用 sqlite3 驱动和对应数据库文件的 DSN。文件路径需要在实际服务环境有效,不能填写操作者电脑上的路径。连接后通过「新增SQL」读取数据。
测试与排查
保存后使用连接测试入口。成功后再创建查询。连接失败时检查地址、端口、账号、数据库名称与网络权限;连接成功但查询失败时,再检查表名、列名和查询权限。
MQTT
新增 MQTT 连接,填写连接名称、Broker URL、客户端 ID,以及需要时的用户名和密码。配置界面使用完整的 WebSocket 地址,例如:
wss://mqtt.example.com:8084/mqtt
客户端 ID 需要避免重复。路径、端口和 ws/wss 协议应与 Broker 实际开放的服务一致,不能只把 TCP 端口替换到 WebSocket 地址中。
之后进入MQTT 数据源选择该连接并填写主题。