问题标签 [elasticsearch-bulk-api]

我正在尝试在 Elasticsearch 中为格式的 JSON 文件创建索引：

我希望字段 jobId 和tenantId 是整数。

我在 curl 命令中给出以下映射：

这不会给我一个错误。但是，它会创建新的空字段 jobId 和 tenantId 作为整数，并将现有数据作为字符串保存到 attributesInfo.jobId。systemInfo.tenantId 也是如此。我想在 Kibana 中使用这两个字段进行可视化。我目前无法使用它们，因为它们是空的。

我是 Kibana 和 Elasticsearch 的新手，所以我不确定映射是否正确。

我也尝试了其他几个映射，但它们给出了错误。上面的映射没有给出错误。

这是 Kibana 上的 Discover Tab 的样子：1

请让我知道我哪里出错了。

我有一个 JSON 文件，我需要在 ElasticSearch 服务器上对其进行索引。

JSOIN 文件如下所示：

但是当我尝试使用命令索引这个 JSON 文件时

我收到此错误：

我不知道我在哪里犯了错误。

我无法索引到 ES 的批量 API。它一直给我这个错误：

注意：我正在使用 Sense 插件

这是我要索引的数据示例

我的格式错了吗？我错过了什么？

我一直在寻找所有地方，但无法找到这个问题的合适答案。我使用以下代码创建了一个 NEST 客户端：

然后，使用它来调用批量 api。

我遇到的问题是在进行批量 api 调用时出现 OutOfMemoryException。填充 myJson 的方法创建了一个巨大的 JSON 块，但不足以引发异常（但如果它被复制，则足以引发异常）。然后，当我调用批量 api 时，它会抛出 OutOfMemoryException，因为 NEST 保留原始请求（本质上，复制 JSON 并且没有足够的内存来保留所有内容）。有没有办法调用 Bulk API，但告诉 NEST 不要保留原始请求，这样大块 JSON 就不会在内存中重复？

编辑

我正在使用 NEST 1.7.2 版和 ElasticSearch 1.7.2 版

我想在 Elasticsearch 批量上传中将请求时间设置为 20 秒或更多。默认时间设置为 10 秒，我的警告消息天数需要 10.006 秒。而且，在显示警告之后，执行会引发错误

现在，我想为每个从用户输入的请求或默认设置的任何值设置请求超时。

错误信息：

当我尝试在 cerebro 插件中发布以下代码时

它在 cerebro 插件中显示如下错误：

我使用 Bulk API 将数据导入我的 ELK 堆栈。

我在数据中有一个 ip，我想使用 GEOIP 插件将其转换为经度和纬度。

我创建了一个管道：

但是，当我导入数据时，管道被忽略了，有人可以解释我如何修改批量 API 以通过管道传递信息，以便为我添加经纬度来创建地图。

谢谢

我一直在尝试使用批量插入功能，但每次使用它都会显示一些映射错误。批量插入函数声明是否已从嵌套 1.x 更改为嵌套 5.x，因为在 5.x 嵌套文档中我没有找到 .bulk() 函数。请建议

批量插入代码：

我传递的数据列表如下所示：

}

我目前有一个 ES 查询来查找最接近纬度/经度的位置：

我希望能够在 1 个查询中针对多个纬度/经度运行此操作，这将返回与其最近位置相关的每个纬度/经度。有没有办法做到这一点？

我希望update_by_query使用我的 python elasticsearch 客户端发出请求。我希望使用索引、类型和 NOT 字段进行查询id。基于该字段，我希望更新其他一些字段，但如果该查询未返回任何结果，则应使用上述索引和类型创建一个新文档。

我可以进行搜索然后更新，但我希望只使用一个查询来完成此操作。此外，我想使用弹性搜索客户端helpers.bulk(es, result)在哪里执行多个此类操作，并且是一个 json 列表。Elasticsearch 版本是 5.4esresult