Python3往Elasticsearch批量插入数据

  • Post author:
  • Post category:python


废话不多说,直接上代码

# -*- coding: utf-8 -*-

from elasticsearch import Elasticsearch
import os

#指定一个文件夹
path = r'C:\Users\Administrator\Desktop\files'
es = Elasticsearch()
doc = []
i = 1
#获取文件夹下所有文件的绝对路径和文件名
for dirname,pathname,filenames in os.walk(path):
    for filename in filenames:
        doc.append({"index":{"_id" : i}})
        doc.append({"filepath":os.path.join(dirname,filename)})
        i = i + 1
es.bulk(index="test",doc_type="text",body=doc)



版权声明:本文为weixin_42126327原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。