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

Merge pull request #28 from kesor/mongodb_auth

Browse source 
Very basic support for MongoDB authentication (take 2, on its own branch)
This commit is contained in:
Jordan Sissel 2011-06-01 09:54:43 -07:00
commit 3ff43b082a
1 changed files with 12 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -14,6 +14,9 @@ class LogStash::Outputs::Mongodb < LogStash::Outputs::Base
# The database to use
config :database, :validate => :string, :required => true
config :user, :validate => :string, :required => false
config :password, :validate => :password, :required => false
# The collection to use. This value can use %{foo} values to dynamically
# select a collection based on data in the event.
config :collection, :validate => :string, :required => true
@ -21,9 +24,16 @@ class LogStash::Outputs::Mongodb < LogStash::Outputs::Base
public
def register
require "mongo"
# TODO(petef): support authentication
# TODO(petef): check for errors
@mongodb = Mongo::Connection.new(@host, @port).db(@database)
db = Mongo::Connection.new(@host, @port).db(@database)
auth = true
if @user then
auth = db.authenticate(@user, @password.value) if @user
end
if not auth then
raise RuntimeError, "MongoDB authentication failure"
end
@mongodb = db
end # def register
public