处理一次,按规则送往多个目标。
图形编排、源码和样本调试,让处理规则清晰可见。
编辑与验证
Pipeline 使用 Platypus。图形、快捷指令和源码视图同步,支持 .ppl 导入导出。按信号类别配置脚本,发布前由 Go 执行器校验。
样本调试验证处理逻辑,不等于上游连接验证,也不会发送到真实 Destination。
set_tag("env", environment)
set_tag("service", service)
set_tag("processed", "yes")组合条件与目标集合
分流在 Pipeline 之后读取 Tag。每条规则可以组合 all(AND)或 any(OR)条件,并绑定一个或多个目标。规则按顺序匹配;未匹配记录使用默认目标。
默认目标是一组目标,不是自动附加到每个命中规则的目标。只需输出字段发生变化,不一定改变 Tag;请显式 set_tag。
{
"when": {
"match": "all",
"conditions": [
{
"tag": "env",
"value": "production"
},
{
"tag": "service",
"value": "checkout"
}
]
},
"destination_ids": [
"dataway-primary",
"search-primary"
]
}多目标独立投递
Pipeline 的处理结果复制到所选目标的独立持久分支。一个目标失败不会要求其他目标重新发送。目标的信号筛选发生在分流之后,应覆盖每种需要保留的数据。
分流匹配失败与 Pipeline 丢弃不同。设计默认目标,避免数据没有可用交付路径。