如何使用python批量導入數據進Elasticsearch中

本文小編為大家詳細介紹“如何使用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中”文章已經介紹完畢，想要掌握這篇文章的知識點還需要大家自己動手實踐使用過才能領會，如果想了解更多相關內容的文章，歡迎關注億速云行業資訊頻道。