使用较低级的
elasticsearch-py库，这种任务比较容易：
from elasticsearch import helpers, Elasticsearchimport csves = Elasticsearch()with open('/tmp/x.csv') as f: reader = csv.DictReader(f) helpers.bulk(es, reader, index='my-index', doc_type='my-type')
使用较低级的
elasticsearch-py库，这种任务比较容易：
from elasticsearch import helpers, Elasticsearchimport csves = Elasticsearch()with open('/tmp/x.csv') as f: reader = csv.DictReader(f) helpers.bulk(es, reader, index='my-index', doc_type='my-type')名师互学网 版权所有 (c)2021-2022 ICP备案号：晋ICP备2021003244-6号
