使用python怎么批量導入數據進Elasticsearch

使用python怎么批量導入數據進Elasticsearch，相信很多沒有經驗的人對此束手無策，為此本文總結了問題出現的原因和解決方法，通過這篇文章希望你能解決這個問題。

先給代碼

#coding=utf-8
from datetime import datetime
from elasticsearch import Elasticsearch
from elasticsearch import helpers
es = Elasticsearch()
actions = []
f=open('index.txt')
i=1
for 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的方法了嗎？如果還想學到更多技能或想了解更多相關內容，歡迎關注億速云行業資訊頻道，感謝各位的閱讀！