问题标签 [amazon-dynamodb-streams]

有一个 dynamodb 表，它在触发器选项卡中有触发器。如何使用给定表的 AWS Java 开发工具包获取这些触发器的列表。我已经浏览了 JAVA SDK，但到目前为止还没有找到任何 API 来获取列表。

是否可以使用 Kinesis SDK 访问由 DynamoDBStreams 服务定义的流？例如，使用 C++，是否可以获取有关添加的流的信息，例如

和

? （这意味着“切换”服务 Kinesis 目标。AFAIK 这是不可能的，因为 Kinesis 和 DynamoDBStreams 服务是分离的，但是它们有共同的概念点。）

根据文档：

DynamoDB 通常会在过期后 48 小时内删除过期项目。过期后项目真正被删除的确切持续时间取决于工作负载的性质和表的大小

有什么方法可以估计在某个表中删除过期项目需要多长时间？我希望实现一种基于具有 TTL 的 DynamoDB 表和处理 DynamoDB 流的 Lambda 函数的调度程序，但我需要在项目过期后一小时内删除才能生效。如果表格不大（少于 1.000 个项目），这可能吗？

我有两个 dynamoDB 表，table1 和 table2，在 table1 上启用了一个流。两者都有一个名为“id”的字符串键。我还有一个 lambda 函数，它从流中读取对 table1 的插入，如果它们满足某些条件，则将它们镜像到 table2。这是我的 JS 代码（ES6 语法）不太好用：

使用此函数会出现此错误：

一个或多个参数值无效：预期键 ID 的类型不匹配：S 实际：M

该消息很容易解释，但我对此感到困惑，因为我使用的 id 应该是一个字符串。此外，是否有一种简单的方法可以按原样插入整个项目？

表有多个记录，其中 mobileNumber 列仅在少数记录中。我只需要得到那些记录。

通过这个查询，我得到了所有记录。

我在 Kibana 中遇到value了以下行中解释的字段的问题。我会试着解释一下情况。

我将 dynamoDB 流发送到 Lambda，然后发送到 Kenesis Firehouse，最后从 Firehose 发送到 Elasticsearch。我正在使用 Kibana 来可视化数据，这就是我遇到问题的地方。

假设我将此 JSON 发送到 DynamoDB：

在 Lambda 中，我收到以下信息：

如果我将最后一个 JSON 转发到 Kinesis Firehose，当我在 Kibana 中配置索引模式时，它会"timestamp"自动识别（这很棒）。这里的问题是该字段"value"就像一个字符串并且无法识别。

我尝试修改 JSON，然后将其再次发送到 Firehose，但 Kibana 无法识别"timestamp"：

我想知道如何发送这些数据，并且 Kibana 可以识别“时间戳”和“值”字段。

这是我在 lambda 中使用的代码示例：

我正在寻找一种按预定时间间隔从 DynamoDB 批量读取更新的方法。

例如，每 10 分钟我希望能够读取自上次读取以来发生的对 DynamoDB 表的所有更新。

我了解 DynamoDB 流可以设置为触发 Lambda 函数。Lambda 是否可以在特定时间间隔内批量处理所有更新？一次性全部处理？

我想实现近乎实时的文档服务搜索，这是我的想法：

1. 我计划使用 DynamoDB 作为我的主要文档存储；
2. 然后每当发生新的文档更新时，就会在 DynamoDB 流中创建一个事件；
3. 我想请 CloudSearch 提取流中的事件并更新 CloudSearch 中的索引

我的问题是如何将 DynamoDB 流与 CloudSearch 集成。我觉得我可以在两者之间使用 Lambda 函数（即触发一个 lambda 函数，它执行写入/更新索引操作，以处理流中的事件）。我会工作，但我只是觉得这可能是实现我的目标的一种昂贵方式（因为 lambda 成本 $$）。

Amazon 是否提供任何直接将 DynamoDB 流与 CloudSearch 集成的钩子？我想知道这种方法是因为下图（它清楚地暗示 CloudSearch 和 Lambda 是不同的集成点）。

dynamodb 如何实现聚合？Mongodb 和 couchbase 有 map reduce 支持。

假设我们正在构建一个技术博客，用户可以在其中发布文章。并说可以标记文章。

在用户界面中，我们要显示当前用户标签和相应的计数。

如何实现以下聚合？

我们将通过一个 rest api 提供这些数据，它会被频繁调用。就像此信息显示在应用程序主页中一样。

• 我可以考虑提取所有文档并在应用程序级别进行聚合。但我觉得我的阅读能力单位会用尽
• 可以使用 EMR、redshift、bigquery、aws lambda 等工具。但我认为这些是出于数据仓库的目的。

我想知道实现相同目标的其他更好的方法。考虑到成本和响应时间，人们如何选择 dynamodb 作为主要数据存储来实现像这样的动态简单查询。

我有一个像下面这样的对象模型。

我对我的文档进行了扫描。它通过丢失大多数属性返回对象。请参阅查询。

它返回这个对象。 [ NewModel { client_id: 'abc', code: '001', name: 'Feathered Brows', service_group: '1', time_period: 2 }, NewModel { client_id: 'abc', code: '002', name: 'Anastasia Brows', service_group: '1' }] 结果中缺少大多数属性。我的代码有什么问题。请帮忙。 dynamodb 控制台上的表格视图。