1

我正在 Talend 建立一个查询宁静服务的工作。在工作中,我发起一个工作并取回一个工作 ID。然后我查询状态服务,需要等待作业完成。我将如何在 Talend 中执行此操作?我一直在玩 tLoop、tFlowToIterate、tIterateToFlow 和 tJavaRow 组件来尝试让它工作,但不知道如何配置它。

以下是我正在尝试做的总结:

1. tRest: Start a job and get job ID
    |
    --> 2. tRest: Poll status of job
       |
        --> 3. tUnknown?: If the job is running, sleep and re-run Step 2.
               |
                --> 4. tRest: when the job is complete, retrieve the results

我将如何设置上面的第 3 步?

4

1 回答 1

1

基本上你想要类似的东西

tInfiniteLoop --iterate-->(用于查询服务并确定结果是否准备好的子作业)--if(结果已准备好)-->(用于获取结果的子作业)--on subjob ok--> tjava with "counter_tInfiniteLoop_1 = -1;" 离开循环(不知道更好的选择)

我建议实现超时或最大查找次数,甚至可能自动增加睡眠时间。

于 2013-09-19T16:08:53.940 回答