Skip to main content

inserting and updating in elasticSearch using python

from elasticsearch import Elasticsearch
from elasticsearch import helpers
import time


es = Elasticsearch()

individialVideoDocs = []
docs = []

subscriberUserID = ["kishlay" , "raj"]

allVideosFullText = {
    "_index": "pipa",
    "_type": "video",
    # "_id": videoId,    "_source": {
        "SusbcriberUserId": subscriberUserID,
        "script": "alltext"}
}

docs.append(allVideosFullText)
k = helpers.bulk(es, docs)
arr = [];
time.sleep(2)
res = es.search(index="pipa", doc_type="video", body={"query": {"match": {"script": "alltext"}}})
print("%d documents found" % res['hits']['total'])

# print(res)es.indices.refresh(index="pipa")

for doc in res['hits']['hits']:
    # print("%s) %s" % (doc['_id'], doc['_source']['SusbcriberUserId']))
    arr = doc['_source']['SusbcriberUserId']
    print(arr)
    arr = ["kika","mina"]
    idResult = doc['_id']
    resOfApp = es.update(index='pipa', doc_type='video', id=idResult,
              body={"doc":{"SusbcriberUserId": arr}})
    print(resOfApp)


# es.update(index='pipa',doc_type='video',id=res.meta.id,                # body={ "SusbcriberUserId": subscriberUserID})

Comments