 条件分支
条件分支
  switch组件:条件分支组件。根据配置的条件表达式列表,依次匹配每个case表达式,当匹配成功时停止匹配并将消息转发到对应的路由链。如果所有case都匹配失败,则转发到默认的Default链。
# 配置
| 字段 | 类型 | 说明 | 默认值 | 
|---|---|---|---|
| cases | Case列表 | 条件表达式列表 | 无 | 
Case配置项:
| 字段 | 类型 | 说明 | 默认值 | 
|---|---|---|---|
| case | string | 条件表达式 | 无 | 
| then | string | 路由关系名称 | 无 | 
条件表达式使用 expr (opens new window) 表达式引擎,支持以下内置变量:
- id- 访问消息ID
- ts- 访问消息时间戳(毫秒)
- data- 访问消息原始内容
- msg- 访问消息体。如果消息的dataType是JSON类型,可以通过- msg.field方式访问字段,例如:- 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')
- msg.humidity >= 80 || msg.temperature >= 30
更多expr表达式语法和函数请参考:expr语言定义 (opens new window)
# Relation Type
- Case.then: 当匹配到某个case表达式时,消息将被路由到该case配置的then关系链
- Default: 当所有case表达式都匹配失败时,消息将被路由到Default关系链
- 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)
  上次更新: 2025/09/02, 11:02:23
