根据条件迭代 Talend 作业

Question

我的 PostgreSQL 数据库中有一个控件 table。部分示例数据如下所示：

id    section_code    ddu_area    ddu_action    status_flag
1     4636            1           1             0
2     4636            1           2             0
3     4636            2           1             0
4     4636            2           2             0

我几乎没有 ddu_area 的 table 分期。总共有 5 个不同的 ddu_area。我想一次传递一个 id 并执行我的 ETL，要传递的 id 应该将 status_flag 设为 0。当 status_flag 为 1 时，它应该采用该特定 id 并将其传递给ETL 作业并将数据从暂存到目标。

不知道Talend有没有这个功能。我是 Talend 的新手。在 SSIS 中，我们可以使用 For Each Loop 容器来做到这一点。谁能帮我解决这个问题？

Answer 1

您必须使用 tFlowToIterate 组件遍历每条记录，然后使用 tRunJob 组件以各种方式传递参数，您可以看到其中的一些参数 here

你的工作流程应该是这样的。

tFlowToIterate--if----tRunJob