Я пытаюсь создать раздел на одном из полей в csv и сохранить его как паркет, используя Glue ETL (python).Проблема в том, что это поле является временной меткой, поэтому перед созданием раздела я хочу извлечь дату из этой временной метки и сохранить ее в поле, а затем использовать это новое поле для создания раздела.
Вот мой код ниже,Я хочу извлечь дату из поля verificationdatetime в поле с именем verificationdate, а затем добавить его как partitionkey во время записи в DynamicFrame.Есть идеи?
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()