rule-manager

Rule-manager

规则引擎相关服务。设置规则将数据转发置你想要的目标。

使用

环境变量

设置系统环境变量：

# root@tcp(localhost:3306)/test?charset=utf8&parseTime=True&loc=Local
export DSN="<your-dsn>"

export RuleTopic="<your-rule-topic>"

DSN 信息用于连接服务数据库，目前使用的是 MySQL 驱动。采用的是 GORM 所以可以适配多个不同数据驱动。

RuleTopic 信息用于创建订阅 ID, 订阅服务可解析此 ID 创建规则主题然后用于用户订阅数据传输，目的是为了和其他服务发订阅区分。

依赖

该服务为 tKeel 下的一个插件，需要在项目中使用以下服务：

• MySQL
• dapr 边车
• redis
• tKeel Core
• tKeel Device

依赖库

Core 的调用以及 Service 中的用户认证 Auth ，还有分页工具用的是 core-broker 项目中的包。后面注意拆解。

import (
    "github.com/tkeel-io/core-broker/pkg/auth"
    "github.com/tkeel-io/core-broker/pkg/core"
    "github.com/tkeel-io/core-broker/pkg/deviceutil"
    "github.com/tkeel-io/core-broker/pkg/pagination"
)

其他说明

1. 在时序路由的转发是 mysql 和 clickhouse 时，数据表需要内置两个字段：
   1. id, string 类型，用于保存设备 id
   2. timestamp, int64(bigint) 类型， 用于保存时间戳，时间戳的单位为毫秒

设计

表设计

rules

规则表，用于存储规则信息。

rule_entities

用于存储规则与实体设备关系的中间表

targets

规则目标表，用于存储规则转发目标的一些信息。