from elasticsearch import helpers, Elasticsearch
import csv
es = Elasticsearch(['http://172.16.2.101:9200'])
with open('/tmp/x.csv') as f:
    reader = csv.DictReader(f)
    helpers.bulk(es, reader, index='my-index', doc_type='my-type')

51cc96eff40e451054240f6d20cb3bec76d52aaa
<mask token>

<mask token>
with open('/tmp/x.csv') as f:
    reader = csv.DictReader(f)
    helpers.bulk(es, reader, index='my-index', doc_type='my-type')

<mask token>
es = Elasticsearch(['http://172.16.2.101:9200'])
with open('/tmp/x.csv') as f:
    reader = csv.DictReader(f)
    helpers.bulk(es, reader, index='my-index', doc_type='my-type')

from elasticsearch import helpers, Elasticsearch
import csv
es = Elasticsearch(['http://172.16.2.101:9200'])
with open('/tmp/x.csv') as f:
    reader = csv.DictReader(f)
    helpers.bulk(es, reader, index='my-index', doc_type='my-type')
