0

我正在研究 Sensu。我已经在 CentOS 中安装了 sensu。我需要获取由 Sensu 检查生成的事件消息。我添加了一些 sensu 社区插件等check-procs.rb,check-load.rb,check-banner.rb, metrics-ebs-volume.rb。我编写了一些处理程序文件来处理这些.rb文件。我在sensu-server.log.

例子：

{"timestamp":"2016-08-10T07:32:08.000003+0000","level":"info","message":"publishing check request","payload":{"name":"swap-free","issued":1470814327,"command":"check-swap.sh 20 10"},"subscribers":["base_centos_monitoring"]}

我编写了一个 ruby​​ 文件"nephele_events_handler.rb"，它通过 rest 调用将事件消息发送到另一台服务器。ruby 文件位于"/etc/sensu/handlers/". 我正在从 STDIN.read 读取事件，我从官方 sensu 文档中读到事件将存储在 STDIN 中。

#!/opt/sensu/embedded/bin/ruby
require "#{File.dirname(__FILE__)}/base"
require 'rubygems'
require 'json'
require 'uri'
require 'net/http'
require 'net/https'
require 'json'

class RunProcs < BaseHandler

  def payload_check
#Read event data

sensuhash = "{ \"SensuMessage\"" + ":"
braces = "}"
s = sensuhash.to_s


event = JSON.parse(STDIN.read, :symbolize_names => true)
eventPayload = event.to_json
sensujson = s + eventPayload + braces
uri = URI.parse("https://localhost:8080/Processor/services/sourceEvents/requestMsg")
https = Net::HTTP.new(uri.host,uri.port)
https.use_ssl = false
req = Net::HTTP::Post.new(uri.path, initheader = {'Content-Type' =>'application/json'})
req.body = "[ #{sensujson} ]"
res = https.request(req)
end        
info = RunProcs.new
  info.payload_check    
end

我正在位置“/etc/sensu/conf.d/handlers”内编写处理程序 json 文件“processor.json”。

{
  "handlers": {
    "nephele_processor": {
      "type": "pipe",
      "command": "nephele_events_handler.rb"
    }
  }
}

但我面临的问题是我只从'check-procs'中获取事件

{"client":{"address":"10.81.1.105","subscriptions":["base_centos","base_chef-client","python","base_centos_monitoring","base_centos_monitoring_metrics","sensu_client","base_aws","base_aws_monitoring","sensu_master","all"],"name":"ip-localhost.internal","hostname":"ip-localhost","version":"0.25.3","timestamp":1470896756},"check":{"command":"check-procs.rb --pattern='chef-client' -W=1","subscribers":["base_centos_monitoring"],"handlers":["base_with_jira"],"interval":60,"team":"ops","aggregate":true,"occurrences":3,"refresh":300,"ticket":true,"name":"process-chef-client","issued":1470896771,"executed":1470896771,"duration":0.864,"output":"CheckProcs CRITICAL: Found 0 matching processes; cmd /chef-client/\n","status":2,"type":"standard","history":["2","2","2","2","2","2","2","2","2","2","2","2","2","2","2","2","2","2","2","2","2"],"total_state_change":0},"occurrences":19879,"action":"create","timestamp":1470896772,"id":"dc2b0698-dbac-416d-a9ae-42aa09d53cc3","last_state_change":1469690268,"last_ok":null}

正在执行的检查

{
  "checks": {
    "process-chef-client": {
      "command": "check-procs.rb --pattern='chef-client' -W=1",
      "subscribers": [
        "base_centos_monitoring"
      ],
      "handlers": [
        "base_with_jira"
      ],
      "interval": 60,
      "team": "ops",
      "aggregate": true,
      "occurrences": 3,
      "interval": 60,
      "refresh": 300,
      "ticket": true
    }
  }
}

base_with_jira.json

{
  "handlers": {
    "base_with_jira": {
      "type": "set",
      "handlers": [
       "jira",
       "nephele_processor"
      ],
      "config": "http://apache.enron.nephele.solutions/uchiwa"
    }
  }
}

我没有从其他插件获取事件。你能解释一下我必须为此做些什么吗？

4

0 回答 0