AWS Step Function 成为 AWS Kinesis Data Stream 消费者

Question

我是 AWS 生态系统的新手，我正在尝试设计一个涉及将数据从 AWS Kinesis Data Stream 发送到 AWS Step Function 的 POT。我知道我可以创建一个 Lambda 函数来使用 Kinesis 数据流并从该 Lambda 调用 Step Function，但我很好奇我是否可以绕过 Lambda 并让 Step Function 直接使用 Kinesis 数据流。在 Step Function 设计器中，您可以使 Kinsis Data Stream 的 GetRecords API 成为一个状态。

但是一旦添加，就无法将该状态指向我在配置中可以看到的特定流。我找不到任何关于如何使 AWS Step Function 成为 Kinesis Data Stream 消费者的文档或示例。作为 AWS 的新手，我对两件事感到好奇：

• 这样可以吗
• 如果可能，从架构的角度来看，这是一个好主意。

Answer 1

没有。不能作为 Kinesis Data Streams 消费者直接调用 Step Functions。

参考资料：

• Step Functions 文档：从其他服务调用 AWS Step Functions
• Kinesis 文档：从 Amazon Kinesis Data Streams 读取数据

Answer 2

您现在可以使用在 re:Invent 2022 上发布的 EventBridge Pipes 执行此操作。

Pipes 允许您配置源（包括 Kinesis Data Streams）和目标（包括 Step Functions），然后它将负责从您的流中进行轮询并可靠地将事件传递到目标。您可以选择在通过管道的过程中过滤和丰富数据。

有关使用 Kinesis Data Streams 配置管道的更多信息，请查看此文档页面。