49得票3回答
如何使用DynamoDB进行基本聚合?

如何在DynamoDB中实现聚合?MongoDB和Couchbase支持MapReduce。 假设我们正在构建一个技术博客,在这个博客中用户可以发布文章,且文章可以被标记。user { id : 1235, name : "John", ... } article ...

44得票3回答
Kinesis Stream和DynamoDB Streams之间的区别是什么?

他们似乎对我做着同样的事情。有人能解释一下它们之间的区别吗?

25得票5回答
AWS Glue:如何处理具有不同模式的嵌套JSON数据?

目标: 我们希望使用AWS Glue数据目录在S3存储桶中为JSON数据创建一个单一的表格,然后通过Redshift Spectrum进行查询和解析。 背景: JSON数据来自DynamoDB Streams,并且具有深度嵌套结构。 JSON的第一级具有一组一致的元素:Keys、NewIma...

23得票1回答
Python中的Dynamodb流

我想在Python中从DynamoDB流中读取数据,到目前为止我发现的替代方案有: 使用DynamoDB流低级库函数(如此处所述):然而,在生产环境中维护应用程序必须维护分片等状态,这个解决方案似乎几乎不可行。 使用用于读取Kinesis流的KCL库:该库的Python版本似乎无法从Dyn...

20得票1回答
本地DynamoDB的流支持?

我似乎无法在DynamoDB本地环境中启用流支持,它们是否受支持?我能找到的唯一迹象是在本地差异开发人员指南的最后一个要点中: “如果使用DynamoDB Streams,则创建分片的速率可能会有所不同。在DynamoDB网络服务中,分片创建行为部分受表分区活动的影响。当在本地运行Dynam...

20得票3回答
DynamoDB streams如何将记录分配到分片?

我的目标是确保DynamoDB流发布的记录按照“正确”的顺序进行处理。我的表包含客户事件,哈希键是事件ID,范围键是时间戳。“正确”的顺序意味着同一客户ID的事件按顺序处理。不同客户ID可以并行处理。 我通过Lambda函数消费流。每个分片自动创建消费者。因此,如果运行时决定对流进行分片,则...

19得票2回答
单个DynamoDB流上的多个AWS Lambda函数

我有一个Lambda函数,它配置了多个DynamoDB流作为事件源,并且这是一个更大流程的一部分。在我的检查中,我发现一个下游组件中有一些缺失的数据。我想编写一个更简单的Lambda函数,它被配置为前面提到的DynamoDB流的事件源之一。这将导致我的一个DynamoDB流有两个Lambda函...

17得票8回答
如何从DynamoDB流的新图像中获取纯Json字符串?

我有一个启用了流式处理的Dynamodb表,并为该表创建了一个触发器,调用一个AWS Lambda函数。在lambda函数内部,我试图从Dynamodb流中读取新图像(修改后的Dynamodb项),并尝试获取其中的纯json字符串。我的问题是如何获得通过流发送的DynamoDB项的纯json字...

17得票3回答
DynamoDb: 扫描查询未返回所有数据

我有一个包含数千条数据的DynamoDb表。我使用Scan函数扫描该表,并应用了“Between”FilterExpression。然而,查询响应仅返回3条记录,而应该返回约100条记录。 我使用Node js创建了Lambda函数。

16得票3回答
DynamoDB:列出所有分区键

我想更新DynamoDB中的内容,为此需要迭代表中已有的分区键。有没有办法使用Python仅获取分区键列表。扫描和查询仅适用于我的表属性。有没有办法获取表的所有分区键?