基于信号恢复Cadence工作流，而不阻塞线程

Question

我们希望建立一个工作流程，其中包含以下步骤，在这个顺序

1. 执行一些同步活动。
2. 通过kafka事件触发外部操作。
3. 收听kafka事件以获取操作结果。
4. 根据结果执行一些其他活动。

Kafka可能包含与工作流无关的事件，因此我们需要一个单独的工作流来过滤该特定工作流的事件。

使用cadence，我计划将它分成两个工作流程

< li >工作流程1 : 1 -

是否可以在不实际阻塞线程的情况下等待 workflow1 中的信号，以便线程可以同时处理另一个工作流。

Answer 1

我有一些编写Kafka/Kinesis消费者的经验（没有与Cadence合作，但计划很快这样做）。我的感觉是，您只需要1个消费者线程被阻塞并等待来自Kafka流的新事件。并且这个消费者可以生活在任何地方，只要它可以与您的Cadence系统对话以向工作流发送信号。对于每个Kafka消息（过滤掉非相关后），如果它可以设计为包含所有信息以供消费者决定向哪个工作流发出信号，这将是非常简单的。如果您无法控制消息中的内容（听起来像是您有一个现有的流），这是一个小技巧。您的消费者可能需要根据消息中的其他标识符查找要调用的工作流

Answer 2

我认为对时间/节奏的工作原理有一些误解。不要求不阻塞线程，以便其他工作流能够取得进展。Worker实例在处理这种情况时不会有问题。

因此，我建议在工作流程中阻塞线程以等待信号，因为这是解决您的业务需求的最简单方法。

附带说明一下，我不明白为什么需要第二个工作流。不需要有工作流来过滤Kafka事件。您可以直接在Kafka消费者中执行此操作，该消费者向第一个工作流发出信号。