如何将多个JSON文件添加到Elasticsearch

Question

我有一个充满JSON文件的目录，我想在Elasticsearch中索引它们。我查看了pyelastic，但我对Python和Elasticsearch都很陌生。

下面是一些代码：

from pyelasticsearch import ElasticSearch

# ElasticSearch settings
ES_CLUSTER = 'http://localhost:9200/'
ES_INDEX = 'test'
ES_TYPE = 'doc'
es = ElasticSearch(ES_CLUSTER)

es.bulk_index(ES_INDEX, ES_TYPE, ???)

- Melvin Wevers

Answer 1

这个函数被称为批量索引文档。

将它们加载到数组中，然后使用批量索引将起作用。如果有大量文档（> 1000），可以选择逐个索引。

from pyelasticsearch import ElasticSearch
import json
import os

es = ElasticSearch(ES_CLUSTER)

json_docs = []
for filename in os.listdir(os.getcwd()):
    if filename.endswith('.json'):
        with open(filename) as open_file:
            json_docs.append(json.load(open_file))

es.bulk(ES_INDEX, ES_TYPE, json_docs) 

- Kutoff