我有一堆JSON文件(100个),它们的名称分别为merged_file 1.json,merged_file 2.json等。
我该如何使用Python(elasticsearch_dsl)将所有这些文件索引到elasticsearch中?
我正在使用此代码,但似乎无法正常工作:
JSON看起来像这样:
我该怎么做才能使这个正确?
我该如何使用Python(elasticsearch_dsl)将所有这些文件索引到elasticsearch中?
我正在使用此代码,但似乎无法正常工作:
from elasticsearch_dsl import Elasticsearch
import json
import os
import sys
es = Elasticsearch()
json_docs =[]
directory = sys.argv[1]
for filename in os.listdir(directory):
if filename.endswith('.json'):
with open(filename,'r') as open_file:
json_docs.append(json.load(open_file))
es.bulk("index_name", "type_name", json_docs)
JSON看起来像这样:
{"one":["some data"],"two":["some other data"],"three":["other data"]}
我该怎么做才能使这个正确?