消息体(body) | - 数据清洗:数据清洗任务提供基本的算子能力,底层逻辑使用函数计算,可实现分割,映射,富化及动态路由等繁杂数据加工能力。更多信息,请参见使用函数计算实现消息数据清洗。
- 数据提取:通过 JSONPath语法提取消息中的数据,将指定的消息内容路由到目标。配置规则,请参见消息转换。
| 数据清洗 |
服务及函数名称 | 默认创建名称为RocketMQ_RocketMQ_Transform_<TemplateName>_<timestamp> 的服务和函数。当消息体(body)选择数据清洗且选择新建函数模板时,需要配置该参数。 | RocketMQ_RocketMQ_Transform_Customized_1688540172662 |
函数模版 | 选择函数模板。当消息体(body)选择数据清洗且选择新建函数模板时,需要配置该参数。- 内容分割:根据正则表达式对消息内容进行分割,将分割后的消息逐条发送至目标。
- 内容映射:根据正则表达式对消息内容进行映射处理。例如,屏蔽消息中敏感字段或将消息大小缩减至最小标准。
- 内容富化:根据富化源对消息内容进行富化。如果消息原始内容包含AccountID,处理时根据AccountID查询数据库,获得客户地域后填至源消息体中,并发送至目标服务。
- 动态路由:根据正则表达式匹配消息内容,将匹配成功的消息路由至对应目标,将匹配不成功的消息路由至默认目标。
| 内容分割 |
服务 | 选择进行数据加工的服务。当消息体(body)选择数据清洗且选择绑定现有函数时,需要配置该参数。 | test_service |
函数 | 选择进行数据加工的函数。当消息体(body)选择数据清洗且选择绑定现有函数时,需要配置该参数。 | test_function |
版本和别名 | 选择版本和别名。当消息体(body)选择数据清洗且选择绑定现有函数时,需要配置该参数。 | 版本
LATEST
|
自定义属性(Properties) | 需要投递的事件的属性。配置规则,请参见消息转换。 | 部分事件$.data.props
|
消息索引(Keys) | 需要投递的事件的属性。配置规则,请参见消息转换。 | 部分事件$.data.systemProperties.KEYS
|
消息标签(Tags) | 需要投递的事件的属性。配置规则,请参见消息转换。 | 部分事件$.data.systemProperties.TAGS
|