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'], do...