put-sidekiq-metric.rb

require 'net/http'
require 'uri'
require 'json'

def put_metric(name, value, unit='Count')
  metric_name = "ApiSidekiq#{name.split('_').collect(&:capitalize).join}"
  `/usr/local/bin/aws cloudwatch put-metric-data --metric-name #{metric_name} --namespace Sidekiq --value #{value} --unit #{unit}`
end

uri = URI.parse("#{ENV['SIDEKIQ_WEB_HOST']}/stats")
req = Net::HTTP::Get.new(uri.request_uri)
req.basic_auth ENV['USERNAME'], ENV['PASSWORD']

resp = Net::HTTP.start(uri.hostname, uri.port, use_ssl: uri.scheme == 'https') do |http|
  http.request(req)
end

if Integer(resp.code) == 200
  data = JSON.parse(resp.body)
  put_metric('BusyJobs', data['sidekiq']['busy'])
  put_metric('EnqueuedJobs', data['sidekiq']['enqueued'])
  put_metric('ScheduledJobs', data['sidekiq']['scheduled'])
  put_metric('RetryJobs', data['sidekiq']['retries'])
  put_metric('Processes', data['sidekiq']['processes'])
  put_metric('RedisClients', data['redis']['connected_clients'])
end