? ?
[ebusd]
[[mode]]
type = num
knx_dpt = 5
knx_send = 8/6/100
knx_listen = 8/7/100
knx_reply = 8/6/100
comment = Heizkreis - Betriebsart
ebusd_type = "set"
ebusd_cmd = "cir2 mode"
type = num
knx_dpt = 1
knx_send = 8/7/100
knx_listen = 8/6/100
knx_reply = 8/6/100
knx_send = 8/7/100
knx_listen = 8/6/100
knx_reply = 8/[COLOR="Red"]7[/COLOR]/100
2013-05-20 14:42:22,919 SmartHome.py INFO eBus: called to refresh item: ebusd.mode -- __init__.py:update_item:157 2013-05-20 14:42:22,923 SmartHome.py DEBUG eBus: set parameter: value:1 cmd:cir2 mode -- __init__.py:set_parameter:78 2013-05-20 14:42:23,051 SmartHome.py DEBUG eBus: request: set cir2 mode 1 >>><<< answer: ACK -- __init__.py:_request:73 2013-05-20 14:42:23,055 SmartHome.py DEBUG eBus: command:set cir2 mode 1 -- __init__.py:set_parameter:81 2013-05-20 14:42:23,059 SmartHome.py DEBUG eBus: answer:ACK -- __init__.py:set_parameter:82 2013-05-20 14:42:23,065 SmartHome.py DEBUG 0.0.0 set 8/7/100 to 1 -- __init__.py:parse_telegram:160
arse_telegram:160". Soweit korrekt. 2013-05-20 14:45:01,373 SmartHome.py DEBUG 0.0.1 set 8/7/100 to 1 -- __init__.py:parse_telegram:160
2013-05-20 14:54:23,378 SmartHome.py DEBUG 0.0.0 read 8/6/100 -- __init__.py:parse_telegram:178 2013-05-20 14:54:23,417 SmartHome.py DEBUG 0.0.0 set 8/6/100 to False -- __init__.py:parse_telegram:165 2013-05-20 14:54:23,422 SmartHome.py DEBUG ebusd.mode = 0 via KNX 0.0.0 -- item.py:_update:214 2013-05-20 14:54:23,429 SmartHome.py INFO eBus: called to refresh item: ebusd.mode -- __init__.py:update_item:157 2013-05-20 14:54:23,434 SmartHome.py DEBUG eBus: set parameter: value:0 cmd:cir2 mode -- __init__.py:set_parameter:78 2013-05-20 14:54:23,575 SmartHome.py DEBUG eBus: request: set cir2 mode 0 >>><<< answer: ACK -- __init__.py:_request:73 2013-05-20 14:54:23,579 SmartHome.py DEBUG eBus: command:set cir2 mode 0 -- __init__.py:set_parameter:81 2013-05-20 14:54:23,583 SmartHome.py DEBUG eBus: answer:ACK -- __init__.py:set_parameter:82
[ebusd]
[[mode]]
type = num
knx_dpt = 1
knx_send = 8/7/100
knx_listen = 8/6/100
knx_reply = 8/6/100
comment = Heizkreis - Betriebsart
ebusd_type = "set"
ebusd_cmd = "cir2 mode"
[ebusd]
[[mode]]
type = num
knx_dpt = 1
knx_send = 8/7/100
knx_listen = 8/6/100
comment = Heizkreis - Betriebsart
ebusd_type = "set"
ebusd_cmd = "cir2 mode"
2013-05-20 12:43:22,915 SmartHome.py DEBUG ebusd.mode = 1 via CLI 192.168.2.29 -- item.py:_update:214 2013-05-20 12:43:22,924 SmartHome.py INFO eBus: called to refresh item: ebusd.mode -- __init__.py:update_item:157 2013-05-20 12:43:22,928 SmartHome.py DEBUG eBus: set parameter: value:1 cmd:cir2 mode -- __init__.py:set_parameter:78 2013-05-20 12:43:23,073 SmartHome.py DEBUG eBus: request: set cir2 mode 1 >>><<< answer: ACK -- __init__.py:_request:73 2013-05-20 12:43:23,078 SmartHome.py DEBUG eBus: command:set cir2 mode 1 -- __init__.py:set_parameter:81 2013-05-20 12:43:23,085 SmartHome.py DEBUG eBus: answer:ACK -- __init__.py:set_parameter:82
#!/usr/bin/env python
# vim: set encoding=utf-8 tabstop=4 softtabstop=4 shiftwidth=4 expandtab
#########################################################################
# Copyright 2012-2013 KNX-User-Forum e.V. https://knx-user-forum.de/
#########################################################################
# This file is part of SmartHome.py. http://smarthome.sourceforge.net/
#
# SmartHome.py is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# SmartHome.py is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with SmartHome.py. If not, see <http://www.gnu.org/licenses/>.
#########################################################################
import sys
import logging
import socket
import threading
import struct
import time
import datetime
logger = logging.getLogger('')
class ebusex(Exception):
pass
class ebusBase():
def __init__(self, host, port=8888):
self.host = host
self.port = int(port)
self._sock = False
self.is_connected = False
self._connection_attempts = 0
self._connection_errorlog = 60
self._params = []
self._attrs = []
def connect(self):
try:
self._sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
self._sock.settimeout(2)
self._sock.connect((self.host, self.port))
except Exception, e:
self._connection_attempts -= 1
if self._connection_attempts <= 0:
logger.error('eBus: could not connect to {0}:{1}: {2}'.format(self.host, self.port, e))
self._connection_attempts = self._connection_errorlog
return
logger.info('eBus: connected to {0}:{1}'.format(self.host, self.port))
self.is_connected = True
self._connection_attempts = 0
def close(self):
self.is_connected = False
try:
self._sock.close()
self._sock = False
except:
pass
def _request(self, request):
self._sock.send(request)
answer = self._sock.recv(1024)
logger.debug("eBus: request: {0} >>><<< answer: {1}".format(request,answer[:-2])) #### [:-2] entfernt Zeilenumbruch/letzte 2 Zeichen
answer = answer.replace(" ", "") ### Remove whitespaces
return answer[:-2]
def set_parameter(self,cmd,item):
logger.debug("eBus: set parameter: value:{0} cmd:{1}".format(item,cmd))
request = "set " + cmd + " " + str(item)
answer = self._request(request)
logger.debug("eBus: command:{0}".format(request))
logger.debug("eBus: answer:{0}".format(answer))
def refresh_attributes(self):
self.refresh_id = 1
for cmds in self._attribute:
if cmds[0] == "cycle":
request = cmds[0] + " " + cmds[1] #build command
else:
request = "get" + " " + cmds[1] #build command
if self.refresh_id == self.id:
answer = self._request(request)
#logger.debug("eBus: Parameter/Refresh {0}/{1}".format(self.id,self.refresh_id))
self._attribute[cmds](answer, 'eBus', 'refresh') #according to item(answer)
return answer
else:
self.refresh_id +=1
class eBus(ebusBase):
_parameter = {}
_attribute = {}
alive = True
def __init__(self, smarthome, host, port=8888, cycle=30):
ebusBase.__init__(self, host, port)
self._sh = smarthome
self._cycle = int(cycle)
self.connect()
self.id = 1
self.refresh_id = 0
def run(self):
self.alive = True
new_cycle = self._cycle/int(len(self._attribute))
logger.debug("eBus: cycle = {0} seconds".format(new_cycle))
self._sh.scheduler.add('eBus', self._refresh, cycle=new_cycle)
def stop(self):
self.alive = False
def _refresh(self):
if not self.is_connected:
return
start = time.time()
if len(self._attribute) > 0:
#logger.debug("eBus: attributes: {0}".format(self._attribute))
val = self.refresh_attributes()
#logger.debug("eBus: refreshed value {0}".format(val))
if self.id >= len(self._attribute):
self.id = 1
else:
self.id += 1
#logger.debug("eBus: next cycle-id: {0}".format(self.id))
cycletime = time.time() - start
#logger.debug("eBus: number of attributes {0}".format(len(self._attribute)))
#logger.debug("cycle takes {0} seconds".format(cycletime))
def parse_item(self, item):
if 'ebusd_type' in item.conf: # Attribute und Parameter werden regelmäßig ausgelesen
ebus_type = item.conf['ebusd_type']
ebus_cmd = item.conf['ebusd_cmd'] # Wert hinter "ebusd_cmd = "
self._attribute[ebus_type,ebus_cmd] = item # makes array
logger.debug("eBus: new set = item:{0} type:{1} cmd:{2}".format(item,ebus_type,ebus_cmd))
return self.update_item
def update_item(self, item, caller=None, source=None):
if caller != 'eBus':
logger.info("eBus: called to refresh item: {0}".format(item))
self.set_parameter(item.conf['ebusd_cmd'], item())
def refresh_parameters(self):
self.refresh_id = 1
for p in self._parameter:
request = p
if self.refresh_id == self.id:
answer = self._request(request, 8)
logger.info("eBus: Parameter/Refresh {0}/{1}".format(self.id,self.refresh_id))
return answer
else:
self.refresh_id +=1
logger.info("eBus: Parameter/Refresh {0}/{1}".format(self.id,self.refresh_id))
Einen Kommentar schreiben: