Yet Another CPAN Grep

POE-Component-ElasticSearch-Indexer ( B/BL/BLHOTSKY/POE-Component-ElasticSearch-Indexer-0.015.tar.gz, BLHOTSKY, 2022; MetaCPAN )

POE-Component-ElasticSearch-Indexer/bin/file-to-elasticsearch.pl ( view source; MetaCPAN )

:Long::Descriptive qw(describe_options);
use Hash::Merge::Simple qw(merge);
use JSON::MaybeXS qw(decode_json encode_json);
use Log::Log4perl qw(:easy);
use Module::Load qw(load);
use Module::Loaded qw

$instr->{decode} ];
        foreach my $decoder ( @{ $decoders } ) {
            if( $decoder eq 'json' ) {
                my $start = index('{', $line);
                my $blob  = $start > 0 ? subs


                    $new = decode_json($blob);
                    1;
                } or do {
                    my $err = $@;
                    TRACE("Bad JSON, error: $err\n$blob");

POE-Component-ElasticSearch-Indexer ( B/BL/BLHOTSKY/POE-Component-ElasticSearch-Indexer-0.015.tar.gz, BLHOTSKY, 2022; MetaCPAN )

POE-Component-ElasticSearch-Indexer/lib/POE/Component/ElasticSearch/Indexer.pm ( view source; MetaCPAN )

est::MD5 qw(md5_hex);
use Digest::SHA1 qw(sha1_hex);
use Fcntl qw(:flock);
use HTTP::Request;
use JSON::MaybeXS;
use List::Util qw(shuffle);
use Log::Log4perl qw(:easy);
use Path::Tiny;
use POSIX qw(s

        eval {
            $details = decode_json($r->content);
        } or do {
            my $error = $@;
            WARN("es_version() not valid JSON: $error");
        };
        if( defined $d

request
            $record = sprintf("%s\n%s\n",
                encode_json({ index => \%meta }),
                encode_json($doc),
            );
        }
        elsif( !is_ref($doc) ) {