条件分支
switch
组件:条件分支组件。
依次匹配case表达式,如果匹配成功,则停止匹配,把消息转发到对应的路由链,如果匹配不到,则转发到默认的Default
链
# 配置
字段 | 类型 | 说明 | 默认值 |
---|---|---|---|
cases | Case列表 | 条件列表 | 无 |
Case:
字段 | 类型 | 说明 | 默认值 |
---|---|---|---|
case | string | 条件表达式 | 无 |
then | string | 路由关系 | 无 |
case
表达式支持以下变量:
- 通过
id
变量访问消息ID - 通过
ts
变量访问消息时间戳 - 通过
data
变量访问消息原始内容 - 通过
msg
变量访问消息体,如果消息的dataType是json类型,可以通过msg.XX
方式访问msg的字段。例如:msg.temperature > 50;
- 通过
metadata
变量访问消息元数据。例如metadata.customerName
- 通过
type
变量访问消息类型 - 通过
dataType
变量访问数据类型
表达式例子:
- msg.temperature > 50
- msg.temperature > 50 && metadata.customerName == 'rulego'
- upper(metadata.customerName[:4]) == 'GO'
- replace(toJSON(msg),'name','productName')
更多expr表达式语法参考: expr (opens new window)
# Relation Type
- 如果匹配到
case
,则把消息发送到then
对应值链 - Failure: 执行失败,把消息发送到
Failure
链
# 执行结果
该组件不会改变msg
、metadata
和msgType
内容。
# 配置示例
{
"ruleChain": {
"id": "bW1lMC97oYih",
"name": "测试条件分支",
"debugMode": true,
"root": true
},
"metadata": {
"endpoints": [],
"nodes": [
{
"id": "node_2",
"additionalInfo": {
"description": "",
"layoutX": 480,
"layoutY": 280
},
"type": "switch",
"name": "条件分支",
"debugMode": false,
"configuration": {
"cases": [
{
"case": "msg.temperature>=20 && msg.temperature<=50",
"then": "Case1"
},
{
"case": "msg.temperature>50",
"then": "Case2"
}
]
}
},
{
"id": "node_4",
"additionalInfo": {
"description": "",
"layoutX": 840,
"layoutY": 160
},
"type": "jsTransform",
"name": "case1",
"debugMode": false,
"configuration": {
"jsScript": "msg=msg||{}\nmsg.match='Case1'\nreturn {'msg':msg,'metadata':metadata,'msgType':msgType};"
}
},
{
"id": "node_5",
"additionalInfo": {
"description": "",
"layoutX": 840,
"layoutY": 280
},
"type": "jsTransform",
"name": "case2",
"debugMode": false,
"configuration": {
"jsScript": "msg=msg||{}\nmsg.match='Case2'\nreturn {'msg':msg,'metadata':metadata,'msgType':msgType};"
}
},
{
"id": "node_6",
"additionalInfo": {
"description": "",
"layoutX": 840,
"layoutY": 380
},
"type": "jsTransform",
"name": "default",
"debugMode": false,
"configuration": {
"jsScript": "msg=msg||{}\nmsg.match='Default'\nreturn {'msg':msg,'metadata':metadata,'msgType':msgType};"
}
}
],
"connections": [
{
"fromId": "node_2",
"toId": "node_4",
"type": "Case1"
},
{
"fromId": "node_2",
"toId": "node_5",
"type": "Case2"
},
{
"fromId": "node_2",
"toId": "node_6",
"type": "Default"
}
]
}
}
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
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
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
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
在 GitHub 上编辑此页 (opens new window)
上次更新: 2024/10/23, 10:13:01