gistfile1.txt

from django.conf import settings
import elasticsearch
from elasticsearch.helpers import scan
from zopim.util.es_lib import BulkIndexerV2

bulk = BulkIndexerV2()

es1 = elasticsearch.Elasticsearch(['esproxy.zopim.net:80'])
es2 = elasticsearch.Elasticsearch(settings.ES_HOSTS)

scan_resp = scan(
	client=es1,
	index='eventlog-*',
	query= {
		"query": {
			"term": {
				"agent_id": 1767963
			}
		}
	}
)

print 'Hi'
for doc in scan_resp:
	bulk.add(
		_index=doc['_index'],
		_type=doc['_type'],
		doc=doc['_source']
	)

bulk.flush()