[516b934] | 1 | #!/usr/bin/env ruby |
---|
| 2 | # |
---|
| 3 | # Author: Norbert Wigbels - foobla.wigbels.de/uber-foobla |
---|
| 4 | # |
---|
| 5 | # HotColdRain continously reads output of USB-WDE1 |
---|
| 6 | # and pushes data to mosquitto-db |
---|
| 7 | # |
---|
| 8 | # todos: |
---|
| 9 | # |
---|
| 10 | |
---|
| 11 | #------------------------------------------ |
---|
| 12 | # Tainted mode 0-4 |
---|
| 13 | $SAFE=0 |
---|
| 14 | |
---|
| 15 | |
---|
| 16 | #------------------------------------------ |
---|
| 17 | require 'logger' |
---|
| 18 | require 'serialport' |
---|
| 19 | require 'mqtt' |
---|
| 20 | |
---|
| 21 | #------------------------------------------ |
---|
| 22 | class HotColdRain < Logger::Application |
---|
| 23 | attr_accessor :temp1, :humidity1, :serialport |
---|
| 24 | |
---|
| 25 | def initialize(application_name) |
---|
| 26 | super(application_name) |
---|
| 27 | @serialport = SerialPort.new("/dev/ttyUSB0", 9600, 8, 1, SerialPort::NONE) |
---|
| 28 | end |
---|
| 29 | |
---|
| 30 | def run |
---|
| 31 | begin |
---|
| 32 | while true do |
---|
| 33 | openformat = @serialport.readline |
---|
| 34 | datagrams = openformat.split(';') |
---|
| 35 | # puts openformat |
---|
| 36 | puts "TemperaturUnten: " + datagrams[3] |
---|
| 37 | puts "LuftfeuchtigkeitUnten: " + datagrams[11] |
---|
| 38 | puts |
---|
| 39 | puts "TemperaturOben: " + datagrams[4] |
---|
| 40 | puts "LuftfeuchtigkeitOben: " + datagrams[12] |
---|
| 41 | puts |
---|
| 42 | puts "TemperaturAussen: " + datagrams[19] |
---|
| 43 | puts "LuftfeuchtigkeitAussen: " + datagrams[20] |
---|
| 44 | puts "Windgeschwindigkeit km/h: " + datagrams[21] |
---|
| 45 | puts "Niederschlag: " + datagrams[22] |
---|
| 46 | puts "Regen ja/nein: " + datagrams[23] |
---|
| 47 | puts "---------------------" |
---|
| 48 | MQTT::Client.connect('mqtt://notwist:pixies@wigbels.net') do |c| |
---|
| 49 | c.publish('oben/temperatur', datagrams[3]) |
---|
| 50 | end |
---|
| 51 | #log(INFO, 'added 100 liter of gas to sensor-database') |
---|
| 52 | end |
---|
| 53 | @serialport.close |
---|
| 54 | rescue => msg |
---|
| 55 | log(ERROR, "error: #{msg}") |
---|
| 56 | retry |
---|
| 57 | ensure |
---|
| 58 | @serialport.close |
---|
| 59 | end |
---|
| 60 | # puts "Filename: "+__FILE__.to_s |
---|
| 61 | # puts "Linenumber: "+__LINE__.to_s |
---|
| 62 | # log(WARN, 'warning', 'mymethod' ) |
---|
| 63 | # @log.error('my_method2') { 'Error!' } |
---|
| 64 | end |
---|
| 65 | end |
---|
| 66 | |
---|
| 67 | |
---|
| 68 | #------------------------------------------ |
---|
| 69 | status = HotColdRain.new("HotColdRain").start |
---|
| 70 | |
---|
| 71 | #if status != 0 |
---|
| 72 | # puts "Some error occured." |
---|
| 73 | #endd |
---|
| 74 | |
---|
| 75 | |
---|
| 76 | |
---|
| 77 | |
---|
| 78 | |
---|
| 79 | |
---|