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

fix mongodb output

Browse source
This commit is contained in:
Pete Fritchman 2011-03-27 20:50:52 -07:00
parent 0e34d43a66
commit de568d2b46
1 changed files with 16 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

22
lib/logstash/outputs/mongodb.rb
View file

@ -1,18 +1,28 @@
require "logstash/outputs/base"
require "logstash/namespace"
require "em-mongo"
require "mongo"
class LogStash::Outputs::Mongodb < LogStash::Outputs::Base
config_name "mongodb"
config :host, :validate => :string, :required => true
config :port, :validate => :number
config :database, :validate => :string, :required => true
config :collection, :validate => :string, :required => true
public
def initialize(params)
super
@port ||= Mongo::Connection::DEFAULT_PORT
end
public
def register
# TODO(sissel): Port?
# TODO(sissel): Authentication?
# db and collection are mongodb://.../db/collection
unused, @db, @collection = @url.path.split("/", 3)
@mongodb = EventMachine::Mongo::Connection.new(@url.host).db(@db)
# TODO(petef): support authentication
# TODO(petef): check for errors
@mongodb = Mongo::Connection.new(@host, @port).db(@database)
end # def register
public