in 04_streaming/transform/df04.py [0:0]
def addtimezone(lat, lon):
try:
import timezonefinder
tf = timezonefinder.TimezoneFinder()
lat = float(lat)
lon = float(lon)
return lat, lon, tf.timezone_at(lng=lon, lat=lat)
except ValueError:
return lat, lon, 'TIMEZONE' # header