AWS有没有办法在dynamodb流达到批量大小限制或时间限制时触发Lambda？
我试图创建一个流，使AWS DynamoDB流仅在达到批量大小限制或达到指定时间间隔（即批量大小为100，时间间隔为5分钟）时触发Lambda函数。假设只有50个记录更新，距离上次调用只有4分钟。如果记录更新未达到100，我希望在下一分钟触发lambda。如果在下一分钟之前达到100，则触发lambda并重置时钟。
我试着只使用批量大小限制。这不起作用。如果我做两次更新，它会调用lambda两次。
共有1个答案
我试图解决类似的问题。使用CloudWatch计时器每5分钟为lambda创建一个触发器。所以你有两个lambda做相同的表。确保您有一些锁，以避免两个lambda同时运行。
-
我正在尝试使用Python Selenium Chrome驱动程序实现谷歌地图的自动化，我的代码是稳定的，可以得到我需要的东西，但不是性能时间。 我使用迭代代码在Google Maps上获取商家数据，使用Selenium获取1个商家数据的时间速率低于1秒，但是当代码捕获到异常时，需要花费很长的时间，比如6-7秒。 下面是一些执行时间的总结： https://picoolio.net/image/d
-
我试图理解AWS DynamoDB的行为到底是什么。当我为表创建本地二级索引（LSI）时，文档中说，项集合有10 GB的限制。文档 它的真正含义是什么？ 假设我的数据跨3个分区，那么问题是： 每个分区对LSI或所有分区都有10GB的限制？ 如果我达到了一个限制，比方说，我继续将数据写入表中，这意味着数据将在表中，但不会被LSI看到？或者怎么做？我知道通常数据将在表中可用，但如果我通过LSI查询，它
-
问题内容： 我通过Ajax将ckeditor内容发布到php。但是在我的数据库表中得到4-5句已发布材料的句子。我想知道，ajax发布有大小限制吗？有什么办法可以通过ajax发布大文本内容？ 我的js看起来像这样 问题答案： HTTP规范没有为帖子强加特定的大小限制。它们通常会受到Web服务器或用于处理表单提交的编程技术的限制。 您使用哪种服务器？
-
问题内容： 我想知道是否有办法限制cassandra java驱动程序同时执行的查询数量？ 当前，我执行许多查询，如下所示： 不幸的是，这可能导致NoHostAvailableException。 谢谢。 问题答案： 您可以使用信号量来限制并发查询的数量： 但是到最后，情况并没有太大的不同：信号量将阻塞（如果使用定时版本的Acquisition，则抛出该信号），而不是在超出容量时得到信号。因此，您
-
是否可以限制Kafka消费者返回Spark Streaming的批的大小？ 我这么问是因为我得到的第一批记录有上亿条记录，处理和检查它们需要很长时间。
-
我不了解DynamoDb中查询/扫描限制的概念。根据文件： 单个查询操作最多可以检索1 MB的数据。在对结果应用任何FilterExpression之前，此限制适用。 假设我有10k个条目，每个条目250kb，所有条目都符合查询参数。 如果我运行一个简单的查询，我只得到4个项目？