保存数据到 Lindorm 数据库 (自 e3.3.6 和 e4.4.1 起)
创建表
资源需要以下启动参数:
- Lindorm 服务器:Lindorm 访问地址,Lindorm 提供了域名访问,阿里云主机请填写内网访问地址,默认端口 ,根据实际情况填写,需要添加 前缀;
- 数据库:数据存储的数据库名称,根据创建的服务填写;
- 连接池大小:数据库写入数据的进程池,根据业务量填写,写入是阻塞型请求,高并发业务推荐 或者 以上;
- 用户名:未开启用户认证不填写,已经开启请按照实际情况填写;
确保资源状态可用(非阿里云部署,可能会出现创建后首次链接比较慢导致不可用状态,点击状态按钮刷新状态)。
创建规则
添加动作;
- 动作类型:数据持久化;保存数据到 Lindorm;
- 使用资源:选择创建的资源 ID;
- 表名:同步模式可以使用占位符动态规划,异步批量写入请严格使用表名,不能动态改变;
- 同步写入:同步即每条数据立即入库,异步模式开启批量功能,数据将按照批量大小和间隔时间规则写入;
- 异步模式批量间隔:默认 100,单位毫秒,推荐 10 - 200;
- 时间戳:单位毫秒,推荐使用消息时间,空数据会按照规则命中的时间戳计算;
- Tags: 数据标签键值对,根据创建的表结构填写;
- Fields:数据键值对,根据创建的表结构填写;
使用 MQTT 客户端发布消息,查看规则命中与成功失败计数;
使用 API 查询数据库写入结果: