prefect_aws_s3_bucket_block_file_upload_flow.py

1from prefect import flow
2from prefect_aws.s3 import S3Bucket
3
4@flow
5def upload_to_s3_example():
6    # Load the S3 bucket block
7    # Note: You must have a block named 'my-s3-bucket-block' created in Prefect
8    s3_bucket_block = S3Bucket.load("my-s3-bucket-block")
9    
10    # Upload a file to the bucket
11    s3_bucket_block.upload_from_path(
12        local_path="my_local_file.txt",
13        to_path="remote_folder/my_remote_file.txt"
14    )
15
16if __name__ == "__main__":
17    upload_to_s3_example()