Извлечение поля даты из отметки времени и создание нового поля в качестве раздела в AWS Glue ETL

Question

Я пытаюсь создать разделение на одном из полей в CSV и сохранить его как паркет с помощью Glue ETL (python). Проблема в том, что это поле является временной меткой, поэтому перед созданием раздела я хочу извлечь дату из этой временной метки и сохранить ее в поле, а затем использовать это новое поле для создания раздела.

Вот мой код ниже. Я хочу извлечь дату из поля verifydatetime в поле под названием validdate, а затем добавить его в качестве ключа раздела во время записи в динамический фрейм. Есть идеи?

args = getResolvedOptions(sys.argv, ['JOB_NAME'])

sc = SparkContext()
glueContext = GlueContext(sc)
spark = glueContext.spark_session
job = Job(glueContext)
job.init(args['JOB_NAME'], args)

datasource0 = glueContext.create_dynamic_frame.from_catalog(database 
= "sample_database", table_name = "sample_table", transformation_ctx 
= "datasource0")

applymapping1 = ApplyMapping.apply(frame = datasource0, mappings = 
[("personid", "string", "personid", "string"), 
("verificationdatetime", "string", "verificationdatetime"), ], transformation_ctx = "applymapping1")

resolvechoice2 = ResolveChoice.apply(frame = applymapping1, choice = 
"make_struct", transformation_ctx = "resolvechoice2")

dropnullfields3 = DropNullFields.apply(frame = resolvechoice2, 
transformation_ctx = "dropnullfields3")

datasink4 = glueContext.write_dynamic_frame.from_options(frame = 
dropnullfields3, connection_type = "s3", connection_options = 
{"path": "s3://samplebucket/samplefile/","partitionKeys":["type"]}, 
format = "parquet", transformation_ctx = "datasink4")

job.commit()

Answer 1

df = dropnullfields3.toDF ()

df = df.withColumn ('validdate', to_date('verifydatetime', 'MM/dd/yyyy HH:mm:ss.SSSSSS'))

Используйте формат даты, указанный в verificationdatetime