将时间戳字段转换为日期类型,并将其用作AWS Glue ETL中的分区

问题描述 投票:1回答:1

我正在尝试在csv中的一个字段上创建一个分区,并使用Glue ETL(python)将其存储为镶木地板。问题是,这个字段是一个时间戳,所以在创建分区之前,我想从这个时间戳中提取日期并将其存储在一个字段中,然后使用这个新字段来创建一个分区。

这是我的代码如下。我想从verificationdatetime字段中提取日期到一个名为verificationdate的字段,然后在写入DynamicFrame时将其添加为partitionkey。有任何想法吗?

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()
amazon-web-services aws-glue
1个回答
1
投票

df = dropnullfields3.toDF()

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

使用verificationdatetime中指定的日期格式

© www.soinside.com 2019 - 2024. All rights reserved.