From 07d9559100592793d4963737caa15aefac897c7b Mon Sep 17 00:00:00 2001 From: Nico Schottelius Date: Mon, 10 Oct 2016 13:00:08 +0200 Subject: [PATCH] Add db insert w/ json --- sql | 1 + swisscom-receive-packet.py | 14 +++++++++++++- 2 files changed, 14 insertions(+), 1 deletion(-) create mode 100644 sql diff --git a/sql b/sql new file mode 100644 index 0000000..3c6b165 --- /dev/null +++ b/sql @@ -0,0 +1 @@ +create table packets ( id SERIAL, received_dt timestamp default now(), provider varchar(128), packet json ); diff --git a/swisscom-receive-packet.py b/swisscom-receive-packet.py index 4090ccb..652bc93 100644 --- a/swisscom-receive-packet.py +++ b/swisscom-receive-packet.py @@ -35,7 +35,7 @@ class testHTTPServer_RequestHandler(BaseHTTPRequestHandler): print(self.dataToString(post_data)) # And insert into the db -# self.insert_xml(post_data) + self.insert_json("swisscom", post_data) # Send to Martin / port 8001 @@ -93,6 +93,18 @@ class testHTTPServer_RequestHandler(BaseHTTPRequestHandler): myhex = self.payload_hex(data) return bytes.fromhex(myhex).decode('utf-8') + def insert_json(self, provider, data): + try: + conn = psycopg2.connect("dbname=lorawan") + cursor = conn.cursor() + cursor.execute("insert into packets values (DEFAULT, DEFAULT, '%s', '%s')", (provider, data, )) + cursor.connection.commit() + conn.close() + except Exception as e: + print("DB Insert failed: %s" % e) + + + def insert_xml(self, data): try: conn = psycopg2.connect("dbname=hackzurich")