Dank @starfish haben wir nun eine Möglichkeit modbus Daten zu pollen. Das ist uU ganz hilfreich (zumindest bis ein Modbus-Adapter fertig ist).
Ich habe für meine Zwecke das Python-Script angepasst, da ich serielle Geräte am Bus habe. Zudem wollte ich mehrere Werte abfragen.
Hier das Python-Script 'pymodhaus.py' (liegt bei mir in /home/pi/modbus-crawler):
#!/usr/bin/env python
import sys, time, json
from pymodbus.constants import Endian
from pymodbus.payload import BinaryPayloadDecoder
from pymodbus.client.sync import ModbusSerialClient as ModbusClient
from pymodbus.transaction import ModbusRtuFramer
def decode32(decval):
decoder = BinaryPayloadDecoder.fromRegisters(decval.registers, endian=Endian.Big)
return decoder.decode_32bit_float()
def decode64(decval):
decoder = BinaryPayloadDecoder.fromRegisters(decval.registers, endian=Endian.Big)
return decoder.decode_64bit_int()
client = ModbusClient(method='rtu', port='/dev/ttyUSB0', stopbits=1, bytesize=8, timeout=0.05, baudrate=19200, parity='N')
connection = client.connect()
#print "Connection: ", connection * Only for debug
try:
timestamp = str(time.time()).split('.')[0]
# iEM3155 Haus --> Adresse immer 1 kleiner als im Schneider Datenblatt; weiss der Geier warum
# HausL01 = decode32(client.read_holding_registers(3028-1, 2, unit=10))
# HausL02 = decode32(client.read_holding_registers(3030-1, 2, unit=10))
# HausL03 = decode32(client.read_holding_registers(3032-1, 2, unit=10))
HausLNM = decode32(client.read_holding_registers(3036-1, 2, unit=10))
HausP01 = decode32(client.read_holding_registers(3054-1, 2, unit=10)) * 1000
HausP02 = decode32(client.read_holding_registers(3056-1, 2, unit=10)) * 1000
HausP03 = decode32(client.read_holding_registers(3058-1, 2, unit=10)) * 1000
HausPower = decode32(client.read_holding_registers(3060-1, 2, unit=10)) * 1000
# HausPowerB = decode32(client.read_holding_registers(3068-1, 2, unit=10)) * 1000
# HausPowerS = decode32(client.read_holding_registers(3076-1, 2, unit=10)) * 1000
HausImport = decode64(client.read_holding_registers(3204-1, 4, unit=10)) / 1000
HausExport = decode64(client.read_holding_registers(3208-1, 4, unit=10)) / 1000
except:
print 6
else:
json_string = json.dumps({'ts': timestamp, 'HausLNM': round(HausLNM,2),
'HausP01': round(HausP01,0), 'HausP02': round(HausP02,0), 'HausP03': round(HausP03,0),
'HausPower': round(HausPower,0),'HausImport': HausImport, 'HausExport': HausExport})
print json_string
client.close()
Nun zum iobroker.javascript:
// Create Datenpunkte für PV-Anlage
createState('javascript.1.Solar.pi1Result', '');
createState('javascript.1.Solar.modPoll', 1);
// Create Datenpunkte für Schneider EnergyMeter 'Haus'
createState('javascript.1.Solar.Schneider.HausLNM', 0);
createState('javascript.1.Solar.Schneider.HausP01', 0);
createState('javascript.1.Solar.Schneider.HausP02', 0);
createState('javascript.1.Solar.Schneider.HausP03', 0);
createState('javascript.1.Solar.Schneider.HausPower', 0);
createState('javascript.1.Solar.Schneider.HausImport', 0);
createState('javascript.1.Solar.Schneider.HausExport', 0);
createState('javascript.1.Solar.Schneider.HausTimeStamp', 0);
schedule({astro: "sunrise"}, function () {
setState('javascript.1.Solar.modPoll', 1, true);
});
schedule({astro: "sunset"}, function () {
setState('javascript.1.Solar.modPoll', 0, true);
});
//Schedule Script Run Haus
schedule("*/1 * * * *", function (Haus) {
var enabled = getState("javascript.1.Solar.modPoll"/*javascript.1.Solar.modPoll*/).val;
if (enabled == 1) {
var python = require('child_process').spawn('python', ["/home/pi/modbus-crawler/pymodhaus.py"]);
// second argument is array of parameters, e.g.:
var result = '';
python.stdout.on('data', function(data){ result += data.toString(); });
python.on('close', function(code1){
if (code1 !== 0) {
log('Error: ' + code1, 'error');
} else {
if (result == 6) {
log('Error: Fehler im Modbus Python Script -Haus-', 'warn');
} else {
log('Modbus Python Script -Haus- erfolgreich gelaufen, Werte akzeptiert');
setState('javascript.1.Solar.pi1Result', result);
var solar1 = JSON.parse(result);
setState('javascript.1.Solar.Schneider.HausLNM', solar1.HausLNM, true);
setState('javascript.1.Solar.Schneider.HausP01', solar1.HausP01, true);
setState('javascript.1.Solar.Schneider.HausP02', solar1.HausP02, true);
setState('javascript.1.Solar.Schneider.HausP03', solar1.HausP03, true);
setState('javascript.1.Solar.Schneider.HausPower', solar1.HausPower, true);
setState('javascript.1.Solar.Schneider.HausImport', solar1.HausImport, true);
setState('javascript.1.Solar.Schneider.HausExport', solar1.HausExport, true);
setState('javascript.1.Solar.Schneider.HausTimeStamp', solar1.ts, true);
}
}
});
}
});
Etwas komplexer hat sich dann der Umstand erwiesen, dass ich das Script (mangels tcp) lokal am Solar-PI laufen lassen muss. Daher musste ein iobroker als remote-host auf den PI. Aber dass ist ein ganz anderes Thema.
Version 0.1.0 2015-06-22 First release
