我正在编写Lambda函数，该函数处理来自DynamoDB流的项。
对于基于流的事件源(和DynamoDB流)，AWS轮询您的流并调用您的Lambda函数。因此，如果Lambda函数失败，AWS Lambda将尝试处理错误的一批记录，直到数据过期时
浏览 0提问于2018-04-24得票数 8
回答已采纳
我不清楚为什么我刚刚在我的DynamoDB流上重新创建的基于lambda的触发器已经停止运行。根据，我知道我的单个DynamoDB实例上的流同步地发送有效负载，在上一批完成之前不会调用后续批。禁用以前的dynamodb流；
重新创建绑定到同一个lambda的触发器(批处理大小为5000)。无论是轮询流并将这些批发送到我的lambda的lambda不是轮询，或者
浏览 1提问于2017-02-09得票数 1
我使用Lambda函数从dyanmoDB streams中读取数据。Lambda从流读取项，并为每个批处理调用一次lambda函数。Lambda使用事件源映射同步调用lambda函数。我从aws文档中了解到的是，Lambda为流中的每个批处理调用一个lambda函数。假设流中有1000个项目，我将lambda函数配置为批量读取100个项目。那么它会同时调用10个lambda函数来处
浏览 13提问于2019-11-14得票数 0
1回答
我们的目标是建立冷和热层的Lambda架构。冷(批)层将用Apache (PySpark)实现。但是对于热(流)层有不同的选择:火花流或Flink。因此，Apache是纯流的，而不是Spark的微批，我倾向于选择Apache。但我唯一关心的是PyFlink的性能。PySpark流的延迟会更少吗？它比Scala编写的Flink代码慢吗？
浏览 3提问于2021-11-05得票数 1
回答已采纳
我有一个Lambda函数，它将DynamoDB流消息推送到SNS。如果我将批处理大小设为10，它能组合两种不同流的记录吗？如果我将批处理大小设为10，那么lambda将创建2个批(每个流一个)，或者将两个流的对象组合在一起，并将它们放在单个批处理下。假设这两条溪流同时撞击Lambda。
浏览 4提问于2020-09-10得票数 0
回答已采纳
当创建Lambda时，每个碎片的并发批数被设置为10。当流数据出现尖峰时，并发数将增加到10。这意味着我们将有10个lambdas并行工作。在这种情况下，我的问题是，我们如何保证能够顺其自然地处理事件流？在我看来，这样做是不可能的，因为我们无法控制并发货币。有人能想到这个主意吗？我的头转不开了。
浏览 6提问于2022-06-28得票数 0
回答已采纳
我有一个lambda函数，它从DynamoDB的事件流中提取数据。在lambda函数中，我对一个内部API端点进行REST调用。Lambda当前的超时设置为60秒。问题:日志中的我注意到，Lambda偶尔会抛出一个超时异常。这可能是因为我的API没有在60秒内处理请求。问题:我想了解的是，如果lambda超时，那么发送到内部/ REST调用的事件和调用会发生什么情况。这些调用/事件会被重新尝试并再次发送到API吗？
浏览 6提问于2022-03-08得票数 0
回答已采纳
2回答
能保证交货吗？
、、
我正在搜索Kinesis数据流的文档，但找不到明确的语句，比如
从生产者端，我期望发送的消息从消费者端传播到多个节点(类似于Kafka的ack=all) --我期待的是在用户成功处理时
浏览 3提问于2021-01-07得票数 2
回答已采纳
我有这个装置以下是我想做的事：
DynamoDBStream触发Lambda2。批次大小是100。因此，根本原因似乎DynamoDBStream没有并行地触发Lam
浏览 3提问于2017-09-24得票数 1
回答已采纳
2回答
我有一个Lambda，它的事件源指向KinaseStream使用者(有任意数量的碎片)1,2,1,3,4,1,2,1谢谢
浏览 7提问于2020-08-19得票数 1
回答已采纳
1回答
假设我有一个带有JSON数据的Kinesis流(假设每隔几分钟就会插入几千条消息)。现在有一个Lambda函数，每次将一个新的msg插入到Kinesis中时都会调用它，它读取msg，并在插入Redshift之前进行一些处理。那么，如果出现一些错误，而Lambda函数在处理过程中崩溃，并且需要几分钟甚至几个小时(我不知道这是否可能)，那么会发生什么呢？
浏览 0提问于2018-12-12得票数 2
1回答
然后将记录传递到DynamoDB流和lambda进行处理。然而，有些时候，lambda收到的事件是不正常的。我理解这种行为，因为从DynamoDB的角度来看，所有3个事件都是同时编写的。但是，如果这些事件是同一批的一部分，那么在处理之前，我总是可以在lambda中重新排序它们。
然而，这正是问题所在。尽管这些记录是在单个事务中编写的，但在lambda中，它们并不总是一起出现在同一批中。有时，我收到C作为唯一的事件，然后A，B到达一批稍后。我认为这种行为
浏览 3提问于2020-07-16得票数 0
回答已采纳
我已经通过流将lambda连接到DyDB表。当记录写入表时，它会触发lambda。交通非常繁忙，所以暂时什么也不会发生，然后我会写几千张唱片。我看到的是一些lambda实例将被触发，但不足以处理突发事件。然后，在随机时间，lambda实例的数量将跳升一个或两个数量级(从2到90或更多)，并将迎头赶上。我试过的东西
批次写入表(一批</
浏览 1提问于2018-10-16得票数 3
我在lambda中设置了一个sqs触发器将SQS队列设置为 sqs_client = boto3.client(running") 'sta
浏览 2提问于2021-02-15得票数 2
回答已采纳
我想简单地禁用lambda重试，当它是由一个动能触发器启动。如果lambda失败或退出，我不希望它重试。
浏览 4提问于2018-12-06得票数 0
1回答
队列
、、
我们使用AMAZON队列来处理我们的应用程序的预约服务。一旦消息进入队列，它就会触发Amazon函数来管理预订过程。因为它是一个FIFO队列，我们确保如果两个人请求相同的时隙，这个时隙将被分配给第一个请求者。我的问题是:有没有一种方法(可能是在SQS队列中设置？)这可以确保一条消息在上一条消息完成执行之前不会触发Amazon函数。我只是试图避免需要编写额外的逻辑(某种类型的插槽锁定系统)，以确保在第一次完成“预订”过程之前，相同的时隙不会被2条背对背消息瞄准。谢谢。
浏览 1提问于2018-11-07得票数 2
AWS目前提供3种目的地选择：
如果将记录作为连续查询或滑动窗口发送到数据分析应用程序中的应用程序中的目标
浏览 0提问于2018-03-28得票数 3
通过以异步方式提交~5k sns请求，我正在以批量方式调用数据处理lambda。这将导致所有请求在很短的时间内访问sns。我注意到的是，我的lambda似乎有确切的5k错误，然后似乎“醒来”，并处理负载。
浏览 0提问于2018-10-16得票数 1
回答已采纳
1回答
我有一个Lambda，它被配置为Kinesis数据流的使用者，批处理大小为10,000 (最大)。lambda解析给定的记录并将它们插入Aurora (使用INSERT命令)。不知怎么的，我发现大部分时间都是使用相对较少的记录(少于200条)调用lambda，尽管“IteratorAge”一直很高(大约60秒)。记录以随机分区键(生成为uuid4)和大小放入流中。我认为，如果使用更大的批调用Lambda，则可以防止延迟。
注意:也有一个作为消费者配置的KinsisFire软管(似乎没有任
浏览 1提问于2018-12-05得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
