适用于长期运行的业务工作流程的 Amazon SWF

Posted 2023-02-25

【中文标题】适用于长期运行的业务工作流程的 Amazon SWF

【英文标题】：Amazon SWF for long running business workflows

【发布时间】：2012-12-13 09:06:09

【问题描述】：

我正在评估 Amazon SWF 作为构建分布式工作流系统的选项。主要语言将是 Java，因此 Flow 框架是一个显而易见的选择。只有一件事让我感到困惑，在我推荐它作为我们架构中的关键组件之前，我会得到一些其他意见：

这些示例都是关于在确定的、相对较短的时间段（即几分钟后）后产生结果的任务。在我们现实生活中的业务工作流程中，事情看起来有所不同，这里我们的任务可能需要数周才能完成。我已经检查了计算器，工作流程持续 30 天左右不会导致成本爆炸，所以似乎他们已经考虑到了这种可能性。

有没有人在这样的场景中使用过 SWF 并且可以分享任何经验？是否有任何建议，最佳实践如何设计这样的工作流程？ Flow在这里是正确的选择吗？

在我看来，Activity 实现最终会同步返回一个值，但是，对于长时间运行的事务，我们宁愿使用消息异步发回工作人员结果。

感谢任何有用的反馈。

【参考方案1】：

从Amazon Simple Workflow Service 的角度来看，活动执行是一对API 调用：PollForActivityTask 和RespondActivityTaskCompleted，它们共享一个任务令牌。这些调用不需要来自同一个线程、进程甚至主机。

默认情况下AWS Flow Framework 同步执行一个活动。使用@ManualActivityCompletion 注解表示在活动方法返回时活动未完成。此类活动应使用提供的ManualActivityCompletionClient 明确完成（或失败）。

这是取自AWS Flow Framework Developer Guide的示例：

@ManualActivityCompletion
public String getName() 
    ActivityExecutionContext executionContext = contextProvider.getActivityExecutionContext();
    String taskToken = executionContext.getTaskToken();
    sendEmail("[e-mail]", 
         "Please provide a name for the greeting message and close task with token: " + taskToken);
    return "This will not be returned to the caller";


public class CompleteActivityTask 

    public void completeGetNameActivity(String taskToken) 

        AmazonSimpleWorkflow swfClient = new AmazonSimpleWorkflowClient(…); //pass in user credentials
        ManualActivityCompletionClientFactory manualCompletionClientFactory = new ManualActivityCompletionClientFactoryImpl(swfClient);
        ManualActivityCompletionClient manualCompletionClient 
       = manualCompletionClientFactory.getClient(taskToken);
        String result = "Hello World!";
        manualCompletionClient.complete(result);
    

    public void failGetNameActivity(String taskToken, Throwable failure)         
        AmazonSimpleWorkflow swfClient
           = new AmazonSimpleWorkflowClient(…); //pass in user credentials
        ManualActivityCompletionClientFactory manualCompletionClientFactory 
           = new ManualActivityCompletionClientFactoryImpl(swfClient);
        ManualActivityCompletionClient manualCompletionClient 
           = manualCompletionClientFactory.getClient(taskToken);
        manualCompletionClient.fail(failure);
    

使用@ManualActivityCompletion 实现活动是一个实现细节。工作流代码通过相同的接口调用它，并且与同步实现的任何活动没有任何区别。

【讨论】：

谢谢，这正是我最终所做的，而且效果和宣传的一样。