节点组
groupAction
组件:节点组。 把多个节点组成一个分组,异步执行所有节点,等待所有节点执行完成后,把所有节点结果合并,发送到下一个节点。类似子规则链
如果匹配到Config.MatchNum
个节点Config.MatchRelationType
指定类型,则把数据到Success
链, 否则发到Failure
链。
# 配置
字段 | 类型 | 是否是必填 | 说明 | 默认值 |
---|---|---|---|---|
matchRelationType | string | 否 | 匹配组内节点关系类型 | Success |
matchNum | int | 否 | 匹配满足条件节点数量 | 0 |
nodeIds | string | 是 | 组内节点ID列表,多个ID与, 隔开 | - |
timeout | int | 否 | 执行超时,单位秒,默认:0代表不超时 | 0 |
matchNum: 匹配满足条件节点数量
- 默认0,表示组内所有节点都是
matchRelationType
指定类型,发送到Success
链,否则发送到Failure
链。 - matchNum>0,则表示任意匹配到
matchNum
个节点是matchRelationType
指定类型,发送到Success
链,否则发送到Failure
链。 - matchNum>=len(nodeIds),则等价于matchNum=0
# Relation Type
Success: 把消息发送到
Success
链Failure: nodeIds为空、执行超时或者节点执行失败,发送到
Failure
链metadata: 合并每个结束节点处理后的metadata,如果相同key则覆盖。
data: 把每个结束节点处理后的消息封装成WrapperMsg数组。 WrapperMsg:
字段 | 类型 | 说明 | 默认值 |
---|---|---|---|
msg | types.RuleMsg | 消息 | 无 |
err | string | "" | |
nodeId | string | 最后的处理节点 | "" |
# 配置示例
//注意:规则链从第三个节点开始触发。firstNodeIndex=2
{
"ruleChain": {
"id": "rule01",
"name": "测试规则链",
"root": true
},
"metadata": {
"firstNodeIndex": 2,
"nodes": [
{
"id": "s1",
"type": "functions",
"name": "组件1",
"debugMode": true,
"configuration": {
"functionName": "groupActionTest1"
}
},
{
"id": "s2",
"type": "functions",
"name": "组件2",
"debugMode": true,
"configuration": {
"functionName": "groupActionTest2"
}
},
{
"id": "group1",
"type": "groupAction",
"name": "action组",
"debugMode": true,
"configuration": {
"matchRelationType": "Success",
"nodeIds": "s1,s2"
}
},
{
"id": "s3",
"type": "log",
"name": "记录日志",
"debugMode": false,
"configuration": {
"jsScript": "return msg;"
}
}
],
"connections": [
{
"fromId": "group1",
"toId": "s3",
"type": "Success"
}
]
}
}
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
52
53
54
55
56
57
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
52
53
54
55
56
57
在 GitHub 上编辑此页 (opens new window)
上次更新: 2024/10/23, 10:13:01