elasticsearch遍历内容

Published on Aug. 22, 2023, 12:07 p.m.

from elasticsearch import Elasticsearch
from elasticsearch import helpers

es = Elasticsearch('127.0.0.1:9200')

index_v="scrapy_search-2020-11"
doc_type_v="items"

query={"query" : {"match_all" : {}}}

scanResp= helpers.scan(client= es, query=query, scroll= "10m", index= index_v , doc_type=doc_type_v , timeout="10m")

for resp in scanResp:
    qid = resp['_id']
    print(qid)
    #print(resp)

Tags: