Я пытаюсь получить широту из функции udf в качестве возвращаемого значения для извлечения в новый столбец данных, но не могу реализовать. Ниже приведен мой код.
def lat(ip_address):
try:
record = reader.city(ip_address)
return record.location.latitude
except Exception:
pass
new_udf=udf(lat, FloatType())
df_new=df.withColumn("distance",new_udf(df.ip_address))
Я получаю следующую ошибку "Ошибка типа: Обязательный аргумент 'fileno' (поз. 1) не найден"