Mercurial > dive4elements > river
changeset 5213:76818dc2c937
Importer: Handle empty year fields in dgm csv
| author | Andre Heinecke <aheinecke@intevation.de> |
|---|---|
| date | Mon, 11 Mar 2013 11:20:32 +0100 |
| parents | 14186e924534 |
| children | b46df0609276 |
| files | flys-backend/contrib/shpimporter/dgm.py |
| diffstat | 1 files changed, 15 insertions(+), 4 deletions(-) [+] |
line wrap: on
line diff
--- a/flys-backend/contrib/shpimporter/dgm.py Mon Mar 11 10:12:55 2013 +0100 +++ b/flys-backend/contrib/shpimporter/dgm.py Mon Mar 11 11:20:32 2013 +0100 @@ -7,6 +7,10 @@ def latin(string): return unicode(string, "latin1") +import logging +logger = logging.getLogger("DGM") + + # <dbfield> : (<csvfield>, conversion function) DGM_MAP = { "projection" : "Projektion", @@ -82,6 +86,8 @@ return idx def get_time_interval_id(cur, a, b, oracle): + if not a or not b: + return None if oracle: cur.execute(SQL_SELECT_TIME_ID_ORA, (a, b)) else: @@ -122,10 +128,15 @@ fields[namedict[val]], "UTF-8")) km_von = fields[namedict["km_von"]] km_bis = fields[namedict["km_bis"]] - year_from = datetime.datetime( - int(fields[namedict["Jahr_von"]]), 1, 1) - year_to = datetime.datetime( - int(fields[namedict["Jahr_bis"]]),1 ,1) + year_from = None + year_to = None + try: + year_from = datetime.datetime( + int(fields[namedict["Jahr_von"]]), 1, 1) + year_to = datetime.datetime( + int(fields[namedict["Jahr_bis"]]),1 ,1) + except ValueError: + logger.warn("Invalid numbers (or none) found in year_from and year_to") name = "%s KM %s - %s" % (river_name, km_von, km_bis) cur = dbconn.cursor()