trunk/bin/mongodb2shards.pl

#!/usr/bin/perl

use lib 'lib';
use Sack::Shard;

use Data::Dump qw(dump);
use autodie;

use MongoDB;

my $name = 'pxelator';
my $shard_size = 5000;


my $connection = MongoDB::Connection->new(host => '10.60.0.91', port => 27017);
my $database   = $connection->get_database('pxelator');
my $collection = $database->get_collection('audit');

my $q;
#$q = {"package.name" => "dnsd", "source" => "upstream"};

warn "# mongodb query: ", dump($q), $/;

my $cursor = $collection->query($q);

Sack::Shard::create( $name, $cursor->count, $shard_size );

while( my $o = $cursor->next ) {
        $o->{_id} .= ''; # convert _id to scalar
        Sack::Shard::add( $o );
}
Sack::Shard::finish;

1	#!/usr/bin/perl
2
3	use lib 'lib';
4	use Sack::Shard;
5
6	use Data::Dump qw(dump);
7	use autodie;
8
9	use MongoDB;
10
11	my $name = 'pxelator';
12	my $shard_size = 5000;
13
14
15	my $connection = MongoDB::Connection->new(host => '10.60.0.91', port => 27017);
16	my $database = $connection->get_database('pxelator');
17	my $collection = $database->get_collection('audit');
18
19	my $q;
20	#$q = {"package.name" => "dnsd", "source" => "upstream"};
21
22	warn "# mongodb query: ", dump($q), $/;
23
24	my $cursor = $collection->query($q);
25
26	Sack::Shard::create( $name, $cursor->count, $shard_size );
27
28	while( my $o = $cursor->next ) {
29	$o->{_id} .= ''; # convert _id to scalar
30	Sack::Shard::add( $o );
31	}
32	Sack::Shard::finish;
33