分支节点实现特定时间执行任务

0.0.201

分支节点是DataStudio中提供的逻辑控制系列节点之一。本文将为您介绍如何使用分支节点，在特定时间执行任务的方法。

分支节点产生背景

Cron表达式无法实现一个节点需要每个月的最后一天执行的场景，分支节点产生后，您可以套用switch-case编程模型实现该需求。详情请参见分支节点。

分支节点与其它控制节点

在数据开发页面，您可以看到当前版本的DataWorks支持的赋值节点、分支节点和归并节点等控制节点。

各类型控制节点的作用如下：

赋值节点：您可以通过赋值节点把自己的结果传给下游，详情请参见赋值节点。
赋值节点复用了配置节点上下文依赖的特性，在已有常量和变量节点上下文的基础上，赋值节点支持自定义的上下文输出。DataWorks会捕获或打印赋值节点的查看结果，并将该结果以outputs形式作为上下文输出参数的值，供下游节点引用。
分支节点：可以决定哪些下游正常执行，详情请参见分支节点。
分支节点复用了DataWorks上依赖关系设置的输入和输出的特性，详情请参见配置同周期调度依赖。
对于普通节点，节点的输出仅仅是一个全局唯一的字符串。当下游需要设置依赖时，搜索这个全局唯一的字符串作为节点的输入即可挂到下游节点列表中。
但是，对于分支节点您可以在设置下游依赖时，选择某一个条件关联的输出作为分支节点的输出。节点在成为分支节点下游的同时，也关联到了分支节点的条件上：
- 满足该条件，该输出对应的下游才会被正常执行。
- 其它未满足条件的输出对应的下游节点，会被置为空跑。
归并节点：无论上游是否正常执行，本身都会正常调度。
未被分支节点选中的分支，DataWorks会把该分支链路上所有的节点实例置为空跑实例，即一旦某个实例的上游有一个空跑实例，它本身也会变为空跑。
DataWorks当前可以通过归并节点来阻止该空跑的属性无限制地传递下去：无论归并节点实例上游有多少个空跑的实例，归并节点都会直接成功，且不会再把下游置为空跑。

下图为存在分支节点的情况下，依赖树的逻辑关系。

ASN：一个赋值节点，用于对比较复杂的情况进行计算，以便选择分支节点的条件。
X和Y：分支节点，处于赋值节点ASN下游，根据赋值节点的输出进行分支的选择。如图中绿色线条所示，X节点选择了左边的分支，Y节点选择了左边两个分支：
- A和C节点由于在X和Y节点被选择的输出下游，因此正常执行。
- B节点虽然在Y节点被选择的分支下游，但由于X节点未选择该输出，因此B节点被置为空跑。
- E节点由于未被Y节点选中，因此即使有一个普通的Z节点上游，也同样被置为了空跑。
- G节点由于上游E节点空跑，因此即使C/F都正常执行，G节点同样空跑。
- 空跑属性什么情况下才能不再向下传递？
  JOIN节点是一个归并节点，它的特殊功能就是停止空跑属性的传递，可以看到由于D节点处于JOIN节点下游，因此B节点的空跑属性被阻断了，D节点可以开始正常跑了。

您可以通过利用分支节点配合其它控制节点，满足某个节点只有每个月最后一天运行的需求场景。

使用分支节点

定义任务依赖。
1. 根节点赋值节点通过定时时间SKYNET_CYCTIME来计算当前是否为本月的最后一天。如果是，则输出1。如果不是，则输出0。该输出会被DataWorks捕获，传递给下游。
2. 分支节点通过赋值节点的输出来定义分支。
3. 两个Shell节点挂在分支节点下，分别执行不同的分支逻辑。
定义赋值节点。
新建赋值节点时，会自带一个outputs，赋值节点支持编写SQL、SHELL和Python三种语言。
- 对于SQL类型，DataWorks捕获最后一条SELECT语句作为outputs的值。
- 对Shell和Python类型，DataWorks捕获最后一行标准输出作为outputs的值。
本文采用Python类型作为赋值节点的代码，调度属性和代码设置如下。
- 代码设置
- 调度属性配置
定义分支。
分支节点可以用Python语法的表达式定义条件，每个条件会绑定一个输出。当满足条件时，该输出的下游节点会被执行，而其它的节点会被置为空跑。
- 调度配置
- 分支配置
- 调度配置生成条件绑定的输出
将执行任务节点挂在不同分支下。
分支节点有3个输出，任意选择一个输出当作输入即可。由于现在分支节点的输出关联了条件，所以要慎重选择。
- 每月最后一天执行的节点依赖
- 每月其它时间执行的节点依赖
验证结果
完成上述所有配置后，您可以提交并发布任务。完成发布后，可以执行补数据来测试效果：业务日期选择2018-12-30和2018-12-31，即定时时间分别为2018-12-31和2019-01-01，则第一批补数据会触发最后一天的逻辑，第二批触发非最后一天的逻辑。两者的区别如下所示。
业务日期为2018-12-30（即定时时间为2018-12-31）
- 分支节点分支选择结果
- 节点（最后一天执行）正常执行
- 节点（除了最后一天之外运行）被置为空跑
业务日期为2018-12-31（即定时时间为2019-01-01）
- 分支节点分支选择结果
- 节点（最后一天执行）被置为空跑
- 节点（除了最后一天之外运行）正常执行