使用argo事件触发argo工作流中的步骤

Question

我们对不同的wf工具进行了讨论，argo脱颖而出，提供了广泛的功能，并且它是k8s原生的，但我们有长时间运行步骤的用例，我们希望基于事件的系统可以触发下一步或基于事件重试上一步(例如，远程作业的状态)，是否可以通过argo-events实现这一点？

Answer 1

为了阐明您的用例，您有一个长时间运行(如持续运行服务)的步骤，它将生成事件，以触发需要基于事件运行的步骤/工作流。这是正确的吗？

对于上面的用例，您可以使用Argo-event从外部事件触发Argo工作流，如(Github、S3、流、SNS、日历事件等)。

Answer 2

您可以将您的步骤分解为不同的argo工作流。然后利用argo事件将这些工作流捆绑在一起。例如:有相当少的方法来配置你的事件源与argo事件。您可以将gcp、pubsub或kafka主题配置为每个工作流的事件源。然后，您可以创建通过上述创建的事件源链接的管道或一系列工作流。

kafka topic1 ===> WF1 --> kafka topic2 ===> WF2 ...and等。

通过执行此操作，您只需向相应主题发送一条消息，即可重试任何工作流。

Answer 3

可以，您可以定义'when‘情况，并根据一些输出执行上一步。

例如，this example展示了如何不断地抛硬币，直到它的正面。注意，当它的尾部时，它再次调用“coinflip”模板-有点像递归的概念。