X-Git-Url: https://wylark.com/src/infoex-autowx.git/blobdiff_plain/d8cdec693274f345101d6a9a5efe337593cf17a7..07dd380ab9bdb7f6357d1c6c2328856ea00cd20e:/infoex-autowx.py?ds=sidebyside diff --git a/infoex-autowx.py b/infoex-autowx.py index 1cdc513..1844d45 100755 --- a/infoex-autowx.py +++ b/infoex-autowx.py @@ -43,7 +43,7 @@ import zeep import zeep.cache import zeep.transports -__version__ = '3.1.1' +__version__ = '3.2.1' LOG = logging.getLogger(__name__) LOG.setLevel(logging.NOTSET) @@ -155,6 +155,10 @@ def setup_logging(log_level): #LOG.addHandler(logging.handlers.SysLogHandler()) # fallback to stdout handler = logging.StreamHandler(sys.stdout) + formatter = logging.Formatter('%(asctime)s.%(msecs)03d ' + '%(levelname)s %(module)s - %(funcName)s: %(message)s', + '%Y-%m-%d %H:%M:%S') + handler.setFormatter(formatter) LOG.addHandler(handler) # ugly, but passable @@ -200,13 +204,7 @@ def main(): iemap = setup_infoex_counterparts_mapping(station['provider']) # override units if user selected metric - if 'units' not in station: - if station['provider'] != 'python': - LOG.error("Please specify the units in the configuration " - "file") - sys.exit(1) - - if station['units'] == 'metric': + if station['provider'] != 'python' and station['units'] == 'metric': final_data = switch_units_to_metric(final_data, fmap) (begin_date, end_date) = setup_time_values(station) @@ -296,6 +294,8 @@ def main(): infoex['wx_data'][element_cd] = round(infoex['wx_data'][element_cd]) elif element_cd in ['TOBS', 'air_temp', 'PRES', 'pressure']: infoex['wx_data'][element_cd] = round(infoex['wx_data'][element_cd], 1) + elif element_cd in ['PREC', 'precip_accum']: + infoex['wx_data'][element_cd] = round(infoex['wx_data'][element_cd], 2) # CONSIDER: Casting every value to Float() -- need to investigate if # any possible elementCds we may want are any other data @@ -468,7 +468,12 @@ def get_mesowest_data(begin, end, station): # construct final, completed API URL api_req_url = station['source'] + '&start=' + begin_date_str + '&end=' + end_date_str - req = requests.get(api_req_url) + + try: + req = requests.get(api_req_url) + except requests.exceptions.ConnectionError: + LOG.error("Could not connect to '%s'", api_req_url) + sys.exit(1) try: json = req.json()