move old stuff away

6 files changed, 0 insertions, 181 deletions

diff --git a/bin/ebus b/bin/ebus
deleted file mode 120000
index 1232ff3..0000000
--- a/bin/ebus
+++ /dev/null
@@ -1 +0,0 @@
-../ebus/
\ No newline at end of file
diff --git a/bin/ebus_app.py b/bin/ebus_app.py
deleted file mode 100755
index c9b89f6..0000000
--- a/bin/ebus_app.py
+++ /dev/null
@@ -1,41 +0,0 @@
-#!/usr/bin/env python
-# -*- coding:utf-8 -*-
-# xapek.org, 2010
-import asyncore
-from sqlalchemy import create_engine
-from sqlalchemy.orm import sessionmaker
-from ebus.web import model
-from ebus import EbusReader
-
-#db_engine = create_engine('sqlite:///:memory:', echo=True)
-db_engine = create_engine("postgresql://yvesf:iii@10.2.2.13:5432/yvesf", echo=True)
-
-session = sessionmaker(bind=db_engine)()
-
-
-def insert(ebus_packet):
-    try:
-        for valueKey in ebus_packet.values().keys():
-            print "Key", valueKey
-            sensor = session.query(model.Sensor).filter(model.Sensor.name==valueKey).first()
-            if not sensor:
-                print "Add sensor %s" % valueKey
-                sensor = model.Sensor(valueKey)
-                session.add(sensor)
-            print sensor
-            m_value = model.Value(sensor, ebus_packet.values()[valueKey])
-            session.add(m_value)
-            print m_value
-        session.commit()
-    except Exception,e:
-        session.rollback()
-        try:
-            print "Failed to insert %s -- reason %s" % (ebus_packet.name(), e)
-        except Exception,e:
-            print e
-
-reader = EbusReader()
-reader.handle_ebus = insert
-reader.debug = False
-
-asyncore.loop()
diff --git a/bin/ebus_dump.py b/bin/ebus_dump.py
deleted file mode 100755
index c170849..0000000
--- a/bin/ebus_dump.py
+++ /dev/null
@@ -1,49 +0,0 @@
-#!/usr/bin/env python
-# -*- coding:utf8 -*-
-import asyncore
-import time
-from ebus import EbusReader
-from ebus.model.sql import ModelBase, EbusSQL, Value
-from ebus.model.sql import EbusSQL
-from sqlalchemy import create_engine
-from sqlalchemy.orm import sessionmaker
-import logging
-
-logging.basicConfig()
-
-#logging.getLogger('sqlalchemy.engine').setLevel(logging.INFO)
-logging.getLogger('sqlalchemy.engine').setLevel(logging.WARNING)
-
-logger = logging.getLogger('ebus.dump')
-logger.setLevel(logging.INFO)
-
-#engine = create_engine('sqlite:///:memory:', echo=True)
-engine = create_engine("postgresql:///ebus")
-
-ModelBase.metadata.create_all(engine)
-
-Session = sessionmaker()
-Session.configure(bind=engine)
-session = Session()
-
-
-class MyEbusReader(EbusReader):
-    def __init__(self,*args,**kwargs):
-        EbusReader.__init__(self,*args,**kwargs)
-        self.debug = True
-        self.sql = EbusSQL(session)
-    def handle_ebus(self,ebus_packet):
-        for field in self.sql.get_values(ebus_packet):
-            session.add(field)
-
-        session.commit()
-
-        logger.info("packet %s" % ebus_packet.name())
-
-MyEbusReader()
-try:
-    asyncore.loop()
-except KeyboardInterrupt:
-    pass
-#    for data in session.query(Value).all():
-#        print data
diff --git a/bin/web_dev.py b/bin/web_dev.py
deleted file mode 100755
index 8c45f0b..0000000
--- a/bin/web_dev.py
+++ /dev/null
@@ -1,9 +0,0 @@
-#!/usr/bin/env python
-# coding: utf-8
-import bottle
-from ebus import webhdf
-
-if __name__ == "__main__":
-    bottle.debug(True)
-
-    bottle.run(webhdf.app, host="0.0.0.0", port=8080, reloader=True)
diff --git a/bin/web_prod.py b/bin/web_prod.py
deleted file mode 100755
index 97bf39c..0000000
--- a/bin/web_prod.py
+++ /dev/null
@@ -1,9 +0,0 @@
-#!/usr/bin/env python
-# coding: utf-8
-import bottle
-from ebus import webhdf
-
-if __name__ == "__main__":
-    bottle.debug(False)
-
-    bottle.run(webhdf.app, host="0.0.0.0", port=8000, reloader=False)
diff --git a/bin/wettermichel.py b/bin/wettermichel.py
deleted file mode 100755
index 57b517a..0000000
--- a/bin/wettermichel.py
+++ /dev/null
@@ -1,72 +0,0 @@
-#!/usr/bin/env python
-# -*- coding:utf8 -*-
-import httplib
-from StringIO import StringIO
-
-from lxml import objectify
-
-from sqlalchemy import create_engine, text
-from sqlalchemy.ext.sqlsoup import SqlSoup
-
-soup = SqlSoup(
-    create_engine("postgresql://ebus:ebus@10.2.2.26:5432/ebus") )
-
-def read():
-    conn = httplib.HTTPConnection("www.wettermichel.de")
-    conn.request("GET", "/weatherdata/params3.xml")
-    result = conn.getresponse()
-    assert result.status == 200, 'Site answered with Status 200'
-
-    xml = objectify.parse( result )
-    conn.close()
-    return xml
-
-def get_sensor_id(sensor_name):
-    try:
-        sensor_id = soup.sensor.filter(soup.sensor.name == sensor_name).one()
-        return sensor_id.id
-    except:
-        conn = soup.connection()
-        conn.execute(text("""INSERT INTO sensor(name) VALUES (:name)"""),
-                     name = sensor_name)
-        soup.commit()
-        return soup.sensor.filter(soup.sensor.name == sensor_name).one().id
-
-def insert(sensor_name,value_int=None, value_float=None, value_string=None):
-    sql = text("""INSERT INTO value(
-          timestamp, sensor_id, type, value_int, value_float, value_string)
-          VALUES (
-          NOW(), :sensor_id, :type, :value_int, :value_float, :value_string)""")
-    conn = soup.connection()
-    ttype = value_int != None and "int" or \
-            value_float != None and "float" or \
-            value_string != None and "string" or \
-            None
-    assert ttype != None, 'ttype is set'
-    conn.execute(sql, sensor_id=get_sensor_id(sensor_name),
-                      type=ttype,
-                      value_int=value_int,
-                      value_float=value_float,
-                      value_string=value_string)
-    soup.commit()
-
-###############
-
-xml = read()
-for keyval in xml.xpath("/data/*"):
-    if keyval.tag == "entry":
-        continue
-
-    if isinstance(keyval, objectify.IntElement):
-        insert("de.wettermichel.%s"%keyval.tag,
-               value_int=int(keyval.text))
-    elif isinstance(keyval, objectify.FloatElement):
-        insert("de.wettermichel.%s"%keyval.tag,
-               value_float=float(keyval.text))
-    elif isinstance(keyval, objectify.StringElement):
-        insert("de.wettermichel.%s"%keyval.tag,
-               value_string=keyval.text)
-    else:
-        print "ignore other: %s %s" % (keyval.tag, keyval.__class__)
-
-