将 Elasticsearch 结果导出到 CSV 文件中

Question

我正在尝试将使用以下查询找到的结果导出到我桌面上的 CSV 文件中。

这是我第一次使用 Elasticsearch 和 cURL，所以我对如何操作感到困惑。

from elasticsearch import Elasticsearch

es = Elasticsearch(["9200"])

# Replace the following Query with your own Elastic Search Query
res = es.search(index="search", body=
                {
                    "_source": ["DTDT", "TRDT", "SPLE", "RPLE"],
                    "query": {
                        "bool": {
                            "should": [
                                {"wildcard": {"CN": "TEST1"}}

                            ]
                        }
                    }
}, size=10)

for doc in res['hits']['hits']:
    print(doc)

现在当我运行这个查询它 returns 戴夫的姓名、姓氏、地址和性别时，我想在我 [=29] 时将结果放入我桌面上的 csv =]查询。

我一直在阅读这个 link 如何做到这一点，但我不确定如何让我的查询做到这一点 - (https://docs.python.org/3/library/csv.html)

有人可以帮助并告诉我如何在导出 csv 时转换我的查询吗？

谢谢

我得到的输出是 -

{'_index': 'search', '_type': 'trades', '_id': '179299804977823744', '_score': 1.0, '_source': {'DTDT': '20170928', 'SPLE': '1001', 'RPLE': '1001', 'TRDT': '2017-09-28 17:01:19'}}

Answer 1

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

根据您给出的输出，我假设您想将数据从 _source 写入 csv 文件。

代码：

from elasticsearch import Elasticsearch
import csv

es = Elasticsearch(["9200"])

# Replace the following Query with your own Elastic Search Query
res = 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)

将 Elasticsearch 结果导出到 CSV 文件中

Export Elasticsearch results into a CSV file

python

curl

python-3.x

elasticsearch

export-to-csv