Changeset 82 for openweather/update.py

Timestamp:

04/01/07 03:04:57 (5 years ago)

Author:

nigel

Message:

Added DB read commands

File:

• openweather/update.py (modified) (2 diffs)

openweather/update.py

@@ -1 +1 @@
 #!/usr/bin/env python
 
-DRUPAL_URL='http://localhost/~nigel/drupal47/xmlrpc.php'
+DRUPAL_URL='http://192.168.1.50/~nigel/drupal47/xmlrpc.php'
 DRUPAL_USERNAME='nigel'
 DRUPAL_PASSWORD='trustno1'
@@ -12 +12 @@
 
 import xmlrpclib
+import MySQLdb
 
 s = xmlrpclib.ServerProxy(DRUPAL_URL)
 
-print s.openweather.addEntry(DRUPAL_STATIONID, DRUPAL_USERNAME, DRUPAL_PASSWORD)
+conn = MySQLdb.connect(host=DB_HOST, user=DB_USERNAME, passwd=DB_PASSWORD, db=DB_NAME)
+cur = conn.cursor(MySQLdb.cursors.DictCursor)
+# Select the newest record
+if cur.execute("SELECT * FROM `weather` ORDER BY `timestamp` DESC LIMIT 1;") == 1:
+        row = cur.fetchone()
+        # convert all elements to strings
+        for i in row:
+                row[i] = str(row[i])
 
+        print s.openweather.addEntry(DRUPAL_STATIONID, DRUPAL_USERNAME, DRUPAL_PASSWORD, row)
+
+cur.close()
+conn.close()
+