talend - 根据 REST 请求结果重试子作业

Question

我有一个 RESTful api 我正在尝试使用 talend 为了获取数据，需要 2 次 api 调用，首先为您的报告生成一个 ID，然后您使用该 ID 进行连续的 api 调用以获取数据结果

问题是如果第二个 api 调用中请求的报告尚未完成，它将返回

[{data:{string:"Requested report ### has not finished processing yet, please try again later"}}]

所以，我将 tJava 放入线程 (5000) 以错开第二个 api 调用 (tRestClient1) 和第一个 api 调用 (tRestClient2)，但我可以预见这是一个问题

我要做的是评估第二个 tRest 请求结果（tFileOutputJSON_3），如果它等于“请求的报告...”，则重新排队第二个 tRest 请求，直到数据准备好

这是我的工作截图

Answer 1

像往常一样，有很多解决方案。 但你离你想要的并不远。以下设计应该尊重您的期望：

我保留了你的组件，因为我真的不知道你在里面做什么（我退休了 tLogrow 以使事情简洁）。但我重新组织了调度链接。

tJava
|onSubjobOk
tRestClient --> tFileOutputJSON
|onSubjobOk
tFileInputJSON--> tExtractJSONFields --> tJavaRow
|onSubjobOk
tSetGlobalVar¹
|onSubjobOk
tLoop² -- 迭代（order1）--> tRestClient --> tHashOutput³
| -- 迭代 (order2)--> tHashInput⁴ --> tJavaRow⁵
| -- 迭代 (order3)--> tSleep⁶
|onSubjobOk
tHashInput⁷ --> tFileOutputJSON

¹：使用变量来管理循环。
²：使用 While 循环。将声明和迭代留空 ("")，并使用先前初始化的变量输入条件。³：不要使用 Append，因为您想在每个循环中获取新结果。
⁴：将其链接到您的 HashOutput 并且不清除缓存。
⁵：在这里完成您的工作。不要忘记更新全局变量。
⁶：如果大多数调用需要时间在报告准备好之前，可以放置在调用之前。
⁷：链接它也到您的 HashOutput，您将能够获取结束循环的数据。