elasticsearch-bulk-api相关内容
使用 Elasticsearch 5.5,在发布此批量请求时出现以下错误,无法弄清楚请求有什么问题. "type": "illegal_argument_exception","reason": "格式错误的操作/元数据行 [3],预期为 START_OBJECT,但发现 [VALUE_STRING]" POST http://localhost:9200/access_log_index/a
..
我正在尝试重新索引我的 Elastic 搜索设置,目前正在查看 Elastic 搜索文档 和 使用 Python API 的示例 我对这一切是如何运作的有点困惑.我能够从 Python API 获取滚动 ID: es = Elasticsearch("myhost")索引 = "我的索引"查询 = {"查询":{"match_all":{}}}response = es.search(in
..
我必须在与我的 python 程序集成的 ElasticSearch 中存储一些消息.现在我尝试存储的消息是: d={"message":"this is message"}对于范围(1,5)中的 index_nr:ElasticSearchAPI.addToIndex(index_nr, d)打印 这意味着如果我有 10 条消息,那么我必须重复我的代码 10 次.所以我想做的是尝试制作一个脚
..
我想使用批量API将一些数据导入Elasticsearch.这是我使用Kibana开发工具创建的映射: PUT/main-news-test-data{“映射":{“属性":{“内容":{"type":"text"},“标题":{"type":"text"},“线索":{"type":"text"},“代理商":{"type":"keyword"},"date_created":{“类型":“
..
我正在尝试使用elasticsearch批量api将多个记录插入索引中.我的JSON看起来像这样:请求json 我在文档末尾插入了新行( \\ n ),但仍然出现换行错误. 错误:{“错误": {“根本原因": [{"type":"illegal_argument_exception","reason":“批量请求必须由换行符[\ n]终止"}],"type":"illegal_argum
..
我正在尝试使用Bulk API将新行JSON上载到Elasticsearch.我要上传的批量JSON如下所示,每个JSON都换行了: {"ip": "x.x.x.x", "seen": true, "classification": "malicious", "spoofable": false, "first_seen": "2020-03-31", "last_seen": "2020-
..
我使用批量更新脚本来更新嵌套字段,但这很慢: POST index/type/_bulk {"update":{"_id":"1"}} {"script"{"inline":"ctx._source.nestedfield.add(params.nestedfield)","params":{"nestedfield":{"field1":"1","field2":"2"}}}} {"up
..
我相信应该有一个公式可以计算ElasticSearch中的批量索引编制大小.以下可能是该公式的变量. 节点数 分片数量/索引 文档大小 RAM 磁盘写入速度 局域网速度 我想知道是否有人知道或使用数学公式.如果没有,人们如何决定其散装尺寸?通过反复试验? 解决方案 对此没有黄金法则.从文档中提取: 在单个批量调用中没有要执行的“正确"数量的操作.您应该尝试不同的
..
使用Elasticsearch 5.5,在发布此批量请求时收到以下错误,无法弄清请求出了什么问题. "type": "illegal_argument_exception", "reason": "Malformed action/metadata line [3], expected START_OBJECT but found [VALUE_STRING]" POST http://
..
我需要更新或删除多个文档。 当我更新时,我这样做: 我首先搜索文档,并为返回的结果设置更大的限制(例如,大小:10000)。 对于每个返回的文档,我都会进行修改 我不喜欢对整个修改后的列表(批量索引)进行弹性搜索。 该操作一直进行到点1不再返回结果为止。 删除后,我将执行以下操作: 我首先搜索文档,为返回的结果设置更大的限制(例如,大小:10000) 我删除所有
..
我在使用批量API(C#NEST v5.4)插入文档时遇到问题.我有一个文档数组,在数组中有我的ID. 我的代码是: documents = documents .ToArray(); Client.Bulk(bd => bd.IndexMany(documents, (descriptor, s) => descriptor.Index(indexName))); 如何
..
{“index”:{“_ index”:“ w“,”_ type“:”日志“,”_ id“:”325d05bb6900440e“}} {”id“:”325d05bb6900440e“,”country“:”US“,”ip“ ,“协议”:“HTTP / 1.1”,“方法”:“GET”,“主机”:“xxxxx”,“user_agent”:“Mozilla / 5.0(Windows NT 10.
..
我正在尝试重新索引我的弹性搜索设置,目前正在查看弹性搜索文档和使用Python API的例子 我有点困惑,尽管如此,我可以从Python API获取滚动ID: es = Elasticsearch(“myhost”) index =“myindex” query = {“query”:{“match_all”:{}}} response = es.search(index
..
我必须在ElasticSearch中存储一些与我的python程序集成的消息。 现在我尝试存储的消息是: d = {“message”:“这是消息” } for range_nr in range(1,5): ElasticSearchAPI.addToIndex(index_nr,d) print d 这意味着如果我有10个消息,那么我必须重复我的代码10次。
..