AWS同步/异步流

Question

在我的AWS环境中有三个步骤：

• 步骤1是同步的
• 步骤2是在步骤1之后执行的，并且是异步的，它从步骤1获取输入并对音频文件进行编码，并将编码的文件放在S3上。
• 步骤3应该在步骤2从步骤1获得输入并在步骤2中生成的S3上编码文件后执行。

我应该如何实现这一点？我想使用Step函数，但我不知道如何处理异步步骤2。

Answer 1

您可以通过实现任务活动来实现它。

活动工作者可以是运行在Amazon实例上的应用程序、AWS函数、移动设备:任何可以在任何地方建立HTTP连接的应用程序。当Step函数达到活动任务状态时，工作流将等待活动工作人员轮询任务。活动工作者通过使用GetActivityTask来轮询步骤函数，并为相关活动发送ARN。GetActivityTask返回一个响应，包括输入(任务的JSON输入字符串)和taskToken (任务的唯一标识符)。活动工作者完成其工作后，可以使用SendTaskSuccess或SendTaskFailure提供其成功或失败的报告。这两个调用使用GetActivityTask提供的GetActivityTask将结果与该任务关联起来。

步骤3应该是一个活动任务。在步骤2中调用的工作者将轮询在步骤3中创建的活动，在完成其任务后，它将根据工人的输出使用SendTaskSuccess或SendTaskFailure报告步骤3活动。