Catmandu Atom ingest v2

ingest.pl

#!/usr/bin/perl

use Catmandu::Importer::Atom;
use Catmandu::Store::ElasticSearch;
use Data::Dumper;
use Modern::Perl;

my $feed = 'http://planet.code4lib.org/atom.xml';

# Set up importer and store
my $importer = Catmandu::Importer::Atom->new( url => $feed );
my $store = Catmandu::Store::ElasticSearch->new( index_name => 'dbabel' );

# Start from scratch during testing
$store->bag->delete_all;

# Loop through items and store them
my $n = $importer->each(sub {
    my $hashref = $_[0];
    # Set a custom ID
    $hashref->{'_id'} = $hashref->{'id'};
    $store->bag->add( $hashref );
});

$store->bag->commit;

# Do a search
my $hits = $store->bag->search( query => 'library' )->to_array;
foreach my $hit ( @{ $hits } ) {

    say "* <", $hit->{'_id'}, "> ", $hit->{'title'};

}