处理Kinesis流时的AWS Lambda限制

来自常见问题解答 http://aws.amazon.com/lambda/faqs/

问:AWS Lambda如何处理来自Amazon Kinesis流和Amazon DynamoDB流的数据? 发送到AWS Lambda函数的Amazon Kinesis和Dynamo DB Streams记录是严格序列化的,每个碎片都是如此。这意味着,如果将两条记录放在同一个碎片中,Lambda保证在用第二条记录调用Lambda函数之前,先用第一条记录成功调用它。如果对一条记录的调用超时、被限制或遇到任何其他错误,Lambda将重试,直到成功(或记录达到24小时到期),然后再继续下一条记录。不同碎片之间的记录顺序无法保证,每个碎片的处理都是并行的。”

这意味着,如果你有1M个项目添加到Kinesis中,但只有一个碎片,那么节流并不重要——根据你指定的批量大小,你只能有一个Lambda函数实例串行读取该碎片。碎片越多,函数的并发调用就越多。如果您有一个流>100个碎片,您提到的账户限额可以通过AWS客户支持轻松增加到您需要的任何程度。更多详情请点击此处。 http://docs.aws.amazon.com/lambda/latest/dg/limits.html

希望这有帮助!