有人可以解釋當Lambda訂閱Kinesis項目創建事件時發生的事件。 AWS賬戶中有100個併發請求的限制,所以如果將1,000,000個項目添加到kinesis中,事件是如何處理的,他們是否會排隊等待下一個可用的併發lambda?AWS Lambda處理Kinesis Stream時的限制
10
A
回答
14
從FAQ http://aws.amazon.com/lambda/faqs/
「問:如何從Amazon的Kinesis流和亞馬遜DynamoDB流AWS LAMBDA過程數據 亞馬遜的Kinesis和DynamoDB行旅發送到您的AWS lambda表達式的記錄是嚴格系列化,每個碎片。這意味着如果您將兩條記錄放在同一個分片中,Lambda保證您的Lambda函數將在第一條記錄被第二條記錄調用之前成功調用。如果一條記錄的調用超時,被限制或遇到任何其他錯誤,Lambda將重試直到成功(或記錄達到其24小時到期),然後再轉到下一條記錄。不能保證跨不同記錄的記錄排序,並且每個分片的處理都是並行進行的。「
這意味着如果您將1M項添加到Kinesis,但只有一個分片,那麼節流無關緊要 - 您將只有一個Lambda函數實例從串行讀取該分片,這取決於批量大小指定。您擁有的分片越多,函數將看到的併發調用就越多。如果您擁有大於100個分片的流,則您提及的帳戶限額可輕鬆增加到AWS客戶支持需要的任何分數。更多細節在這裏。 http://docs.aws.amazon.com/lambda/latest/dg/limits.html
希望有幫助!
相關問題
- 1. Kinesis + AWS Lambda:監測流
- 2. AWS Kinesis Stream作爲FIFO隊列
- 3. Kinesis - 處理寫入ProvisionedThroughputExceededException
- 4. Amazon Kinesis Stream to S3
- 5. AWS Lambda/Aws批處理工作流程
- 6. 限制AWS-Lambda預算
- 7. AWS Lambda函數限制
- 8. aws lambda錯誤處理
- 9. AWS Lambda函數從kinesis流中無限讀取記錄
- 10. AWS Kinesis Stream返回「ProvisionedThroughputExceededException」時數據是否丟失?
- 11. Kinesis Lambda消費者最小批處理大小
- 12. 處理EC2描述限制在Boto3 Lambda?
- 13. AWS Lambda更快的處理方式
- 14. Kafka喜歡Kinesis Stream上的偏移量?
- 15. API網關和Lambda的地理限制
- 16. 處理來自AWS Lambda的CSRF攻擊?
- 17. aws cloudformation lambda python壞的處理程序
- 18. 在AWS中處理錯誤Lambda
- 19. AWS lambda函數不處理POST變量
- 20. AWS LAMBDA處理程序擴展S3event
- 21. AWS Lambda達到內存限制
- 22. 針對AWS kinesis處理的KCL是否線程安全?
- 23. aws kinesis流以較低的速率向lambda發送數據
- 24. AWS Lambda爪哇處理程序Hello World
- 25. AWS Lambda如何處理多個請求?
- 26. RealmResult處理時間限制
- 27. AWS Kinesis leaseOwner混淆
- 28. AWS API Gateway服務代理到Kinesis Firehose
- 29. 如何訪問AWS中的Kinesis ApproxArrivalTime Lambda表達式
- 30. 從AWS遷移Kinesis