У меня есть следующее json
{'client_partition_id': 2, 'client_id': 'd7d3e26f-d105-4816-825d-d5858b9cf0d1', 'ingestion_timestamp': datetime.datetime(2020, 4, 10, 4, 3, 19, 654977, tzinfo=<UTC>)}
в nd json файле
, которое пытается прочитать в spark spark.read.json()
, но получает сообщение об ошибке в pyspark для анализа даты и времени. пожалуйста, помогите мне решить эту проблему.