Prefect Collection for interacting with Azure in your flows: prefect-azure

Docs

https://prefecthq.github.io/prefect-azure/

Code

Examples

from prefect import flow

from prefect_azure import BlobStorageAzureCredentials
from prefect_azure.blob_storage import blob_storage_download

@flow
def example_blob_storage_download_flow():
    connection_string = "connection_string"
    blob_storage_credentials = BlobStorageAzureCredentials(
        connection_string=connection_string,
    )
    data = blob_storage_download(
        blob="prefect.txt",
        container="prefect",
        azure_credentials=blob_storage_credentials,
    )
    return data

example_blob_storage_download_flow() 
1 Like