Cadence工作流中外部状态转换的轮询

Question

我有一个 Cadence 工作流，我需要轮询外部 AWS API，直到特定资源转换，这可能需要一些时间。我假设我应该将每个单独的“checkStatus”请求设置为活动，并让工作流执行睡眠/检查循环。但是，这意味着我的工作流历史记录中可能有无限数量的活动调用。这令人担忧吗？有没有更好的方法来实现这一点？

Answer 1

这取决于你想投票的频率。

>

对于不经常进行的轮询（每分钟或更慢），请使用服务器端重试。调用活动时指定RetryPolicy（或用于Java的RetryOptions）。在RetryPolicy中，指定指数系数1和轮询频率的初始间隔。然后，如果轮询的资源未就绪，并且服务器将在指定的重试策略过期时间间隔内重试，则使活动失败。

对于每几秒钟或更快的非常频繁的轮询，解决方案是在活动实现中实现轮询，作为一个循环进行轮询，然后在轮询间隔内Hibernate。为了确保在工作者失败/重启的情况下及时重启轮询活动，该活动必须在每次迭代时心跳。使用适当的RetryPolicy来重新启动此类失败的活动。

在极少数情况下，当轮询需要定期执行一系列活动或活动参数时，应在两次重试之间更改，则可以使用子工作流。诀窍在于，父母不知道孩子打电话继续作为新人。它只有在孩子完成或失败时才会收到通知。因此，如果子级在循环中执行活动序列，并且定期作为新调用继续，则在子级完成之前，父级不会受到影响。