Domoticz

Code: Select all

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import xml.etree.ElementTree as ET
import requests
from requests.exceptions import ConnectionError

domoticz_devicesIdx = {"PM10": 1,
                       "O3": 2,
                       "NO": 3,
                       "CO": 4,
                       "SO2": 5,
                       "NH3": 6,
                       "NO2": 7
                       }

domoticz_server = "http://localhost"
domoticz_port = 8080


class AirQuality:

    def __init__(self, location):
        self.link = "http://www.lml.rivm.nl/xml/actueel.xml"
        self.location = location
        timedata = "http://www.lml.rivm.nl/xml/actueel-update.xml"
        z = requests.get(timedata)
        f = ET.fromstring(z.content)
        data = f.getchildren()[0].getchildren()[0].getchildren()
        year = data[0].text
        month = data[1].text
        day = data[2].text
        hour = data[3].text
        self.fetch()

        print "Fetching data from: %s/%s/%s, hour: %s" % (day, month, year, hour)

    def push(self, device, value):
        try:
            requests.get(
                "%s:%d/json.htm?type=command&param=udevice&idx=%d&nvalue=0&svalue=%s" %
                (domoticz_server, domoticz_port, device, value))
        except ConnectionError:
            print "I wasn't able to contact the domoticz server, is it up?"

    def fetch(self):
        # fetch the data and push it
        z = requests.get(self.link)
        elements = ET.fromstring(z.content).getchildren()[0].getchildren()
        components = {}
        for element in elements:
            data = element.getchildren()
            station = data[2].text
            component = data[3].text
            unit = data[4].text
            value = data[5].text
            if not (station.lower() == self.location.lower()):
                continue

            components[component] = '%s%s' % (value, unit)

        for component in domoticz_devicesIdx.keys():
            device = domoticz_devicesIdx[component]
            try:
                value = components[component]
            except KeyError:
                value = "n/a"

            self.push(device, value)


AirQuality("NL01489")

Code: Select all

Traceback (most recent call last):
  File "airquality.py", line 71, in <module>
    AirQuality("NL01489")
  File "airquality.py", line 34, in __init__
    self.fetch()
  File "airquality.py", line 69, in fetch
    self.push(device, value)
  File "airquality.py", line 42, in push
    (domoticz_server, domoticz_port, device, value))
  File "/usr/lib/python2.7/dist-packages/requests/api.py", line 60, in get
    return request('get', url, **kwargs)
  File "/usr/lib/python2.7/dist-packages/requests/api.py", line 49, in request
    return session.request(method=method, url=url, **kwargs)
  File "/usr/lib/python2.7/dist-packages/requests/sessions.py", line 457, in request
    resp = self.send(prep, **send_kwargs)
  File "/usr/lib/python2.7/dist-packages/requests/sessions.py", line 563, in send
    adapter = self.get_adapter(url=request.url)
  File "/usr/lib/python2.7/dist-packages/requests/sessions.py", line 642, in get_adapter
    raise InvalidSchema("No connection adapters were found for '%s'" % url)
requests.exceptions.InvalidSchema: No connection adapters were found for '192.168.1.xxx:8081/json.htm?type=command&param=udevice&i  dx=309&nvalue=0&svalue=n/a'