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 --- ebus-datastore/testfiles/bsdtest.py | 49 ------------------------------------- 1 file changed, 49 deletions(-) delete mode 100644 ebus-datastore/testfiles/bsdtest.py (limited to 'ebus-datastore/testfiles/bsdtest.py') diff --git a/ebus-datastore/testfiles/bsdtest.py b/ebus-datastore/testfiles/bsdtest.py deleted file mode 100644 index b6587d0..0000000 --- a/ebus-datastore/testfiles/bsdtest.py +++ /dev/null @@ -1,49 +0,0 @@ -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