data['winddegrees'] = w['wind']['deg'] if 'deg' in w['wind'] else math.nan
data['winddirection'] = degToCompass(data['winddegrees'])
- data['precipitation'] = w['rain']['3h'] if 'rain' in w else math.nan
+ data['precipitation'] = w['rain']['3h'] if 'rain' in w and w['rain'].get('3h') else math.nan
data['visibility'] = w.get('visibility', math.nan)
return data
sql = 'insert ignore into openweathermap ({}) values ({})'.format(', '.join(sql_columns), ','.join(['%s'] * len(sql_columns)))
with warnings.catch_warnings():
# ignore _mysql_exceptions.Warning: Duplicate entry '3319578-2018-08-01 20:50:00' for key 'cityid_datetime'
- warnings.simplefilter("ignore", category=MySQLdb.cursors.Warning)
+ warnings.simplefilter("ignore", category=MySQLdb.cursors.Warning)
conn.execute(sql, *sql_values)
conn.close()