Amit Rawat
02/28/2023, 12:47 PMMartin Picard
02/28/2023, 1:52 PMfrom argus.dagster.adls2 import adls2_resource
from azure.storage.blob import BlobServiceClient
from dagster import Definitions, OpExecutionContext, asset
@asset(required_resource_keys={"adls2"})
def example(context: OpExecutionContext):
client: BlobServiceClient = context.resources.adls2.blob_client
container = client.create_container("test")
container.upload_blob("myfile.pdf", data=...)
defs = Definitions(assets=[example], resources={"adls2": adls2_resource.configured({...})})