I cannot seem to get remediation to work. It writes the test file even if the process is running 
I am not really sure what is wrong and can’t find any documentation for this. Thanks!
{
“handlers”: {
“remediator”: {
“type”: “pipe”,
“command”: “/etc/sensu/community/handlers/remediation/remediation.rb”
}
},
“checks”: {
“fail_with_remediation”: {
“command”: “/usr/bin/ruby /etc/sensu/community/plugins/processes/check-procs.rb -p testprocess -W 1”,
“interval”: 60,
“standalone”: true,
“publish”: false,
“subscribers”: [“test”],
“handlers”: [“remediator”],
“remediation”: {
“remediation”: {
“occurrences”: [“2+”],
“severities”: [2]
}
}
},
“remediation”: {
“command”: “/bin/touch /tmp/remediation_this_stuff”,
“standalone”: true,
“publish”: false,
“interval”: 60,
“subscribers”: [“test”]
}
}
}
cat /etc/sensu/community/handlers/remediation/remediation.rb
#!/usr/bin/env ruby
···
“remediation”: {
“light_remediation”: {
“occurrences”: [1,2],
“severities”: [1]
},
“medium_remediation”: {
“occurrences”: [“3-10”],
“severities”: [1]
},
“heavy_remediation”: {
“occurrences”: [“1+”],
“severities”: [2]
}
}
===
Copyright 2012 Nick Stielau nick.stielau@gamil.com
Released under the same terms as Sensu (the MIT license); see LICENSE
for details.
require ‘rubygems’ if RUBY_VERSION < ‘1.9.0’
require ‘sensu-handler’
class Remediator < Sensu::Handler
Override filter_repeated from Sensu::Handler.
Remediations are not alerts.
def filter_repeated; end
def handle
client = @event[‘client’][‘name’]
remediations = @event[‘check’][‘remediate’]
occurrences = @event[‘occurrences’]
severity = @event[‘check’][‘status’].to_i
puts “Evaluating remediation: #{client} #{remediations.inspect} #=#{occurrences} sev=#{severity}”
remediation_checks = parse_remediations(remediations, occurrences, severity)
remediation_checks.each do |remediation_check|
puts “Triggering remediation check ‘#{remediation_check}’ for #{[client].inspect}”
response = trigger_remediation(remediation_check, [client])
puts “Recieved API Response (#{response.code}): #{response.body}, exiting.”
end
end
def parse_remediations(remediations, occurrences, severity)
puts “Parsing remediations from #{remediations}[#{occurrences}]”
remediations_to_trigger =
remediations.each do |check, conditions|
valid_occurrences =
(conditions[“occurrences”] || ).each do |value|
if value.is_a?(Integer)
valid_occurrences << value
elsif value.to_s.match(/^\d+$/)
valid_occurrences << $~.to_a.first.to_i
elsif value.to_s.match(/^(\d+)-(\d+)$/)
valid_occurrences << Range.new(~.to_a[1].to_i, ~.to_a[2].to_i).to_a
elsif value.to_s.match(/^(\d+)+$/)
puts “Matchdata: #{$~.inspect}”
valid_occurrences << Range.new($~.to_a[1].to_i, 99999).to_a
end
end
valid_occurrences.flatten!
puts “Valids: #{valid_occurrences}”
next unless valid_occurrences.include?(occurrences) && (conditions[“severities”] || ).include?(severity)
remediations_to_trigger << check
end
remediations_to_trigger
end
Issue a check via the API
def trigger_remediation(check, subscribers)
result = api_request(:POST, ‘/checks/request’) do |req|
req.body = JSON.dump({“check” => check, “subscribers” => subscribers})
end
end
end