postgresql 基于条件迭代Talend作业

tjjdgumg  于 2023-06-05  发布在  PostgreSQL
关注(0)|答案(1)|浏览(170)

我在PostgreSQL数据库中有一个控制表。一些示例数据如下所示:

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

我有几个staging表的每个ddu_area的。总共有5个不同的ddu_area。我想一次传递一个id并执行我的ETL,要传递的id应该具有status_flag为0。当status_flag为1时,它应该获取该特定id并将其传递给ETL作业,并将数据从暂存到目标。
我不知道我们是否有这个功能在Talend或没有。我是新来的Talend。在SSIS中,我们可以使用For Each循环容器来实现这一点。接下来我可以尝试什么?

jqjz2hbq

jqjz2hbq1#

您必须使用tFlowToIterate组件迭代每个记录,然后使用tRunJob组件通过各种方式传递参数,您可以看到其中的一些here
你的工作流程应该是这样的。

tFlowToIterate--if----tRunJob

相关问题