diff --git a/python-sdk/docs/astro/sql/operators/load_file.rst b/python-sdk/docs/astro/sql/operators/load_file.rst index c0105b7c9..e75efa7e2 100644 --- a/python-sdk/docs/astro/sql/operators/load_file.rst +++ b/python-sdk/docs/astro/sql/operators/load_file.rst @@ -288,6 +288,15 @@ Users can also load data from an FTP: :start-after: [START load_file_example_21] :end-before: [END load_file_example_21] +Loading data from Azure Blob storage +~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ +Users can also load data from an Azure Blob storage: + +.. literalinclude:: ../../../../example_dags/example_load_file.py + :language: python + :start-after: [START load_file_example_25] + :end-before: [END load_file_example_25] + Default Datasets ~~~~~~~~~~~~~~~~ diff --git a/python-sdk/example_dags/example_load_file.py b/python-sdk/example_dags/example_load_file.py index 797231775..1eb1038e4 100644 --- a/python-sdk/example_dags/example_load_file.py +++ b/python-sdk/example_dags/example_load_file.py @@ -330,4 +330,17 @@ ) # [END load_file_example_24] + # [START load_file_example_25] + aql.load_file( + input_file=File("wasb://astro-sdk/sample.csv", conn_id="wasb_default_conn"), + output_table=Table( + conn_id=SNOWFLAKE_CONN_ID, + metadata=Metadata( + database=os.environ["SNOWFLAKE_DATABASE"], + schema=os.environ["SNOWFLAKE_SCHEMA"], + ), + ), + ) + # [END load_file_example_25] + aql.cleanup()