Skip to content

Instantly share code, notes, and snippets.

@francois
Last active August 29, 2015 14:16
Show Gist options
  • Select an option

  • Save francois/88b1868bd98369944daf to your computer and use it in GitHub Desktop.

Select an option

Save francois/88b1868bd98369944daf to your computer and use it in GitHub Desktop.
~/logstash-1.4.2 $ cat source.mjson
{"script": "update-community-metrics-twitter", "duration": 358.9, "rows": 6372}
{"script": "update-community-metrics-facebook", "duration": 398.9, "rows": 6429}
{"script": "update-community-metrics-followers", "duration": 1358.9, "rows": 6372}
~/logstash-1.4.2 $ cat source.mjson | bin/logstash -e 'input{stdin{codec=>json}}'
{
"script" => "update-community-metrics-twitter",
"duration" => 358.9,
"rows" => 6372,
"@version" => "1",
"@timestamp" => "2015-03-06T22:30:20.161Z",
"host" => "francois"
}
{
"script" => "update-community-metrics-facebook",
"duration" => 398.9,
"rows" => 6429,
"@version" => "1",
"@timestamp" => "2015-03-06T22:30:20.164Z",
"host" => "francois"
}
{
"script" => "update-community-metrics-followers",
"duration" => 1358.9,
"rows" => 6372,
"@version" => "1",
"@timestamp" => "2015-03-06T22:30:20.165Z",
"host" => "francois"
}
~/logstash-1.4.2 $ cat source.mjson | bin/logstash -e 'input{stdin{codec=>json}}' -e 'output{elasticsearch{codec=>json}}'
:~/logstash-1.4.2 $ cat source.mjson | bin/logstash -e 'input{stdin{codec=>json_lines}}' -e 'output{elasticsearch{codec=>json} stdout{codec=>json}}'
{"message":"{\"script\": \"update-community-metrics-twitter\", \"duration\": 358.9, \"rows\": 6372}","@version":"1","@timestamp":"2015-03-06T22:47:14.256Z","type":"stdin","host":"francois"}{"message":"{\"script\": \"update-community-metrics-facebook\", \"duration\": 398.9, \"rows\": 6429}","@version":"1","@timestamp":"2015-03-06T22:47:14.279Z","type":"stdin","host":"francois"}{"message":"{\"script\": \"update-community-metrics-followers\", \"duration\": 1358.9, \"rows\": 6372}","@version":"1","@timestamp":"2015-03-06T22:47:14.280Z","type":"stdin","host":"francois"}%
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment