js脚本过滤器
jsFilter
组件:脚本过滤器。可以使用JavaScript脚本对msg、metadata、msgType进行过滤。脚本应返回路由到True或者False链。
JavaScript脚本支持ECMAScript 5.1(+) 语法规范和部分ES6规范,如:async/await/Promise/let。允许在脚本中调用Go自定义函数,请参考udf 。
# 配置
字段 | 类型 | 说明 | 默认值 |
---|---|---|---|
jsScript | string | js脚本 | 无 |
jsScript
:可以对msg、metadata、msgType进行过滤。该字段是以下函数体内容function Filter(msg, metadata, msgType) { ${jsScript} }
1
2
3- msg:消息内容,如果dataType=JSON,类型是:
jsonObject
,可以使用msg.temperature
方式操作。如果dataType是其他类型,该字段类型是:string
- metadata:消息元数据,类型:
jsonObject
- msgType:消息类型
- 函数返回值类型:
boolean
,决定和下一个节点的连接关系(Relation Type
)
- msg:消息内容,如果dataType=JSON,类型是:
注意
jsScript
脚本一定要有返回值,return true/false;
脚本执行超时时间配置参考: config.ScriptMaxExecutionTime
# Relation Type
- True: 把消息发送到
True
链 - False: 把消息发送到
False
链 - Failure: 执行失败,把消息发送到
Failure
链
# 执行结果
该组件不会改变msg
、metadata
和msgType
内容。
# 配置示例
{
"id": "s1",
"type": "jsFilter",
"name": "过滤",
"configuration": {
"jsScript": "return msg.temperature > 50;"
}
}
1
2
3
4
5
6
7
8
2
3
4
5
6
7
8
# 应用示例
如果msgType是:EVENT_APP1,则把消息推送到:http://192.168.136.26:9099/app1/api/msg,否则推送到:http://192.168.136.26:9099/app2/api/msg
{
"ruleChain": {
"id":"rule01",
"name": "测试规则链",
"root": true
},
"metadata": {
"nodes": [
{
"id": "s1",
"type": "jsFilter",
"name": "过滤",
"configuration": {
"jsScript": "return msgType =='EVENT_APP1';"
}
},
{
"id": "s2",
"type": "restApiCall",
"name": "推送数据-app2",
"configuration": {
"restEndpointUrlPattern": "http://192.168.136.26:9099/app1/api/msg",
"requestMethod": "POST",
"maxParallelRequestsCount": 200
}
},
{
"id": "s3",
"type": "restApiCall",
"name": "推送数据-app2",
"configuration": {
"restEndpointUrlPattern": "http://192.168.136.26:9099/app2/api/msg",
"requestMethod": "POST",
"maxParallelRequestsCount": 200
}
}
],
"connections": [
{
"fromId": "s1",
"toId": "s2",
"type": "True"
},
{
"fromId": "s1",
"toId": "s3",
"type": "False"
}
]
}
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
在 GitHub 上编辑此页 (opens new window)
上次更新: 2024/09/24, 16:40:39