Simple (and greedy) reindexer

es_reindexer.py

#!/usr/bin/env python

from pyes import *
import argparse
import logging

parser = argparse.ArgumentParser()
parser.add_argument('--source', type=str, help='Enter the source index', required=True)
parser.add_argument('--dest', type=str, help='Enter the dest index', required=True)
parser.add_argument('--type', type=str, help='Enter the type', required=True)
parser.add_argument('--es_server', type=str, help='Enter the address of the ES server', default='127.0.0.1:9200', required=False)
args = parser.parse_args()

logging.basicConfig(level='INFO')

conn = ES(args.es_server)

count = conn.count(MatchAllQuery(), args.source, args.type)['count']
logging.info('{0} {1}'.format(count, args.type))

results = conn.search(MatchAllQuery(), indices=args.source, doc_types=args.type, size=count)
logging.info('Grabbed {0} {1}'.format(len(results), args.type))

for result in results:
    del result['meta']
    conn.index(result, args.dest, args.type)
    
logging.info('Done')