#!/usr/bin/perl
use Cassandra::Client;

 my $client=Cassandra::Client->new(
     contact_points=>['172.21.0.2', '172.21.0.4', '172.21.0.5'],
     username => 'admin',
     password => '********',
     keyspace => 'pingtest'
 );

 $client->connect;

 foreach my $line ( <STDIN> ) {
 if($line =~ /\[(\d+.\d+)\](.*)time=(\d+\.\d+)/) {
     $client->execute("INSERT INTO pingtime (tstamp, tvalue) VALUES(?, ?)",
     [$1*1000, $3],
     { consistency => "one" });
   }
 }

 $client->shutdown;