我们为特定区域 (10-30K) 的应用用户提供实时设备信息（位置和其他一些信息）的 API。数据是实时刷新的，但是我们是通过get请求来获取的。我不知道频率是多少，但他们希望支持未来的 ML 用例。 Kinesis 在这里使用有意义吗？我是 aws 新手，不知道是否应该编写一个 lambda 函数，每分钟将其写入 s3，或者是否应该使用特定服务。谢谢！
【问题讨论】：
标签： amazon-web-services iot amazon-kinesis
Kinesis Firehose 是根据您描述的要求的最佳解决方案。
如果在此阶段不需要进行严格的数据转换，您可以将数据从 API Gateway 直接发送到 Firehose。您可以在“IntegrationRequest”阶段在 API 网关级别执行简单的转换和映射，或者只是“按原样”代理数据。
如果需要，Firehose 还可以使用一些 Lambda 转换数据，以便为 S3 做好准备。
这种架构的美妙之处在于您在这里只使用 AWS 托管服务，而无需发明自己的数据管道。
【讨论】：
sosw 包。我们使用它来编排类似的 Lambda 工作流程。文档仍然有点原始，但是一旦实施就可以省去很多麻烦。