DataWorks为您提供遍历节点(for-each节点),您可以通过for-each节点来循环遍历赋值节点传递的结果集。同时您也可以重新编排for-each节点内部的业务流程。本文以一个具体示例,通过for-each节点2次循环遍历赋值节点输出结果,并在每次循环遍历时打印当前循环次数,为您介绍for-each节点的逻辑原理与操作流程。
前提条件
在配置节点前,请先了解相关介绍,避免任务配置过程出错。详情请参见for-each节点逻辑原理介绍。操作流程
使用遍历节点时,通常与赋值节点一起使用,操作流程如下所示。

- 设置节点依赖关系
for-each遍历节点需要依赖赋值节点。配置详情可参考文档:创建和配置业务流程。
- 赋值结果集
赋值节点自带的节点上下文输出参数outputs,需作为for-each遍历节点的节点上下文输入参数。配置详情可参考文档:配置赋值节点。
- 遍历节点的内部节点获取参数
根据业务需求自定义for-each遍历节点的内部业务流程,并在内部流程的节点中通过内置变量来获取所需参数值,运行循环遍历任务。内置变量的详情请参见内置变量,配置详情请参见配置for-each节点。
- 遍历节点不支持在DataStudio测试
创建和配置业务流程
您需要创建一个上游为赋值节点,下游为for-each节点的业务流程:
配置赋值节点
- 双击赋值节点名称,打开节点的编辑页面。
- 从请选择赋值语言列表中,选中SHELL。
- 在节点的编辑页面,输入以下语句。
echo 'this is name,ok';
- 单击节点编辑页面右侧的调度配置,在 区域查看默认输出的outputs参数。
- 单击工具栏中的
图标,保存赋值节点。
- 提交赋值节点。重要 您需要设置节点的重跑属性和依赖的上游节点,才可以提交节点。
- 单击工具栏中的
图标。
- 在提交新版本对话框中,输入备注。
- 单击确认。
如果您使用的是标准模式的工作空间,提交成功后,请单击右上角的发布。具体操作请参见发布任务。 - 单击工具栏中的
配置for-each节点
- 双击打开for-each节点的编辑页面,默认有start、SQL和end三个节点。
- 删除SQL节点。您可以根据自身需求,选择第2个节点为不同的类型:
- 如果您需要使用ODPS SQL节点,请跳过此步骤。
- 如果您需要使用其它类型的节点(本文以使用Shell节点为例),请先删除默认产生的SQL节点。
- 创建并编辑Shell节点。您可以通过同样的方式,新建不同类型的节点。如果您使用的是默认的SQL节点,请跳过此步骤。
- 配置for-each节点。
- 单击工具栏中的
图标,保存for-each节点。
- 提交for-each节点。重要 您需要设置节点的重跑属性和依赖的上游节点,才可以提交节点。如果您使用的是标准模式的工作空间,提交成功后,请单击右上方的发布。具体操作请参见发布任务。
测试并查看测试结果
- 单击页面右上方的运维,进入运维中心。
- 在左侧导航栏,单击 。
- 选中相应的节点,在右侧的DAG图中,右键单击赋值节点,选中 。
- 刷新补数据实例页面,待补数据实例运行成功后,单击实例后的DAG图。
- 右键单击赋值节点,选中查看运行日志,确认赋值结果。
- 在补数据实例页面,右键单击遍历节点,选中查看内部节点。
- 在内部节点页面,单击左侧的第1次,并右键单击Shell节点,选中查看运行日志。在运行日志页面,查看第1次循环时,Shell节点的日志。
- 以同样的方式,查看第2次循环时,Shell节点的日志。