Ardexa Sunny Boy to Graphite

sunny_graphite.rb

#!/usr/bin/env ruby

require 'socket'
require 'time'

$file = ARGV[0] || "opt/ardexa/sma/logs/{}/latest.csv"

puts "Streaming readings from #{$file}..."

sock = TCPSocket.new 'localhost', 2003

File.open($file).each_line do |line|
  next if line[0] == '#'

  l = line.split(',')

  ts = Time.parse(l[0]).to_i
  power = l[1]
  energy = l[2]
  mode  = l[-2]
  status = l[-1].strip

  sock.write("solar.power #{power} #{ts}\n")
  sock.write("solar.energy #{energy} #{ts}\n")
  sock.write("solar.mode #{mode} #{ts}\n")
  sock.write("solar.status #{status} #{ts}\n")
end