github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 06:37:19 -04:00
Code Issues Projects Releases Packages Wiki Activity

- set type and tags for twitter://

Browse source
This commit is contained in:
Jordan Sissel 2010-12-25 20:06:01 -08:00
parent a69cffc6a3
commit 9369af61b1
1 changed files with 6 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

8
lib/logstash/inputs/twitter.rb
View file

@ -21,8 +21,12 @@ class LogStash::Inputs::Twitter < LogStash::Inputs::Base
tweet = JSON.parse(line)
next if !tweet
event = LogStash::Event.new
event.message = tweet["text"]
event = LogStash::Event.new({
"@message" => tweet["text"],
"@type" => @type,
"@tags" => @tags.clone,
})
event.fields.merge!(
"user" => (tweet["user"]["screen_name"] rescue nil),
"client" => (tweet["user"]["source"] rescue nil),