物联网规则引擎

SQL表达式

JSON数据可以映射为虚拟的表，其中Key对应表的列，Value对应列值，这样就可以使用SQL处理。为便于理解，我们将规则引擎的一条规则抽象为一条SQL表达（类试MySQL语法）：

例如某环境传感器用于火灾预警，可以采集温度、湿度及气压数据，上报数据内容如下：
{
"temperature":25.1
"humidity":65
"pressure":101.5
"location":"xxx,xxx"
}
假定温度大于38，湿度小于40时，需要触发报警，可以编写如下的SQL语句：SELECT temperature as t, deviceName() as deviceName, location FROM /ProductA/+/update WHERE temperature > 38 and humidity < 40
当上报的数据中，温度大于38且湿度小于40时，会触发该规则，并且解析数据中的温度、设备名称、位置，用于进一步处理。

FROM

FROM 需要填写Topic通配符，用于匹配需要处理的消息Topic。当有符合Topic规则的消息到达时，消息的payload数据以json格式解析，并根据SQL语句进行处理（如果消息格式不合法，将忽略此消息）。您可以使用topic()函数引用具体的Topic值。

上文例子中，"FROM /ProductA/+/update"语句表示该SQL仅处理符合/ProductA/+/update格式的消息，具体匹配参考 Topic。

SELECT

• JSON数据格式

  select语句中的字段，可以使用上报消息的payload解析结果，即json中的键值，也可以使用SQL内置的函数，比如deviceName()。不支持子SQL查询。

  上报的json数据格式，可以是数组或者嵌套的json，SQL语句支持使用json path获取其中的属性值，如对于{a:{key1:v1, key2:v2}}，可以通过a.key2 获取到值v2。使用变量时需要注意单双引号区别：单引号表示常量，双引号或不加引号表示变量。如使用单引号'a.key2'，值为a.key2。

  内置的SQL函数可以参考函数列表。

  例如上文，"SELECT temperature as t, deviceName() as deviceName, location"语句，其中temperature和loaction来自于上报数据中的字段，deviceName()则使用了内置的SQL函数。
  

• 二进制数据格式

  目前二进制数据不支持解析payload中的字段，SELECT语句固定为SELECT *，表示透传二进制数据。

WHERE

• JSON数据格式

  规则触发条件，条件表达式。不支持子SQL查询。WHERE中可以使用的字段和SELECT语句一致，当接收到对应topic的消息时，WHERE语句的结果会作为规则是否触发的判断条件。具体条件表达式列表见下方表格。

  上文例子中， "WHERE temperature > 38 and humidity < 40" 表示温度大于38且湿度小于40时，才会触发该规则，执行配置。

• 二进制数据格式

  目前二进制格式WHERE语句中仅支持内置函数及条件表达式，无法使用payload中的字段。

SQL结果

SQL语句执行完成后，会得到对应的SQL结果，用于下一步转发处理。如果payload数据解析过程中出错会导致规则运行失败。 转发数据动作中的表达式需要使用 ${表达式} 引用对应的值。

对于上文例子，配置转发动作时，可以${t}、${deviceName}和${loaction}获取SQL解析结果，如果要将数据存储到TableStore，配置中可以使用${t}、${deviceName}和${loaction}。

数组使用说明

数组表达式需要使用双引号，比如设备消息为：｛a:[{v:1},{v:2},{v:3}]｝，那么SQL语句中的select写法为：select "$.a[0]" data1,".a[1].v" data2,".a[2]" data3，则data1={v:1}，data2=2，data3=[{v:3}]。

条件表达式支持列表