当前位置: 首页 > 知识库问答 >
问题:

如何通过AWS Lambda索引Amazon Elasticsearch服务中的Dynamodb流数据?

申高卓
2023-03-14

我一步一步地遵循本教程,但当我到达“测试结果”步骤时,我在索引时间中看不到我的表名,因为示例中显示了“所有产品”。

这意味着我的dynamodb表在我的Amazon ES域中没有索引。

我设置了所有授权并配置了lambda,就像在示例中一样。

现在我只是不知道如何在AWS ES中触发我的Dynamodb流。

共有2个答案

吴宝
2023-03-14

我只是复制了那些家伙在博客中所做的事情,因为博客中提到的Lambda函数Blueprint不再可用。

你可以在这里使用我的代码做同样的事情:https://github.com/sportarchive/dynamodb-to-elasticsearch

它使用ElasticSearch Python库,在生产环境中运行良好。它支持:插入、更新和删除以及DynamoDB中的所有数据类型

薛弘阔
2023-03-14

检查您的Dynamo DB表中是否有内容。如果没有这个,将不会发生流式传输,并且由于Elasticsearch在第一次输入某些内容时创建索引(表),这将导致索引不存在。

如果您的Dynamo DB中存在内容,则问题很可能是由于Dynamo DB和AWS Lambda之间或AWS Lambda和Elasticsearch之间的集成问题。

以下是您可以进行调试的几件事:

  • 检查您的CloudWatch日志/监控以查看lambda是否已被调用

希望这能帮助您解决问题!

 类似资料:
  • 问题内容: 从这里开始。该解决方案仅适用于一列。如何改进多列解决方案。即如果我有一个像 如何重塑像 如果df是 然后 问题答案: 采用 要么, 另外,索引不相等

  • 例如,假设我们有: 如果我这样做: 我总是得到0或1,因为它会搜索与值匹配的第一个匹配项。我如何精确地通过索引引用数组中的元素?也就是说,在这种情况下如何获得“0、1、2、3、4”?或者甚至使用多个维度的数组。

  • 问题内容: 我正在尝试使用Java从使用SFTP(而不是FTPS)的服务器检索文件。我怎样才能做到这一点? 问题答案: 另一个选择是考虑查看JSch库。JSch似乎是一些大型开源项目的首选库,其中包括Eclipse,Ant和Apache Commons HttpClient。 它很好地支持用户/通过和基于证书的登录,以及所有其他许多美味的SSH2功能。 这是通过SFTP检索的简单远程文件。错误处理

  • 如何在Laravel中检索数据。 我有表用户,其中我有字段parent_id,其中我显示其user_id的信息。 现在我想显示已登录用户的信息 我试过这个 我得到了选定的parent_id,现在我想要user_id的名字。 我在试这个 它得到一个错误。请告诉我如何在我的代码中写这个来获得父id的名称。

  • 问题内容: 我试图在把手模板内的数组中指定项的索引: 使用这个: 如果上述方法不可行,我将如何编写一个可以访问数组中特殊项目的助手? 问题答案: 尝试这个:

  • 问题内容: 在从VB.NET转换数据“ to_timestamp”和“ to_number”获得出色的结果之后,我想知道PostgreSQL是否有可能通过.NET的整数数组查询表索引? 说,我的数组充满。PostgreSQL是否有可能将包含这些索引的数据的行返回到“ odbc.reader”? 这将比我现在循环和查询5次要快得多。 像这样的东西: 如果可能的话,一个简单的查询应该是什么样子? 问题