欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

Elasticsearch 批量导入数据

程序员文章站 2022-06-11 11:42:15
...

本人的 Elasticsearch 版本是 6.2.3

python script

from datetime import datetime
from elasticsearch import Elasticsearch
from elasticsearch import helpers

es = Elasticsearch()
#es = Elasticsearch("http://localhost:9200/)
#es = Elasticsearch("http://localhost:9200/test/one")

actions = [
  {
    "_index": "test",
    "_type": "one",
    "_id": j,
    "_source": {
        "any":"data" + str(j),
        "timestamp": datetime.now()}
  }
  for j in range(0, 10)
]

helpers.bulk(es, actions)

参考:

https://*.com/questions/20288770/how-to-use-bulk-api-to-store-the-keywords-in-es-by-using-python

https://github.com/elastic/elasticsearch-py