Question

I m trying to get all index document using python client but the result show me only the first document This is my python code :

res = es.search(index="92c603b3-8173-4d7a-9aca-f8c115ff5a18", doc_type="doc", body = {
 size  : 10000,
 query : {
     match_all  : {}
}
})
print("%d documents found" % res[ hits ][ total ])
data = [doc for doc in res[ hits ][ hits ]]
for doc in data:
    print(doc)
    return "%s %s %s" % (doc[ _id ], doc[ _source ][ 0 ], doc[ _source ][ 5 ])

Answer 1

尝试“思想”而不是“思想”

res = es.search(index="92c603b3-8173-4d7a-9aca-f8c115ff5a18", doc_type="_doc", body = {
 size  : 100,
 query : {
     match_all  : {}
}
})

Answer 2

缺省研究只能检索10份文件。您可改变这一行为:doc here。 agi学的最佳做法是:rel=“nofollow noreferer”>search after query and scroll query/code<>/><>>。这取决于你们的需要。请阅读这一答案:。



展示所有成果:

for doc in res[ hits ][ hits ]:
    print doc[ _id ], doc[ _source ]

Answer 3

也可以使用<条码>弹性研究-dsl及其检索标本,使您能够通过<条码><><>>>查询所有文件。

import elasticsearch
from elasticsearch_dsl import Search

client = elasticsearch.Elasticsearch()
search = Search(using=client, index="92c603b3-8173-4d7a-9aca-f8c115ff5a18")

for hit in search.scan():
    print(hit)

Answer 4

you can find info from here https://discuss.elastic.co/t/get-all-documents-from-an-index/86977/5

es = Elasticsearch(["http://x.x.x.x:9200/"])
doc = {"size": 10000, "query": {"match_all": {}}}

resObj = es.search(index="myIndex", doc_type="myType", body=doc, scroll="1m")

download_alldata = []
download_alldata.extend(resObj["hits"]["hits"])

total_data_size = resObj["hits"]["total"]["value"]

allbar = tqdm(total=total_data_size, desc="processing")

download_data = []
download_data.extend(resObj["hits"]["hits"])
allbar.update(len(resObj["hits"]["hits"]))

while True:
    try:
        i = es.scroll(scroll_id=resObj["_scroll_id"], scroll="1m")["hits"][
            "hits"
        ]

        download_data.extend(i)
        # print(t)
        allbar.update(len(i))

        if len(i) == 0:
            break
    except Exception as e:
        break
    
    
print(len(download_data))

Answer 5

你可以尝试以下提问。它将归还所有文件。

result = es.search(index="index_name", body={"query":{"match_all":{}}})

Answer 6

我急切地看到,如果你只增加数据,就必须更新该指数。使用:

es.indices.refresh(index="index_name")

友情链接