字段过滤器
fieldFilter
组件:字段过滤器。用于检查消息(msg)和元数据(metadata)中是否包含指定的字段,根据检查结果决定消息的路由方向(True或False链)。
# 配置
字段 | 类型 | 说明 | 默认值 |
---|---|---|---|
checkAllKeys | boolean | 是否要求所有指定的字段都存在。true:全部存在才返回true;false:存在任一字段即返回true | false |
dataNames | string | 需要检查的msg字段名列表,多个字段用逗号分隔 | 无 |
metadataNames | string | 需要检查的metadata字段名列表,多个字段用逗号分隔 | 无 |
# Relation Type
- True: 当字段检查通过时,消息将沿
True
链路径继续传递 - False: 当字段检查不通过时,消息将沿
False
链路径继续传递 - Failure: 组件执行出错时,消息将沿
Failure
链路径继续传递
# 执行结果
该组件是纯过滤组件,不会修改传入的msg
、metadata
和msgType
内容。仅根据字段检查结果决定消息的路由方向。
# 配置示例
{
"id": "s1",
"type": "fieldFilter",
"name": "字段过滤",
"configuration": {
"checkAllKeys": true,
"dataNames": "temperature",
"metadataNames": "productType,name"
}
}
1
2
3
4
5
6
7
8
9
10
2
3
4
5
6
7
8
9
10
# 应用示例
如果msg包含temperature
字段,则把消息推送到: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": "fieldFilter",
"name": "过滤",
"configuration": {
"dataNames": "temperature"
}
},
{
"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/12/22, 03:38:12