elasticsearch

elasticsearch.py

import json
import sys
from time import sleep
from datetime import datetime
from elasticsearch import Elasticsearch, helpers

es = Elasticsearch("localhost:9200")

def create_index(index):
    es.indices.create(index=index, ignore=400)

def insert_one_data(_index, data,idkey):
    res = es.index(index=_index, id=idkey, body=data)
    print(res)

index = "huhuhuggggg"

num = 1
with open("data.json") as infile:
    for line in infile:
        try:
            dict_doc = json.loads(line.rstrip())
            insert_one_data(index,dict_doc)
            num = num + 1
        except json.decoder.JSONDecodeError as err:
            print ("error pass")