From 773093acabfb84b88c37bb0342d6a8d4a6f8267a Mon Sep 17 00:00:00 2001 From: Ebus-at-dockstar Date: Sat, 26 Jul 2014 19:57:28 +0200 Subject: move ebus-datastore to heap --- heap/ebus-datastore/testfiles/bsdtest.py | 49 ++++++++++++++++++++++++++++++++ 1 file changed, 49 insertions(+) create mode 100644 heap/ebus-datastore/testfiles/bsdtest.py (limited to 'heap/ebus-datastore/testfiles/bsdtest.py') diff --git a/heap/ebus-datastore/testfiles/bsdtest.py b/heap/ebus-datastore/testfiles/bsdtest.py new file mode 100644 index 0000000..b6587d0 --- /dev/null +++ b/heap/ebus-datastore/testfiles/bsdtest.py @@ -0,0 +1,49 @@ +import bsddb +import psycopg2 +from subprocess import Popen,PIPE +import time +import sys + +db = bsddb.btopen("test.btdbm") + +conn = psycopg2.connect("dbname=ebus user=ebus") +cur = conn.cursor() +sql = """SELECT * from sensor""" +cur.execute(sql) +sensors = cur.fetchall() +sensors = map(lambda a: (a[0], a[1]), sensors) +sensors = dict(sensors) +cur.close() +conn.close() + +pg_dump = Popen(["psql","-A","-t"], stdin=PIPE, stdout=PIPE) +pg_dump.stdin.write("COPY value TO stdout WITH DELIMITER '|' NULL AS '';\n") +pg_dump.stdin.close() + +c=0 +try: + while not pg_dump.stdout.closed: + line = pg_dump.stdout.readline() + c += 1 + if line == "": + continue + (oid, s_timestamp, sensor_id, type, value_float, value_int, value_string) = line.split("|") + name = sensors[int(sensor_id)] + timestamp = time.strptime(s_timestamp.split(".")[0], "%Y-%m-%d %H:%M:%S") + timestamp = time.mktime(timestamp) + if type == "int": + value= value_int + elif type == "float": + value = value_float + else: + continue + + db["%s:%d"%(name,timestamp)] = value + if c%10000==0: + print "%d: %s:%s=%s"%(c,name,s_timestamp,value) +except KeyboardInterrupt: + db.close() + +print "done" + + -- cgit v1.2.1