Kinesis流到AWS lambda

Question

我目前正在使用DynamoDB流，并期待着转向Kinesis流，因为我想控制我喜欢从流中处理的记录数量。

我一直在读有关Kinesis流和lambda的文章。有很多关于Kinesis流和EC2的多用户和KCL等的文章。

null

Answer 1

您可以订阅lambda到Kinesis流。当您订阅时，您可以指定批大小，我记得是1到1000。当有多达批处理大小的可用记录时，将为流中的每个碎片调用lambda。如果lambda出错（例如返回错误或超时），将使用相同的数据重试。它将被重试，直到成功或记录退出流为止。如果有可用的记录，lambda将在每秒每个碎片中调用一次。lambda是用批大小范围内可用的任何记录调用的。

每个碎片只有一个并发的lambda调用。这是为了保证分片内记录的顺序。

通常，Kinesis流的行为与DynamoDB流相同。