保存数据到 Lindorm 数据库 (自 e3.3.6 和 e4.4.1 起)

    创建表

    资源需要以下启动参数:

    • Lindorm 服务器:Lindorm 访问地址,Lindorm 提供了域名访问,阿里云主机请填写内网访问地址,默认端口 ,根据实际情况填写,需要添加 前缀;
    • 数据库:数据存储的数据库名称,根据创建的服务填写;
    • 连接池大小:数据库写入数据的进程池,根据业务量填写,写入是阻塞型请求,高并发业务推荐 或者 以上;
    • 用户名:未开启用户认证不填写,已经开启请按照实际情况填写;

    确保资源状态可用(非阿里云部署,可能会出现创建后首次链接比较慢导致不可用状态,点击状态按钮刷新状态)。

    创建规则

    image

    添加动作;

    • 动作类型:数据持久化;保存数据到 Lindorm;
    • 使用资源:选择创建的资源 ID;
    • 表名:同步模式可以使用占位符动态规划,异步批量写入请严格使用表名,不能动态改变;
    • 同步写入:同步即每条数据立即入库,异步模式开启批量功能,数据将按照批量大小和间隔时间规则写入;
    • 异步模式批量间隔:默认 100,单位毫秒,推荐 10 - 200;
    • 时间戳:单位毫秒,推荐使用消息时间,空数据会按照规则命中的时间戳计算;
    • Tags: 数据标签键值对,根据创建的表结构填写;
    • Fields:数据键值对,根据创建的表结构填写;

    image

    使用 MQTT 客户端发布消息,查看规则命中与成功失败计数;

    使用 API 查询数据库写入结果: