我有一堆JSON文件(100个),它们被命名为merged_file 1.json、merged_file 2.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)
Run Code Online (Sandbox Code Playgroud)
JSON 如下所示:
{"one":["some data"],"two":["some other data"],"three":["other data"]}
Run Code Online (Sandbox Code Playgroud)
我该怎么做才能使这个正确?