ES在之前的博客已有介紹，提供很多接口，本文介紹如何使用python批量導入。ES官網上有較多說明文檔，仔細研究并結合搜索引擎應該不難使用。

先給代碼

#coding=utf-8from datetime import datetimefrom elasticsearch import Elasticsearchfrom elasticsearch import helperses = Elasticsearch()actions = []f=open('index.txt')i=1for line in f: line = line.strip().split(' ') action={ "_index":"image", "_type":"imagetable", "_id":i, "_source":{  u"圖片名":line[0].decode('utf8'),  u"來源":line[1].decode('utf8'),  u"權威性":line[2].decode('utf8'),  u"大小":line[3].decode('utf8'),  u"質量":line[4].decode('utf8'),  u"類別":line[5].decode('utf8'),  u"型號":line[6].decode('utf8'),  u"國別":line[7].decode('utf8'),  u"采集人":line[8].decode('utf8'),  u"所屬部門":line[9].decode('utf8'),  u"關鍵詞":line[10].decode('utf8'),  u"訪問權限":line[11].decode('utf8')   } } i+=1 actions.append(action) if(len(actions)==500): helpers.bulk(es, actions) del actions[0:len(actions)]if (len(actions) > 0): helpers.bulk(es, actions) 

每句話的含義還是很明顯的，這里需要說幾點，首先是index.txt是以utf8編碼的，所以需要decode('utf8')轉換成unicode對象，并且“圖片名”前需要加u，否則ES會報錯

導入的速度還是很快的，2000多條記錄每秒。

以上這篇python批量導入數據進Elasticsearch的實例就是小編分享給大家的全部內容了，希望能給大家一個參考，也希望大家多多支持武林站長站。