Zack
12/02/2022, 12:52 AMAnna Geller
12/02/2022, 12:54 AM# you could do
from prefect import flow
@flow
def write_to_s3_glue():
wr.s3.to_parquet(
df=df,
path=f"s3://{bucket}/products/",
dataset=True,
database="awswrangler_test",
table="products",
mode="overwrite",
description=desc,
parameters=param,
columns_comments=comments
)
Zack
12/02/2022, 1:05 AMAnna Geller
12/02/2022, 1:38 AM