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
Post a Comment