reindex ES v1.7

reindex.pl

#!/usr/bin/perl

#https://www.elastic.co/blog/changing-mapping-with-zero-downtime

use Search::Elasticsearch 2.03;

my $es = Search::Elasticsearch->new( nodes => '192.168.1.2:9200');

# Reindex docs:
my $bulk = $es->bulk_helper(
    index   => 'twitch_v2',
    verbose => 1
);

$bulk->reindex( source => { index => 'twitch' },
        transform   => sub {
        my $doc = shift;

        # convert time from ss to ss.SSS (append milliseconds)
        $doc->{_source}{timestamp} .= '.000';

        #print $doc->{_source}{timestamp};

        return $doc
        });