通过批量 API、扫描和滚动重新索引弹性搜索 [英] Reindexing Elastic search via Bulk API, scan and scroll
问题描述
我正在尝试重新索引我的 Elastic 搜索设置,目前正在查看 Elastic 搜索文档 和 使用 Python API 的示例
I am trying to re-index my Elastic search setup, currently looking at the Elastic search documentation and an example using the Python API
我对这一切是如何运作的有点困惑.我能够从 Python API 获取滚动 ID:
I'm a little bit confused as to how this all works though. I was able to obtain the scroll ID from the Python API:
es = Elasticsearch("myhost")
index = "myindex"
query = {"query":{"match_all":{}}}
response = es.search(index= index, doc_type= "my-doc-type", body= query, search_type= "scan", scroll= "10m")
scroll_id = response["_scroll_id"]
现在我的问题是,这对我有什么用?知道滚动 ID 还能给我什么?文档说要使用批量 API",但我不知道 scoll_id 是如何影响这个的,这有点令人困惑.
Now my question is, what use is this to me? What does knowing the scrolling id even give me? The documentation says to use the "Bulk API" but I have no idea how the scoll_id factors into this, it was a little confusing.
考虑到我已经正确获得了 scroll_id,谁能举一个简短的例子来展示我如何从这一点重新索引?
Could anyone give a brief example showing my how to re-index from this point, considering that I've got the scroll_id correctly?
推荐答案
这里是一个使用 elasticsearch-py 重新索引到另一个 elasticsearch 节点的示例:
here is an example of reindexing to another elasticsearch node using elasticsearch-py:
from elasticsearch import helpers
es_src = Elasticsearch(["host"])
es_des = Elasticsearch(["host"])
helpers.reindex(es_src, 'src_index_name', 'des_index_name', target_client=es_des)
您还可以将查询结果重新索引到不同的索引,方法如下:
you can also reindex the result of a query to a different index here is how to do it:
from elasticsearch import helpers
es_src = Elasticsearch(["host"])
es_des = Elasticsearch(["host"])
body = {"query": {"term": {"year": "2004"}}}
helpers.reindex(es_src, 'src_index_name', 'des_index_name', target_client=es_des, query=body)
这篇关于通过批量 API、扫描和滚动重新索引弹性搜索的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!