数据集成模块流程组件之条件分发介绍

作者:坚乃


在数据集成的过程中,在一些场景下,需要对上游数据进行分发操作,条件分发组件可对上游数据根据配置条件进行分发,本文将介绍如何进行条件分发组件的配置。


1 组件说明

用于将上游数据按照条件分发给下游两个组件。

2 原理说明

根据配置的条件,对上游数据进行路由分发,如果条件为true,则该记录发送连接为true的下游,如果条件为false,则该数据发送连接为false的下游。

3 使用说明

当条件分发组件链接下游输出组件时,会弹出数据发送方式设置的弹窗,根据实际情况配置两种条件对应的输出。

数据集成模块流程组件之条件分发介绍

此处需要注意的是 ,下游仅支持一个true节点一个false节点,当下有选择了多个true节点或false节点的时候,仅最后一次添加的输出组件有效

数据集成模块流程组件之条件分发介绍

如上图所示、分别可以配置步骤名称、分发的条件以及对应下游输出组件的输出字段信息

  • 步骤名称
    • 步骤名称为组件步骤名称,必填且根据实际情况进行命名。对实际运行无影响。
  • 合并逻辑配置
    • 分发的条件根据实际业务情况,配置具体的逻辑。例如图上所示,配置area_code > 1 满足该条件则为true 输出到MySQL_2的输出组建中、否则false输出到MySQL_3组件中
  • 输出字段配置
    • 输出字段为下拉选项。选项内容为下游的输出组件,选择对应的输出组件可以配置对应的输出字段。
    • 可以针对实际业务删除不必要的字段或输出所有字段。

数据集成模块流程组件之条件分发介绍

4 配置说明

对pipeline生成的配置json参数进行说明,其中较为重要的如下

{
          "negated": false,
          "conditions": [
            {
              "function": "=",
              "leftValue": "base_project_id",
              "negated": false,
              "rightValue": "project_id",
              "value": {
                "isNull": false,
                "name": "constant"
              }
            }
            }
          ]
        }


  • condition
    • 描述:配置路由条件
    • 必选:是
  • sendFalseTo
    • 描述:条件为false时发送的下游步骤
    • 必选:是
  • sendTrueTo
    • 描述:条件为true时发送的下游步骤
    • 必选:是

5 特别注意

条件分发组件下游仅支持一个true节点一个false节点,当下有选择了多个true节点或false节点的时候,仅最后一次添加的输出组件有效

上一篇:端智能系列文章|端侧复杂事件实时处理框架


下一篇:智能手表也不安全?可能泄露用户密码