来自同一个表的多个DynamoDB流被同一个Lambda函数消耗
我有一个Lambda函数，它将DynamoDB流消息推送到SNS。如果我把批量大小设为10，它可以合并两个不同流的记录吗？
例如：Stream1有一个由2个对象组成的数组，Stream2也有一个由2个对象组成的数组。如果我将批大小设置为10，lambda会创建2个批（每个流一个），还是将两个流的对象合并并将它们放在单个批下。假设两条流同时到达Lambda。
共有1个答案
来自DynamoDB Streams和AWS Lambda触发器-Amazon DynamoDB：
如果您在表上启用DynamoDB Streams，您可以将流Amazon资源名称（ARN）与您编写的AWS Lambda函数相关联。修改表中的项目后，表的流中会立即出现一条新记录。AWS Lambda轮询流并在检测到新的流记录时同步调用您的Lambda函数。
因此，Lambda函数仅从单个DynamoDB流检索消息。如果批量大小配置为检索多个记录，则将从同一个流中检索所有记录。
-
我有一个Lambda函数，将多个DynamoDB流配置为事件源，这是更大管道的一部分。在进行检查时，我在一个下游组件中发现了一些缺失的数据。我想编写一个更简单的Lambda函数，将其配置为前面提到的DynamoDB流之一的事件源。这将导致我的一个DynamoDB流有两个Lambda函数从中读取。我想知道这样可以吗？这两个Lamdba函数是否都能保证接收流中的所有记录，是否有任何需要注意的资源（读/
-
我有一个Kinesis生产者，它将单一类型的消息写入流。我想在多个完全不同的消费者应用程序中处理这个流。因此，给定主题/流的具有单个发布者的发布/订阅。我还想利用检查点来确保每个消费者处理写入流的每条消息。 最初，我对所有消费者和生产者使用相同的应用程序名称。但是，一旦我启动多个消费者，我就开始收到以下错误： 通用域名格式。amazonaws。服务。运动。模型InvalidArgumentExce
-
问题内容： class Match(Base): tablename = ‘matches’ 我需要编写一个查询，该查询将列和团队表连接在一起，以显示本地和客队的团队信息。 这返回 问题答案： 首先，您的代码不起作用的原因是因为SQLAlchemy不知道您是否要通过via或加入，因此您必须告诉它。此外，您需要加入两次，这使事情变得更加复杂。 使用以下命令可以更轻松地完成此操作： 并且将在相同的查询
-
如何修改此ffmpeg字符串以生成具有不同视频比特率的多个输出？这是为了在yadif=1消耗大量电力时节省时间。而且，无法让它在windows中接受yadif_cuda。 ffmpeg-y-f lavfi-i anullsrc=cl=mono:sample_rate=48000-i“test.mxf”-vf yadif=1-s 1920:1080-c:v h264-nvenc-强制关键帧“expr
-
我正在尝试编写一个简单的应用程序，其中包含一个跟踪每个用户支付的款项的表和一个包含每个用户支付的总金额（所有付款的总和）的第二个表。目前，两个表都有相同的字段（firstName、lastName、金额），我已经将它们从同一个Java类映射到多个表，我无法将该类映射到多个表。对此有什么简单的解决方案吗？
-
我正在计划一个设计，我将从同一个池中获得两个连接（plocal）。仅在一个连接上启动事务，而不在另一个连接上启动事务。我希望在同一过程中使用这两个数据库连接，并使用非事务连接进行模式调用，使用事务连接进行支持事务的记录级调用。这种方法有效吗？