mirror of
https://github.com/elastic/logstash.git
synced 2025-04-24 06:37:19 -04:00
- trim carriage returns
This commit is contained in:
Jordan Sissel
parent
2fa19bbd6c
commit
91ebd39f12
1 changed files with 112 additions and 112 deletions
|
|
@ -1,112 +1,112 @@
|
|||
require "logstash/namespace"
|
||||
require "logstash/outputs/base"
|
||||
|
||||
# The zabbix output is used for sending item data to zabbux via the
|
||||
# zabbix_sender executable.
|
||||
#
|
||||
# For this output to work, your event must have the following fields:
|
||||
#
|
||||
# * "zabbix_host" (the host configured in Zabbix)
|
||||
# * "zabbix_item" (the item key on the host in Zabbix)
|
||||
#
|
||||
# In Zabbix, create your host with the same name (no spaces in the name of
|
||||
# the host supported) and create your item with the specified key as a
|
||||
# Zabbix Trapper item.
|
||||
#
|
||||
# The easiest way to use this output is with the grep filter.
|
||||
# Presumably, you only want certain events matching a given pattern
|
||||
# to send events to zabbix, so use grep to match and also to add the required
|
||||
# fields.
|
||||
#
|
||||
# filter {
|
||||
# grep {
|
||||
# type => "linux-syslog"
|
||||
# match => [ "@message", "(error|ERROR|CRITICAL)" ]
|
||||
# add_tag => [ "zabbix-sender" ]
|
||||
# add_fields => [
|
||||
# "zabbix_host", "%{@source_host}",
|
||||
# "zabbix_item", "item.key"
|
||||
# ]
|
||||
# }
|
||||
# }
|
||||
#
|
||||
# output{
|
||||
# zabbix {
|
||||
# # only process events with this tag
|
||||
# tags => "zabbix-sender"
|
||||
#
|
||||
# # specify the hostname or ip of your zabbix server
|
||||
# # (defaults to localhost)
|
||||
# zabbix_server => "localhost"
|
||||
#
|
||||
# # specify the port to connect to (default 10051)
|
||||
# zabbix_port => "10051"
|
||||
#
|
||||
# # specify the path to zabbix_sender
|
||||
# # (defaults to "/usr/local/bin/zabbix_sender")
|
||||
# zabbix_sender => "/usr/local/bin/zabbix_sender"
|
||||
# }
|
||||
# }
|
||||
class LogStash::Outputs::Zabbix < LogStash::Outputs::Base
|
||||
|
||||
config_name "zabbix"
|
||||
|
||||
config :host, :validate => :string, :default => "localhost"
|
||||
config :port, :validate => :number, :default => 10051
|
||||
config :zabbix_sender, :validate => :string, :default => "/usr/local/bin/zabbix_sender"
|
||||
|
||||
# Only handle events with any of these tags. Optional.
|
||||
# If not specified, will process all events.
|
||||
config :tags, :validate => :array, :default => []
|
||||
|
||||
public
|
||||
def register
|
||||
# nothing to do
|
||||
end # def register
|
||||
|
||||
public
|
||||
def receive(event)
|
||||
if !@tags.empty?
|
||||
if (event.tags - @tags).size == 0
|
||||
# Skip events that have no tags in common with what we were configured
|
||||
return
|
||||
end
|
||||
end
|
||||
|
||||
if !File.exists?(@zabbix_sender)
|
||||
@logger.warn(["Skipping zabbix output; zabbix_sender file is missing",
|
||||
{"zabbix_sender" => @zabbix_sender, "missed_event" => event}])
|
||||
return
|
||||
end
|
||||
|
||||
host = event.fields["zabbix_host"]
|
||||
if !host
|
||||
@logger.warn(["Skipping zabbix output; zabbix_host field is missing",
|
||||
{"missed_event" => event}])
|
||||
return
|
||||
end
|
||||
|
||||
item = event.fields["zabbix_item"]
|
||||
if !item
|
||||
@logger.warn(["Skipping zabbix output; zabbix_item field is missing",
|
||||
{"missed_event" => event}])
|
||||
return
|
||||
end
|
||||
|
||||
zmsg = event.message
|
||||
zmsg = zmsg.gsub("\n", "\\n")
|
||||
zmsg = zmsg.gsub(/"/, "\\\"")
|
||||
|
||||
cmd = "#{@zabbix_sender} -z #{@host} -p #{@port} -s #{host} -k #{item} -o \"#{zmsg}\" 2>/dev/null >/dev/null"
|
||||
|
||||
@logger.debug({"zabbix_sender_command" => cmd})
|
||||
begin
|
||||
system cmd
|
||||
rescue => e
|
||||
@logger.warn(["Skipping zabbix output; error calling zabbix_sender",
|
||||
{"error" => $!, "zabbix_sender_command" => cmd,
|
||||
"missed_event" => event}])
|
||||
@logger.debug(["Backtrace", e.backtrace])
|
||||
end
|
||||
end # def receive
|
||||
end # class LogStash::Outputs::Nagios
|
||||
require "logstash/namespace"
|
||||
require "logstash/outputs/base"
|
||||
|
||||
# The zabbix output is used for sending item data to zabbux via the
|
||||
# zabbix_sender executable.
|
||||
#
|
||||
# For this output to work, your event must have the following fields:
|
||||
#
|
||||
# * "zabbix_host" (the host configured in Zabbix)
|
||||
# * "zabbix_item" (the item key on the host in Zabbix)
|
||||
#
|
||||
# In Zabbix, create your host with the same name (no spaces in the name of
|
||||
# the host supported) and create your item with the specified key as a
|
||||
# Zabbix Trapper item.
|
||||
#
|
||||
# The easiest way to use this output is with the grep filter.
|
||||
# Presumably, you only want certain events matching a given pattern
|
||||
# to send events to zabbix, so use grep to match and also to add the required
|
||||
# fields.
|
||||
#
|
||||
# filter {
|
||||
# grep {
|
||||
# type => "linux-syslog"
|
||||
# match => [ "@message", "(error|ERROR|CRITICAL)" ]
|
||||
# add_tag => [ "zabbix-sender" ]
|
||||
# add_fields => [
|
||||
# "zabbix_host", "%{@source_host}",
|
||||
# "zabbix_item", "item.key"
|
||||
# ]
|
||||
# }
|
||||
# }
|
||||
#
|
||||
# output{
|
||||
# zabbix {
|
||||
# # only process events with this tag
|
||||
# tags => "zabbix-sender"
|
||||
#
|
||||
# # specify the hostname or ip of your zabbix server
|
||||
# # (defaults to localhost)
|
||||
# zabbix_server => "localhost"
|
||||
#
|
||||
# # specify the port to connect to (default 10051)
|
||||
# zabbix_port => "10051"
|
||||
#
|
||||
# # specify the path to zabbix_sender
|
||||
# # (defaults to "/usr/local/bin/zabbix_sender")
|
||||
# zabbix_sender => "/usr/local/bin/zabbix_sender"
|
||||
# }
|
||||
# }
|
||||
class LogStash::Outputs::Zabbix < LogStash::Outputs::Base
|
||||
|
||||
config_name "zabbix"
|
||||
|
||||
config :host, :validate => :string, :default => "localhost"
|
||||
config :port, :validate => :number, :default => 10051
|
||||
config :zabbix_sender, :validate => :string, :default => "/usr/local/bin/zabbix_sender"
|
||||
|
||||
# Only handle events with any of these tags. Optional.
|
||||
# If not specified, will process all events.
|
||||
config :tags, :validate => :array, :default => []
|
||||
|
||||
public
|
||||
def register
|
||||
# nothing to do
|
||||
end # def register
|
||||
|
||||
public
|
||||
def receive(event)
|
||||
if !@tags.empty?
|
||||
if (event.tags - @tags).size == 0
|
||||
# Skip events that have no tags in common with what we were configured
|
||||
return
|
||||
end
|
||||
end
|
||||
|
||||
if !File.exists?(@zabbix_sender)
|
||||
@logger.warn(["Skipping zabbix output; zabbix_sender file is missing",
|
||||
{"zabbix_sender" => @zabbix_sender, "missed_event" => event}])
|
||||
return
|
||||
end
|
||||
|
||||
host = event.fields["zabbix_host"]
|
||||
if !host
|
||||
@logger.warn(["Skipping zabbix output; zabbix_host field is missing",
|
||||
{"missed_event" => event}])
|
||||
return
|
||||
end
|
||||
|
||||
item = event.fields["zabbix_item"]
|
||||
if !item
|
||||
@logger.warn(["Skipping zabbix output; zabbix_item field is missing",
|
||||
{"missed_event" => event}])
|
||||
return
|
||||
end
|
||||
|
||||
zmsg = event.message
|
||||
zmsg = zmsg.gsub("\n", "\\n")
|
||||
zmsg = zmsg.gsub(/"/, "\\\"")
|
||||
|
||||
cmd = "#{@zabbix_sender} -z #{@host} -p #{@port} -s #{host} -k #{item} -o \"#{zmsg}\" 2>/dev/null >/dev/null"
|
||||
|
||||
@logger.debug({"zabbix_sender_command" => cmd})
|
||||
begin
|
||||
system cmd
|
||||
rescue => e
|
||||
@logger.warn(["Skipping zabbix output; error calling zabbix_sender",
|
||||
{"error" => $!, "zabbix_sender_command" => cmd,
|
||||
"missed_event" => event}])
|
||||
@logger.debug(["Backtrace", e.backtrace])
|
||||
end
|
||||
end # def receive
|
||||
end # class LogStash::Outputs::Nagios
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue