将Elasticsearch结果导出到CSV文件

您可以使用csv模块写入数据。

从您给出的输出中，我假设您要将数据从中写入

_source

代码：

from elasticsearch import Elasticsearchimport csves = Elasticsearch(["9200"])# Replace the following Query with your own Elastic Search Queryres = es.search(index="search", body=     {         "_source": ["DTDT", "TRDT", "SPLE", "RPLE"],         "query": {  "bool": {      "should": [          {"wildcard": {"CN": "TEST1"}}      ]  }         }}, size=10)with open('mycsvfile.csv', 'w') as f:  # Just use 'w' mode in 3.x    header_present  = False    for doc in res['hits']['hits']:        my_dict = doc['_source']         if not header_present: w = csv.DictWriter(f, my_dict.keys()) w.writeheader() header_present = True        w.writerow(my_dict)