munin-graphite/munin-graphite.rb at master · cornet/munin-graphite · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
#!/usr/bin/env ruby

require 'rubygems'
require 'munin-ruby'
require 'bunny'

munin = Munin::Node.new

metric_base = "servers"

all_metrics = Array.new

while true

  munin.nodes.each do |node|
    munin.list(node).each do |service|
      munin.fetch(service).each do |metrics|

        metrics[1].each do |k,v|

          msg = "%s.%s.%s.%s %s %d" % [
            metric_base,
            node.split('.').reverse.join('.'), # Reverse hostname parts
            service,
            k,
            v.to_s,
            Time.now.utc.to_i
          ]

          all_metrics << msg

        end
      end
    end
  end

  bunny = Bunny.new(
    :host    => 'localhost',
    :user    => 'graphite',
    :pass    => 'gr4ph1t3',
    :logging => false,
  )

  bunny.start

  exch = bunny.exchange("graphite", :type => "topic", :durable => true)

  all_metrics.each do |metric|
    puts "Sending #{metric}"
    exch.publish(metric)
  end

  bunny.stop

  sleep 60

end