Changeset 66:d288a492befe for src/mlx

Timestamp:

04/09/12 06:55:01 (13 years ago)

Author:

István Váradi <ivaradi@…>

Branch:

default

Phase:

public

Message:

The METARs can now be downloaded

File:

• src/mlx/web.py (modified) (5 diffs)

src/mlx/web.py

@@ -10 +10 @@
 import urllib2
 import hashlib
+import time
 import datetime
 import codecs
+import re
 import xml.sax
 
@@ -426 +428 @@
 
     def run(self):
-        """Perform the plane update."""
+        """Perform the retrieval of the NOTAMs."""
         xmlParser = xml.sax.make_parser()
         notamHandler = NOTAMHandler([self._departureICAO, self._arrivalICAO])
@@ -447 +449 @@
 #------------------------------------------------------------------------------
 
+class GetMETARs(Request):
+    """Get the METARs from the NOAA website for certain airport ICAOs."""    
+
+    # Regular expression matching a METAR line
+    metarLine = re.compile("^[A-Z0-9]{4} ")
+
+    def __init__(self, callback, airports):
+        """Construct the request for the given airports."""
+        super(GetMETARs, self).__init__(callback)
+        self._airports = airports
+
+    def run(self):
+        """Perform the retrieval opf the METARs."""
+        tm = time.gmtime()
+        url = "http://weather.noaa.gov/pub/data/observations/metar/cycles/%02dZ.TXT" % \
+              (tm.tm_hour,)
+        f = urllib2.urlopen(url)
+        try:
+            result = Result()
+            result.metars = {}
+            for line in iter(f.readline, ""):
+                if len(line)>5 and line[4]==' ':
+                    icao = line[0:4]
+                    if icao in self._airports:
+                        result.metars[icao] = line.strip()
+        finally:
+            f.close()
+
+        return result
+
+#------------------------------------------------------------------------------
+
 class Handler(threading.Thread):
     """The handler for the web services.
@@ -476 +510 @@
         """Get the NOTAMs for the given two airports."""
         self._addRequest(GetNOTAMs(callback, departureICAO, arrivalICAO))
+        
+    def getMETARs(self, callback, airports):
+        """Get the METARs for the given airports."""
+        self._addRequest(GetMETARs(callback, airports))
         
     def run(self):
@@ -513 +551 @@
     #time.sleep(3)
 
-    handler.getNOTAMs(callback, "LHBP", "EPWA")
-    time.sleep(3)
+    #handler.getNOTAMs(callback, "LHBP", "EPWA")
+    handler.getMETARs(callback, ["LHBP", "EPWA"])
+    time.sleep(5)