处理一次,按规则送往多个目标。

图形编排、源码和样本调试,让处理规则清晰可见。

编辑与验证

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 丢弃不同。设计默认目标,避免数据没有可用交付路径。