21 lines
442 B
Ruby
21 lines
442 B
Ruby
#!/usr/bin/env ruby
|
|
#
|
|
# An example of funneling metrics to Redis pub/sub.
|
|
#
|
|
# to run this, you may need to:
|
|
# gem install redis
|
|
#
|
|
require 'redis'
|
|
require 'json'
|
|
|
|
r = Redis.new(host: "127.0.0.1", port: 6379, db: 1)
|
|
|
|
loop do
|
|
# example input: "{"fields":{"count":0},"name":"counter_ruby","tags":{"host":"localhost"},"timestamp":1586374982}"
|
|
line = STDIN.readline.chomp
|
|
|
|
l = JSON.parse(line)
|
|
|
|
key = l["name"]
|
|
r.publish(key, line)
|
|
end
|