• Home
• Index

Index

_

__version__ (in module airflow.providers.microsoft.azure)

A

add_managed_identity_connection_widgets() (in module airflow.providers.microsoft.azure.utils) add_single_task_to_job() (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook method) ADFPipelineRunStatusSensorTrigger (class in airflow.providers.microsoft.azure.triggers.data_factory) adls_files (in module tests.system.microsoft.azure.example_adls_list) ADLSCreateObjectOperator (class in airflow.providers.microsoft.azure.operators.adls) ADLSDeleteOperator (class in airflow.providers.microsoft.azure.operators.adls) ADLSListOperator (class in airflow.providers.microsoft.azure.operators.adls) AdminClientHook (class in airflow.providers.microsoft.azure.hooks.asb) airflow.providers.microsoft.azure module airflow.providers.microsoft.azure.fs module airflow.providers.microsoft.azure.fs.adls module airflow.providers.microsoft.azure.hooks module airflow.providers.microsoft.azure.hooks.adx module airflow.providers.microsoft.azure.hooks.asb module airflow.providers.microsoft.azure.hooks.base_azure module airflow.providers.microsoft.azure.hooks.batch module airflow.providers.microsoft.azure.hooks.container_instance module airflow.providers.microsoft.azure.hooks.container_registry module airflow.providers.microsoft.azure.hooks.container_volume module airflow.providers.microsoft.azure.hooks.cosmos module airflow.providers.microsoft.azure.hooks.data_factory module airflow.providers.microsoft.azure.hooks.data_lake module airflow.providers.microsoft.azure.hooks.fileshare module airflow.providers.microsoft.azure.hooks.msgraph module airflow.providers.microsoft.azure.hooks.powerbi module airflow.providers.microsoft.azure.hooks.synapse module airflow.providers.microsoft.azure.hooks.wasb module airflow.providers.microsoft.azure.log module airflow.providers.microsoft.azure.log.wasb_task_handler module airflow.providers.microsoft.azure.operators module airflow.providers.microsoft.azure.operators.adls module airflow.providers.microsoft.azure.operators.adx module airflow.providers.microsoft.azure.operators.asb module airflow.providers.microsoft.azure.operators.batch module airflow.providers.microsoft.azure.operators.container_instances module airflow.providers.microsoft.azure.operators.cosmos module airflow.providers.microsoft.azure.operators.data_factory module airflow.providers.microsoft.azure.operators.msgraph module airflow.providers.microsoft.azure.operators.powerbi module airflow.providers.microsoft.azure.operators.synapse module airflow.providers.microsoft.azure.operators.wasb_delete_blob module airflow.providers.microsoft.azure.secrets module airflow.providers.microsoft.azure.secrets.key_vault module airflow.providers.microsoft.azure.sensors module airflow.providers.microsoft.azure.sensors.cosmos module airflow.providers.microsoft.azure.sensors.data_factory module airflow.providers.microsoft.azure.sensors.msgraph module

airflow.providers.microsoft.azure.sensors.wasb module airflow.providers.microsoft.azure.transfers module airflow.providers.microsoft.azure.transfers.local_to_adls module airflow.providers.microsoft.azure.transfers.local_to_wasb module airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake module airflow.providers.microsoft.azure.transfers.s3_to_wasb module airflow.providers.microsoft.azure.transfers.sftp_to_wasb module airflow.providers.microsoft.azure.triggers module airflow.providers.microsoft.azure.triggers.data_factory module airflow.providers.microsoft.azure.triggers.msgraph module airflow.providers.microsoft.azure.triggers.powerbi module airflow.providers.microsoft.azure.triggers.wasb module airflow.providers.microsoft.azure.utils module AIRFLOW_HOME (in module tests.system.microsoft.azure.example_azure_synapse) api_version (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook property) (airflow.providers.microsoft.azure.operators.powerbi.PowerBIDatasetRefreshOperator property) (airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger property) (airflow.providers.microsoft.azure.triggers.powerbi.PowerBITrigger property) append_result() (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator class method) ASBReceiveSubscriptionMessageOperator (class in airflow.providers.microsoft.azure.operators.asb) AsyncCredentials (in module airflow.providers.microsoft.azure.hooks.data_factory) (in module airflow.providers.microsoft.azure.hooks.wasb) azure_batch_operator (in module tests.system.microsoft.azure.example_azure_batch_operator) AZURE_BLOB_NAME (in module tests.system.microsoft.azure.example_local_to_wasb) AZURE_CONTAINER_NAME (in module tests.system.microsoft.azure.example_local_to_wasb) (in module tests.system.microsoft.azure.example_sftp_to_wasb) AZURE_STORAGE_ACOOUNT (in module tests.system.microsoft.azure.example_azure_container_instances) AZURE_VOLUME_SHARE_NAME (in module tests.system.microsoft.azure.example_azure_container_instances) azure_wasb_sensor (in module tests.system.microsoft.azure.example_wasb_sensors) AzureBaseHook (class in airflow.providers.microsoft.azure.hooks.base_azure) AzureBatchHook (class in airflow.providers.microsoft.azure.hooks.batch) AzureBatchOperator (class in airflow.providers.microsoft.azure.operators.batch) AzureContainerInstanceHook (class in airflow.providers.microsoft.azure.hooks.container_instance) AzureContainerInstancesOperator (class in airflow.providers.microsoft.azure.operators.container_instances) AzureContainerRegistryHook (class in airflow.providers.microsoft.azure.hooks.container_registry) AzureContainerVolumeHook (class in airflow.providers.microsoft.azure.hooks.container_volume) AzureCosmosDBHook (class in airflow.providers.microsoft.azure.hooks.cosmos) AzureCosmosDocumentSensor (class in airflow.providers.microsoft.azure.sensors.cosmos) AzureCosmosInsertDocumentOperator (class in airflow.providers.microsoft.azure.operators.cosmos) AzureDataExplorerHook (class in airflow.providers.microsoft.azure.hooks.adx) AzureDataExplorerQueryOperator (class in airflow.providers.microsoft.azure.operators.adx) AzureDataFactoryAsyncHook (class in airflow.providers.microsoft.azure.hooks.data_factory) AzureDataFactoryHook (class in airflow.providers.microsoft.azure.hooks.data_factory) AzureDataFactoryPipelineRunException AzureDataFactoryPipelineRunLink (class in airflow.providers.microsoft.azure.operators.data_factory) AzureDataFactoryPipelineRunStatus (class in airflow.providers.microsoft.azure.hooks.data_factory) AzureDataFactoryPipelineRunStatusSensor (class in airflow.providers.microsoft.azure.sensors.data_factory) AzureDataFactoryRunPipelineOperator (class in airflow.providers.microsoft.azure.operators.data_factory) AzureDataFactoryTrigger (class in airflow.providers.microsoft.azure.triggers.data_factory) AzureDataLakeHook (class in airflow.providers.microsoft.azure.hooks.data_lake) AzureDataLakeStorageV2Hook (class in airflow.providers.microsoft.azure.hooks.data_lake) AzureFileShareHook (class in airflow.providers.microsoft.azure.hooks.fileshare) AzureIdentityCredentialAdapter (class in airflow.providers.microsoft.azure.utils) AzureKeyVaultBackend (class in airflow.providers.microsoft.azure.secrets.key_vault) AzureServiceBusCreateQueueOperator (class in airflow.providers.microsoft.azure.operators.asb) AzureServiceBusDeleteQueueOperator (class in airflow.providers.microsoft.azure.operators.asb) AzureServiceBusReceiveMessageOperator (class in airflow.providers.microsoft.azure.operators.asb) AzureServiceBusSendMessageOperator (class in airflow.providers.microsoft.azure.operators.asb) AzureServiceBusSubscriptionCreateOperator (class in airflow.providers.microsoft.azure.operators.asb) AzureServiceBusSubscriptionDeleteOperator (class in airflow.providers.microsoft.azure.operators.asb) AzureServiceBusTopicCreateOperator (class in airflow.providers.microsoft.azure.operators.asb) AzureServiceBusTopicDeleteOperator (class in airflow.providers.microsoft.azure.operators.asb) AzureServiceBusUpdateSubscriptionOperator (class in airflow.providers.microsoft.azure.operators.asb) AzureSynapseHook (class in airflow.providers.microsoft.azure.hooks.synapse) AzureSynapsePipelineHook (class in airflow.providers.microsoft.azure.hooks.synapse) AzureSynapsePipelineRunException AzureSynapsePipelineRunLink (class in airflow.providers.microsoft.azure.operators.synapse) AzureSynapsePipelineRunStatus (class in airflow.providers.microsoft.azure.hooks.synapse) AzureSynapseRunPipelineOperator (class in airflow.providers.microsoft.azure.operators.synapse) AzureSynapseRunSparkBatchOperator (class in airflow.providers.microsoft.azure.operators.synapse) AzureSynapseSparkBatchRunStatus (class in airflow.providers.microsoft.azure.hooks.synapse)

B

BaseAzureServiceBusHook (class in airflow.providers.microsoft.azure.hooks.asb) BaseAzureSynapseHook (class in airflow.providers.microsoft.azure.hooks.synapse) begin (in module tests.system.microsoft.azure.example_adf_run_pipeline) (in module tests.system.microsoft.azure.example_synapse_run_pipeline) BLOB_NAME (in module tests.system.microsoft.azure.example_s3_to_wasb) (in module tests.system.microsoft.azure.example_wasb_sensors)

BLOB_PREFIX (in module tests.system.microsoft.azure.example_s3_to_wasb) (in module tests.system.microsoft.azure.example_sftp_to_wasb) blob_service_client() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) build_path() (airflow.providers.microsoft.azure.secrets.key_vault.AzureKeyVaultBackend static method) BUSY (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseSparkBatchRunStatus attribute)

C

cached_request_adapters (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook attribute) cancel_dataset_refresh() (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIHook method) cancel_job_run() (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook method) cancel_pipeline_run() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryAsyncHook method) (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) cancel_run_pipeline() (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineHook method) cancel_trigger() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) CANCELING (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryPipelineRunStatus attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineRunStatus attribute) CANCELLED (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryPipelineRunStatus attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineRunStatus attribute) check_for_blob() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) check_for_blob_async() (airflow.providers.microsoft.azure.hooks.wasb.WasbAsyncHook method) check_for_directory() (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook method) check_for_file() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeHook method) check_for_prefix() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) check_for_prefix_async() (airflow.providers.microsoft.azure.hooks.wasb.WasbAsyncHook method) check_wildcards_limit() (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator method) clean_up() (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator method) client() (airflow.providers.microsoft.azure.secrets.key_vault.AzureKeyVaultBackend method) CLIENT_ID (in module tests.system.microsoft.azure.example_azure_service_bus) (in module tests.system.microsoft.azure.example_powerbi_dataset_refresh) CLIENT_SECRET (in module tests.system.microsoft.azure.example_powerbi_dataset_refresh) close() (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler method) COMPLETED (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIDatasetRefreshStatus attribute) configure_job() (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook method) configure_pool() (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook method) configure_task() (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook method) conn_id (airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger property) (airflow.providers.microsoft.azure.triggers.powerbi.PowerBITrigger property) CONN_ID (in module tests.system.microsoft.azure.example_powerbi_dataset_refresh) conn_name_attr (airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook attribute) (airflow.providers.microsoft.azure.hooks.asb.BaseAzureServiceBusHook attribute) (airflow.providers.microsoft.azure.hooks.base_azure.AzureBaseHook attribute) (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook attribute) (airflow.providers.microsoft.azure.hooks.container_instance.AzureContainerInstanceHook attribute) (airflow.providers.microsoft.azure.hooks.container_registry.AzureContainerRegistryHook attribute) (airflow.providers.microsoft.azure.hooks.container_volume.AzureContainerVolumeHook attribute) (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook attribute) (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook attribute) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeHook attribute) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook attribute) (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook attribute) (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook attribute) (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.BaseAzureSynapseHook attribute) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook attribute) conn_type (airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook attribute) (airflow.providers.microsoft.azure.hooks.asb.BaseAzureServiceBusHook attribute) (airflow.providers.microsoft.azure.hooks.base_azure.AzureBaseHook attribute) (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook attribute) (airflow.providers.microsoft.azure.hooks.container_instance.AzureContainerInstanceHook attribute) (airflow.providers.microsoft.azure.hooks.container_registry.AzureContainerRegistryHook attribute) (airflow.providers.microsoft.azure.hooks.container_volume.AzureContainerVolumeHook attribute) (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook attribute) (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook attribute) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeHook attribute) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook attribute) (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook attribute) (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook attribute) (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.BaseAzureSynapseHook attribute) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook attribute)

connection() (airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook method) (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook method) (airflow.providers.microsoft.azure.hooks.container_instance.AzureContainerInstanceHook method) (airflow.providers.microsoft.azure.hooks.container_registry.AzureContainerRegistryHook method) CONTAINER_NAME (in module tests.system.microsoft.azure.example_wasb_sensors) CONTAINER_REGISTRY_SERVER (in module tests.system.microsoft.azure.example_azure_container_instances) copy_blobs() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) copy_files_to_wasb() (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator method) create_collection() (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook method) create_connection() (in module tests.system.microsoft.azure.example_powerbi_dataset_refresh) create_container() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) create_database() (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook method) create_dataflow() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) create_dataset() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) create_directory() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook method) (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook method) create_factory() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) create_file() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook method) create_file_system() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook method) create_fileshare() (in module tests.system.microsoft.azure.example_fileshare) create_job() (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook method) create_linked_service() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) create_or_update() (airflow.providers.microsoft.azure.hooks.container_instance.AzureContainerInstanceHook method) create_pipeline() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) create_pool() (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook method) create_queue() (airflow.providers.microsoft.azure.hooks.asb.AdminClientHook method) create_service_bus_queue (in module tests.system.microsoft.azure.example_azure_service_bus) create_share() (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook method) create_subscription() (airflow.providers.microsoft.azure.hooks.asb.AdminClientHook method) create_trigger() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) Credentials (in module airflow.providers.microsoft.azure.hooks.data_factory) (in module airflow.providers.microsoft.azure.hooks.data_lake) (in module airflow.providers.microsoft.azure.hooks.synapse)

D

DAG_ID (in module tests.system.microsoft.azure.example_adf_run_pipeline) (in module tests.system.microsoft.azure.example_adls_create) (in module tests.system.microsoft.azure.example_adls_delete) (in module tests.system.microsoft.azure.example_adls_list) (in module tests.system.microsoft.azure.example_azure_container_instances) (in module tests.system.microsoft.azure.example_azure_cosmosdb) (in module tests.system.microsoft.azure.example_fileshare) (in module tests.system.microsoft.azure.example_local_to_adls) (in module tests.system.microsoft.azure.example_local_to_wasb) (in module tests.system.microsoft.azure.example_msfabric) (in module tests.system.microsoft.azure.example_msgraph) (in module tests.system.microsoft.azure.example_powerbi) (in module tests.system.microsoft.azure.example_powerbi_dataset_refresh) (in module tests.system.microsoft.azure.example_s3_to_wasb) (in module tests.system.microsoft.azure.example_sftp_to_wasb) DATASET_ID (in module tests.system.microsoft.azure.example_powerbi_dataset_refresh) DEAD (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseSparkBatchRunStatus attribute) default_args (in module tests.system.microsoft.azure.example_azure_synapse) DEFAULT_AZURE_DATA_LAKE_CONN_ID (in module airflow.providers.microsoft.azure.operators.adls) default_conn_name (airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook attribute) (airflow.providers.microsoft.azure.hooks.asb.BaseAzureServiceBusHook attribute) (airflow.providers.microsoft.azure.hooks.base_azure.AzureBaseHook attribute) (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook attribute) (airflow.providers.microsoft.azure.hooks.container_instance.AzureContainerInstanceHook attribute) (airflow.providers.microsoft.azure.hooks.container_registry.AzureContainerRegistryHook attribute) (airflow.providers.microsoft.azure.hooks.container_volume.AzureContainerVolumeHook attribute) (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook attribute) (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryAsyncHook attribute) (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook attribute) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeHook attribute) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook attribute) (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook attribute) (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook attribute) (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.BaseAzureSynapseHook attribute) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook attribute)

DEFAULT_CPU (in module airflow.providers.microsoft.azure.operators.container_instances) DEFAULT_ENVIRONMENT_VARIABLES (in module airflow.providers.microsoft.azure.operators.container_instances) default_event_handler() (in module airflow.providers.microsoft.azure.operators.msgraph) DEFAULT_HEADERS (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook attribute) DEFAULT_MEMORY_IN_GB (in module airflow.providers.microsoft.azure.operators.container_instances) DEFAULT_SECURED_VARIABLES (in module airflow.providers.microsoft.azure.operators.container_instances) DEFAULT_VOLUMES (in module airflow.providers.microsoft.azure.operators.container_instances) DefaultResponseHandler (class in airflow.providers.microsoft.azure.hooks.msgraph) delete() (airflow.providers.microsoft.azure.hooks.container_instance.AzureContainerInstanceHook method) delete_blobs() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) delete_collection() (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook method) delete_container() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) delete_database() (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook method) delete_dataflow() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) delete_dataset() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) delete_directory() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook method) delete_document() (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook method) delete_factory() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) delete_file() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) delete_file_system() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook method) delete_files() (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator method) delete_fileshare() (in module tests.system.microsoft.azure.example_fileshare) delete_linked_service() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) delete_pipeline() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) delete_queue() (airflow.providers.microsoft.azure.hooks.asb.AdminClientHook method) delete_sftp_file() (in module tests.system.microsoft.azure.example_sftp_to_wasb) delete_share() (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook method) delete_subscription() (airflow.providers.microsoft.azure.hooks.asb.AdminClientHook method) delete_trigger() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) deserialize() (airflow.providers.microsoft.azure.triggers.msgraph.ResponseSerializer method) DIRECTORY (in module tests.system.microsoft.azure.example_fileshare) DISABLED (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIDatasetRefreshStatus attribute) does_collection_exist() (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook method) does_database_exist() (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook method) download() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) download_file() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeHook method) dry_run() (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator method)

E

encoded_query_parameters() (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook static method) ENV_ID (in module tests.system.microsoft.azure.example_adf_run_pipeline) (in module tests.system.microsoft.azure.example_adls_delete) (in module tests.system.microsoft.azure.example_adls_list) (in module tests.system.microsoft.azure.example_azure_container_instances) (in module tests.system.microsoft.azure.example_azure_cosmosdb) (in module tests.system.microsoft.azure.example_fileshare) (in module tests.system.microsoft.azure.example_local_to_adls) (in module tests.system.microsoft.azure.example_local_to_wasb) (in module tests.system.microsoft.azure.example_sftp_to_wasb) (in module tests.system.microsoft.azure.example_synapse_run_pipeline) ERROR (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIDatasetRefreshFields attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseSparkBatchRunStatus attribute) error_mapping() (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook static method) execute() (airflow.providers.microsoft.azure.operators.adls.ADLSCreateObjectOperator method) (airflow.providers.microsoft.azure.operators.adls.ADLSDeleteOperator method) (airflow.providers.microsoft.azure.operators.adls.ADLSListOperator method) (airflow.providers.microsoft.azure.operators.adx.AzureDataExplorerQueryOperator method) (airflow.providers.microsoft.azure.operators.asb.ASBReceiveSubscriptionMessageOperator method) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusCreateQueueOperator method) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusDeleteQueueOperator method) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusReceiveMessageOperator method) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSendMessageOperator method) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSubscriptionCreateOperator method) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSubscriptionDeleteOperator method) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusTopicCreateOperator method) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusTopicDeleteOperator method) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusUpdateSubscriptionOperator method) (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator method) (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator method) (airflow.providers.microsoft.azure.operators.cosmos.AzureCosmosInsertDocumentOperator method) (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryRunPipelineOperator method) (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator method) (airflow.providers.microsoft.azure.operators.powerbi.PowerBIDatasetRefreshOperator method) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunPipelineOperator method) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunSparkBatchOperator method) (airflow.providers.microsoft.azure.operators.wasb_delete_blob.WasbDeleteBlobOperator method) (airflow.providers.microsoft.azure.sensors.data_factory.AzureDataFactoryPipelineRunStatusSensor method) (airflow.providers.microsoft.azure.sensors.msgraph.MSGraphSensor method) (airflow.providers.microsoft.azure.sensors.wasb.WasbBlobSensor method) (airflow.providers.microsoft.azure.sensors.wasb.WasbPrefixSensor method) (airflow.providers.microsoft.azure.transfers.local_to_adls.LocalFilesystemToADLSOperator method) (airflow.providers.microsoft.azure.transfers.local_to_wasb.LocalFilesystemToWasbOperator method) (airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake.OracleToAzureDataLakeOperator method) (airflow.providers.microsoft.azure.transfers.s3_to_wasb.S3ToAzureBlobStorageOperator method) (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator method)

execute_complete() (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryRunPipelineOperator method) (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator method) (airflow.providers.microsoft.azure.operators.powerbi.PowerBIDatasetRefreshOperator method) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunPipelineOperator method) (airflow.providers.microsoft.azure.sensors.data_factory.AzureDataFactoryPipelineRunStatusSensor method) (airflow.providers.microsoft.azure.sensors.msgraph.MSGraphSensor method) (airflow.providers.microsoft.azure.sensors.wasb.WasbBlobSensor method) (airflow.providers.microsoft.azure.sensors.wasb.WasbPrefixSensor method) EXECUTION_TIMEOUT (in module tests.system.microsoft.azure.example_azure_service_bus) (in module tests.system.microsoft.azure.example_azure_synapse) exists() (airflow.providers.microsoft.azure.hooks.container_instance.AzureContainerInstanceHook method)

F

FAILED (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryPipelineRunStatus attribute) (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIDatasetRefreshStatus attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineRunStatus attribute) FAILURE_STATES (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryPipelineRunStatus attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineRunStatus attribute)

FAILURE_STATUSES (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIDatasetRefreshStatus attribute) FILE_COMPLETE_PATH (in module tests.system.microsoft.azure.example_sftp_to_wasb) format_no_proxy_url() (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook static method)

G

get_adf_pipeline_run_status() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryAsyncHook method) get_api_version() (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook method) get_async_conn() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryAsyncHook method) (airflow.providers.microsoft.azure.hooks.wasb.WasbAsyncHook method) get_async_default_azure_credential (in module airflow.providers.microsoft.azure.utils) get_blobs_list() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) get_blobs_list_async() (airflow.providers.microsoft.azure.hooks.wasb.WasbAsyncHook method) get_blobs_list_recursive() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) get_collection_link() (in module airflow.providers.microsoft.azure.hooks.cosmos) get_config() (airflow.providers.microsoft.azure.secrets.key_vault.AzureKeyVaultBackend method) get_conn() (airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook method) (airflow.providers.microsoft.azure.hooks.asb.AdminClientHook method) (airflow.providers.microsoft.azure.hooks.asb.BaseAzureServiceBusHook method) (airflow.providers.microsoft.azure.hooks.asb.MessageHook method) (airflow.providers.microsoft.azure.hooks.base_azure.AzureBaseHook method) (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook method) (airflow.providers.microsoft.azure.hooks.container_instance.AzureContainerInstanceHook method) (airflow.providers.microsoft.azure.hooks.container_registry.AzureContainerRegistryHook method) (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook method) (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeHook method) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook method) (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook method) (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook method) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook method) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineHook method) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) (airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger method) get_conn_value() (airflow.providers.microsoft.azure.secrets.key_vault.AzureKeyVaultBackend method) get_connection_form_widgets() (airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook class method) (airflow.providers.microsoft.azure.hooks.asb.BaseAzureServiceBusHook class method) (airflow.providers.microsoft.azure.hooks.base_azure.AzureBaseHook class method) (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook class method) (airflow.providers.microsoft.azure.hooks.container_registry.AzureContainerRegistryHook class method) (airflow.providers.microsoft.azure.hooks.container_volume.AzureContainerVolumeHook class method) (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook class method) (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook class method) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeHook class method) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook class method) (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook class method) (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook class method) (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIHook class method) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook class method) (airflow.providers.microsoft.azure.hooks.synapse.BaseAzureSynapseHook class method) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook class method) get_database_link() (in module airflow.providers.microsoft.azure.hooks.cosmos) get_dataflow() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) get_dataset() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) get_directory_client() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook method) get_document() (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook method) get_document_link() (in module airflow.providers.microsoft.azure.hooks.cosmos) get_documents() (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook method)

get_factory() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) get_field() (in module airflow.providers.microsoft.azure.hooks.data_factory) (in module airflow.providers.microsoft.azure.utils) get_fields_from_url() (airflow.providers.microsoft.azure.operators.synapse.AzureSynapsePipelineRunLink method) get_file() (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook method) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) get_file_system() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook method) get_file_to_stream() (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook method) get_file_volume() (airflow.providers.microsoft.azure.hooks.container_volume.AzureContainerVolumeHook method) get_files_to_move() (airflow.providers.microsoft.azure.transfers.s3_to_wasb.S3ToAzureBlobStorageOperator method) get_fs() (in module airflow.providers.microsoft.azure.fs.adls) get_full_path_blob() (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator method) get_host() (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook method) get_job_run_status() (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook method) get_link() (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryPipelineRunLink method) (airflow.providers.microsoft.azure.operators.powerbi.PowerBILink method) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapsePipelineRunLink method) get_linked_service() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) get_logs() (airflow.providers.microsoft.azure.hooks.container_instance.AzureContainerInstanceHook method) get_pipeline() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) get_pipeline_run() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryAsyncHook method) (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineHook method) get_pipeline_run_status() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineHook method) get_refresh_details_by_refresh_id() (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIHook method) get_refresh_history() (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIHook method) get_sftp_files_map() (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator method) get_state() (airflow.providers.microsoft.azure.hooks.container_instance.AzureContainerInstanceHook method) get_storagekey() (airflow.providers.microsoft.azure.hooks.container_volume.AzureContainerVolumeHook method) get_sync_default_azure_credential (in module airflow.providers.microsoft.azure.utils) get_tree_behavior() (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator method) get_trigger() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) get_ui_field_behaviour() (airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook class method) (airflow.providers.microsoft.azure.hooks.asb.BaseAzureServiceBusHook class method) (airflow.providers.microsoft.azure.hooks.base_azure.AzureBaseHook class method) (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook class method) (airflow.providers.microsoft.azure.hooks.container_registry.AzureContainerRegistryHook class method) (airflow.providers.microsoft.azure.hooks.container_volume.AzureContainerVolumeHook class method) (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook class method) (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook class method) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeHook class method) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook class method) (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook class method) (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook class method) (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIHook class method) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook class method) (airflow.providers.microsoft.azure.hooks.synapse.BaseAzureSynapseHook class method) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook class method) get_value() (airflow.providers.microsoft.azure.hooks.msgraph.DefaultResponseHandler static method) get_variable() (airflow.providers.microsoft.azure.secrets.key_vault.AzureKeyVaultBackend method) GROUP_ID (in module tests.system.microsoft.azure.example_powerbi_dataset_refresh)

H

handle_response_async() (airflow.providers.microsoft.azure.hooks.msgraph.DefaultResponseHandler method) hook() (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler method) (airflow.providers.microsoft.azure.operators.adx.AzureDataExplorerQueryOperator method) (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator method) (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryRunPipelineOperator method) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunPipelineOperator method) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunSparkBatchOperator method) (airflow.providers.microsoft.azure.sensors.data_factory.AzureDataFactoryPipelineRunStatusSensor method) hook_name (airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook attribute) (airflow.providers.microsoft.azure.hooks.asb.BaseAzureServiceBusHook attribute) (airflow.providers.microsoft.azure.hooks.base_azure.AzureBaseHook attribute) (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook attribute) (airflow.providers.microsoft.azure.hooks.container_instance.AzureContainerInstanceHook attribute) (airflow.providers.microsoft.azure.hooks.container_registry.AzureContainerRegistryHook attribute) (airflow.providers.microsoft.azure.hooks.container_volume.AzureContainerVolumeHook attribute) (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook attribute) (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook attribute) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeHook attribute) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook attribute) (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook attribute) (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook attribute) (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.BaseAzureSynapseHook attribute) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook attribute)

I

IDLE (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseSparkBatchRunStatus attribute) IN_PROGRESS (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryPipelineRunStatus attribute) (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIDatasetRefreshStatus attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineRunStatus attribute)

insert_documents() (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook method) INTERMEDIATE_STATES (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryPipelineRunStatus attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineRunStatus attribute) InvalidAzureBlobParameters InvalidKeyComponents

K

KILLED (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseSparkBatchRunStatus attribute)

KiotaRequestAdapterHook (class in airflow.providers.microsoft.azure.hooks.msgraph)

L

list() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeHook method) list_directories_and_files() (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook method) list_file_system() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook method) list_files() (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook method) list_files_directory() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook method) load_data() (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook method) load_file() (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook method) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method)

load_string() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) LOCAL_FILE_PATH (in module tests.system.microsoft.azure.example_adls_delete) (in module tests.system.microsoft.azure.example_adls_list) (in module tests.system.microsoft.azure.example_local_to_adls) (in module tests.system.microsoft.azure.example_sftp_to_wasb) LocalFilesystemToADLSOperator (class in airflow.providers.microsoft.azure.transfers.local_to_adls) LocalFilesystemToWasbOperator (class in airflow.providers.microsoft.azure.transfers.local_to_wasb)

M

MESSAGE (in module tests.system.microsoft.azure.example_azure_service_bus) MESSAGE_LIST (in module tests.system.microsoft.azure.example_azure_service_bus) MessageCallback (in module airflow.providers.microsoft.azure.hooks.asb) (in module airflow.providers.microsoft.azure.operators.asb) MessageHook (class in airflow.providers.microsoft.azure.hooks.asb) module airflow.providers.microsoft.azure airflow.providers.microsoft.azure.fs airflow.providers.microsoft.azure.fs.adls airflow.providers.microsoft.azure.hooks airflow.providers.microsoft.azure.hooks.adx airflow.providers.microsoft.azure.hooks.asb airflow.providers.microsoft.azure.hooks.base_azure airflow.providers.microsoft.azure.hooks.batch airflow.providers.microsoft.azure.hooks.container_instance airflow.providers.microsoft.azure.hooks.container_registry airflow.providers.microsoft.azure.hooks.container_volume airflow.providers.microsoft.azure.hooks.cosmos airflow.providers.microsoft.azure.hooks.data_factory airflow.providers.microsoft.azure.hooks.data_lake airflow.providers.microsoft.azure.hooks.fileshare airflow.providers.microsoft.azure.hooks.msgraph airflow.providers.microsoft.azure.hooks.powerbi airflow.providers.microsoft.azure.hooks.synapse airflow.providers.microsoft.azure.hooks.wasb airflow.providers.microsoft.azure.log airflow.providers.microsoft.azure.log.wasb_task_handler airflow.providers.microsoft.azure.operators airflow.providers.microsoft.azure.operators.adls airflow.providers.microsoft.azure.operators.adx airflow.providers.microsoft.azure.operators.asb airflow.providers.microsoft.azure.operators.batch airflow.providers.microsoft.azure.operators.container_instances airflow.providers.microsoft.azure.operators.cosmos airflow.providers.microsoft.azure.operators.data_factory airflow.providers.microsoft.azure.operators.msgraph airflow.providers.microsoft.azure.operators.powerbi airflow.providers.microsoft.azure.operators.synapse airflow.providers.microsoft.azure.operators.wasb_delete_blob airflow.providers.microsoft.azure.secrets airflow.providers.microsoft.azure.secrets.key_vault airflow.providers.microsoft.azure.sensors airflow.providers.microsoft.azure.sensors.cosmos airflow.providers.microsoft.azure.sensors.data_factory airflow.providers.microsoft.azure.sensors.msgraph airflow.providers.microsoft.azure.sensors.wasb airflow.providers.microsoft.azure.transfers airflow.providers.microsoft.azure.transfers.local_to_adls airflow.providers.microsoft.azure.transfers.local_to_wasb airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake airflow.providers.microsoft.azure.transfers.s3_to_wasb airflow.providers.microsoft.azure.transfers.sftp_to_wasb airflow.providers.microsoft.azure.triggers airflow.providers.microsoft.azure.triggers.data_factory airflow.providers.microsoft.azure.triggers.msgraph airflow.providers.microsoft.azure.triggers.powerbi airflow.providers.microsoft.azure.triggers.wasb airflow.providers.microsoft.azure.utils tests.system.microsoft.azure tests.system.microsoft.azure.example_adf_run_pipeline tests.system.microsoft.azure.example_adls_create tests.system.microsoft.azure.example_adls_delete tests.system.microsoft.azure.example_adls_list tests.system.microsoft.azure.example_azure_batch_operator tests.system.microsoft.azure.example_azure_container_instances tests.system.microsoft.azure.example_azure_cosmosdb tests.system.microsoft.azure.example_azure_service_bus tests.system.microsoft.azure.example_azure_synapse tests.system.microsoft.azure.example_fileshare tests.system.microsoft.azure.example_local_to_adls tests.system.microsoft.azure.example_local_to_wasb tests.system.microsoft.azure.example_msfabric tests.system.microsoft.azure.example_msgraph tests.system.microsoft.azure.example_powerbi tests.system.microsoft.azure.example_powerbi_dataset_refresh tests.system.microsoft.azure.example_s3_to_wasb tests.system.microsoft.azure.example_sftp_to_wasb tests.system.microsoft.azure.example_synapse_run_pipeline tests.system.microsoft.azure.example_wasb_sensors

move_file() (airflow.providers.microsoft.azure.transfers.s3_to_wasb.S3ToAzureBlobStorageOperator method) MSGraphAsyncOperator (class in airflow.providers.microsoft.azure.operators.msgraph) MSGraphSensor (class in airflow.providers.microsoft.azure.sensors.msgraph) MSGraphTrigger (class in airflow.providers.microsoft.azure.triggers.msgraph)

N

name (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryPipelineRunLink attribute) (airflow.providers.microsoft.azure.operators.powerbi.PowerBILink attribute) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapsePipelineRunLink attribute)

NAME (in module tests.system.microsoft.azure.example_fileshare) normalize_url() (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook static method) NOT_STARTED (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseSparkBatchRunStatus attribute)

O

on_kill() (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator method) (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator method) (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryRunPipelineOperator method) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunPipelineOperator method) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunSparkBatchOperator method)

operator_extra_links (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryRunPipelineOperator attribute) (airflow.providers.microsoft.azure.operators.powerbi.PowerBIDatasetRefreshOperator attribute) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunPipelineOperator attribute) OracleToAzureDataLakeOperator (class in airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake)

P

paginate() (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator static method) parse_blob_account_url() (in module airflow.providers.microsoft.azure.utils) PartitionKeyType (in module airflow.providers.microsoft.azure.hooks.cosmos) PATH_TO_UPLOAD_FILE (in module tests.system.microsoft.azure.example_local_to_wasb) poke() (airflow.providers.microsoft.azure.sensors.cosmos.AzureCosmosDocumentSensor method) (airflow.providers.microsoft.azure.sensors.data_factory.AzureDataFactoryPipelineRunStatusSensor method) (airflow.providers.microsoft.azure.sensors.wasb.WasbBlobSensor method) (airflow.providers.microsoft.azure.sensors.wasb.WasbPrefixSensor method) POOL_ID (in module tests.system.microsoft.azure.example_azure_batch_operator) PowerBIDatasetRefreshException PowerBIDatasetRefreshFields (class in airflow.providers.microsoft.azure.hooks.powerbi) PowerBIDatasetRefreshOperator (class in airflow.providers.microsoft.azure.operators.powerbi)

PowerBIDatasetRefreshStatus (class in airflow.providers.microsoft.azure.hooks.powerbi) PowerBIHook (class in airflow.providers.microsoft.azure.hooks.powerbi) PowerBILink (class in airflow.providers.microsoft.azure.operators.powerbi) PowerBITrigger (class in airflow.providers.microsoft.azure.triggers.powerbi) PREFIX (in module tests.system.microsoft.azure.example_wasb_sensors) provide_targeted_factory() (in module airflow.providers.microsoft.azure.hooks.data_factory) provide_targeted_factory_async() (in module airflow.providers.microsoft.azure.hooks.data_factory) proxies (airflow.providers.microsoft.azure.operators.powerbi.PowerBIDatasetRefreshOperator property) (airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger property) (airflow.providers.microsoft.azure.triggers.powerbi.PowerBITrigger property) pull_xcom() (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator method) push_xcom() (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator method)

Q

QUEUE_NAME (in module tests.system.microsoft.azure.example_azure_service_bus)

QUEUED (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryPipelineRunStatus attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineRunStatus attribute)

R

raw_to_refresh_details() (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIHook class method) read_file() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) receive_message() (airflow.providers.microsoft.azure.hooks.asb.MessageHook method) receive_subscription_message() (airflow.providers.microsoft.azure.hooks.asb.MessageHook method) refresh_conn() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryAsyncHook method) (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineHook method) REMOTE_FILE_PATH (in module tests.system.microsoft.azure.example_adls_create) (in module tests.system.microsoft.azure.example_adls_delete) (in module tests.system.microsoft.azure.example_adls_list) (in module tests.system.microsoft.azure.example_local_to_adls) remove() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeHook method) REQUEST_ID (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIDatasetRefreshFields attribute) request_information() (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook method) rerun_trigger() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) resolve_api_version_from_value() (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook static method)

resolve_type() (airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger class method) ResponseSerializer (class in airflow.providers.microsoft.azure.triggers.msgraph) retry_execute() (airflow.providers.microsoft.azure.sensors.msgraph.MSGraphSensor method) run() (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook method) (airflow.providers.microsoft.azure.triggers.data_factory.ADFPipelineRunStatusSensorTrigger method) (airflow.providers.microsoft.azure.triggers.data_factory.AzureDataFactoryTrigger method) (airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger method) (airflow.providers.microsoft.azure.triggers.powerbi.PowerBITrigger method) (airflow.providers.microsoft.azure.triggers.wasb.WasbBlobSensorTrigger method) (airflow.providers.microsoft.azure.triggers.wasb.WasbPrefixSensorTrigger method) run_pipeline() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineHook method) run_query() (airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook method) run_spark_job (in module tests.system.microsoft.azure.example_azure_synapse) run_spark_job() (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook method) RUNNING (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseSparkBatchRunStatus attribute)

S

s3_hook() (airflow.providers.microsoft.azure.transfers.s3_to_wasb.S3ToAzureBlobStorageOperator method) S3_KEY (in module tests.system.microsoft.azure.example_s3_to_wasb) S3_PREFIX (in module tests.system.microsoft.azure.example_s3_to_wasb) S3ToAzureBlobStorageOperator (class in airflow.providers.microsoft.azure.transfers.s3_to_wasb) SAMPLE_FILENAME (in module tests.system.microsoft.azure.example_sftp_to_wasb) schemes (in module airflow.providers.microsoft.azure.fs.adls) send_batch_message() (airflow.providers.microsoft.azure.hooks.asb.MessageHook static method) send_list_messages() (airflow.providers.microsoft.azure.hooks.asb.MessageHook static method) send_message() (airflow.providers.microsoft.azure.hooks.asb.MessageHook method) serialize() (airflow.providers.microsoft.azure.triggers.data_factory.ADFPipelineRunStatusSensorTrigger method) (airflow.providers.microsoft.azure.triggers.data_factory.AzureDataFactoryTrigger method) (airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger method) (airflow.providers.microsoft.azure.triggers.msgraph.ResponseSerializer method) (airflow.providers.microsoft.azure.triggers.powerbi.PowerBITrigger method) (airflow.providers.microsoft.azure.triggers.wasb.WasbBlobSensorTrigger method) (airflow.providers.microsoft.azure.triggers.wasb.WasbPrefixSensorTrigger method) service_client() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook method) set_context() (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler method) set_token() (airflow.providers.microsoft.azure.utils.AzureIdentityCredentialAdapter method) set_up_connection (in module tests.system.microsoft.azure.example_powerbi_dataset_refresh) SFTP_FILE_COMPLETE_PATH (in module tests.system.microsoft.azure.example_sftp_to_wasb)

sftp_hook() (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator method) SFTP_SRC_PATH (in module tests.system.microsoft.azure.example_sftp_to_wasb) SftpFile (in module airflow.providers.microsoft.azure.transfers.sftp_to_wasb) SFTPToWasbOperator (class in airflow.providers.microsoft.azure.transfers.sftp_to_wasb) share_directory_client (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook property) share_file_client (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook property) share_service_client (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook property) SHUTTING_DOWN (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseSparkBatchRunStatus attribute) signed_session() (airflow.providers.microsoft.azure.utils.AzureIdentityCredentialAdapter method) site_task (in module tests.system.microsoft.azure.example_msgraph) source_path_contains_wildcard (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator property) SPARK_JOB_PAYLOAD (in module tests.system.microsoft.azure.example_azure_synapse) start_trigger() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) STARTING (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseSparkBatchRunStatus attribute) STATUS (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIDatasetRefreshFields attribute) stop_trigger() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) SUBSCRIPTION_NAME (in module tests.system.microsoft.azure.example_azure_service_bus) SUCCEEDED (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryPipelineRunStatus attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineRunStatus attribute) SUCCESS (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseSparkBatchRunStatus attribute) sys_test_context_task (in module tests.system.microsoft.azure.example_s3_to_wasb)

T

T (in module airflow.providers.microsoft.azure.hooks.data_factory) t1 (in module tests.system.microsoft.azure.example_azure_container_instances) (in module tests.system.microsoft.azure.example_azure_cosmosdb) template_ext (airflow.providers.microsoft.azure.operators.adx.AzureDataExplorerQueryOperator attribute) template_fields (airflow.providers.microsoft.azure.operators.adls.ADLSCreateObjectOperator attribute) (airflow.providers.microsoft.azure.operators.adls.ADLSDeleteOperator attribute) (airflow.providers.microsoft.azure.operators.adls.ADLSListOperator attribute) (airflow.providers.microsoft.azure.operators.adx.AzureDataExplorerQueryOperator attribute) (airflow.providers.microsoft.azure.operators.asb.ASBReceiveSubscriptionMessageOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusCreateQueueOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusDeleteQueueOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusReceiveMessageOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSendMessageOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSubscriptionCreateOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSubscriptionDeleteOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusTopicCreateOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusTopicDeleteOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusUpdateSubscriptionOperator attribute) (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator attribute) (airflow.providers.microsoft.azure.operators.cosmos.AzureCosmosInsertDocumentOperator attribute) (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryRunPipelineOperator attribute) (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator attribute) (airflow.providers.microsoft.azure.operators.powerbi.PowerBIDatasetRefreshOperator attribute) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunPipelineOperator attribute) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunSparkBatchOperator attribute) (airflow.providers.microsoft.azure.operators.wasb_delete_blob.WasbDeleteBlobOperator attribute) (airflow.providers.microsoft.azure.sensors.cosmos.AzureCosmosDocumentSensor attribute) (airflow.providers.microsoft.azure.sensors.data_factory.AzureDataFactoryPipelineRunStatusSensor attribute) (airflow.providers.microsoft.azure.sensors.msgraph.MSGraphSensor attribute) (airflow.providers.microsoft.azure.sensors.wasb.WasbBlobSensor attribute) (airflow.providers.microsoft.azure.sensors.wasb.WasbPrefixSensor attribute) (airflow.providers.microsoft.azure.transfers.local_to_adls.LocalFilesystemToADLSOperator attribute) (airflow.providers.microsoft.azure.transfers.local_to_wasb.LocalFilesystemToWasbOperator attribute) (airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake.OracleToAzureDataLakeOperator attribute) (airflow.providers.microsoft.azure.transfers.s3_to_wasb.S3ToAzureBlobStorageOperator attribute) (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator attribute) (airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger attribute) template_fields_renderers (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator attribute) (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryRunPipelineOperator attribute) (airflow.providers.microsoft.azure.operators.powerbi.PowerBIDatasetRefreshOperator attribute) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunSparkBatchOperator attribute) (airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake.OracleToAzureDataLakeOperator attribute) TENANT_ID (in module tests.system.microsoft.azure.example_powerbi_dataset_refresh) TERMINAL_STATUSES (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryPipelineRunStatus attribute) (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIDatasetRefreshStatus attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineRunStatus attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseSparkBatchRunStatus attribute) test_connection() (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook method) (airflow.providers.microsoft.azure.hooks.container_instance.AzureContainerInstanceHook method) (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook method) (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook method) (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook method) (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook method) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) test_context (in module tests.system.microsoft.azure.example_s3_to_wasb) test_run (in module tests.system.microsoft.azure.example_adf_run_pipeline) (in module tests.system.microsoft.azure.example_adls_create) (in module tests.system.microsoft.azure.example_adls_delete) (in module tests.system.microsoft.azure.example_adls_list) (in module tests.system.microsoft.azure.example_azure_batch_operator) (in module tests.system.microsoft.azure.example_azure_container_instances) (in module tests.system.microsoft.azure.example_azure_cosmosdb) (in module tests.system.microsoft.azure.example_azure_service_bus) (in module tests.system.microsoft.azure.example_azure_synapse) (in module tests.system.microsoft.azure.example_fileshare) (in module tests.system.microsoft.azure.example_local_to_adls) (in module tests.system.microsoft.azure.example_local_to_wasb) (in module tests.system.microsoft.azure.example_msfabric) (in module tests.system.microsoft.azure.example_msgraph) (in module tests.system.microsoft.azure.example_powerbi) (in module tests.system.microsoft.azure.example_powerbi_dataset_refresh) (in module tests.system.microsoft.azure.example_s3_to_wasb) (in module tests.system.microsoft.azure.example_sftp_to_wasb) (in module tests.system.microsoft.azure.example_synapse_run_pipeline) (in module tests.system.microsoft.azure.example_wasb_sensors)

tests.system.microsoft.azure module tests.system.microsoft.azure.example_adf_run_pipeline module tests.system.microsoft.azure.example_adls_create module tests.system.microsoft.azure.example_adls_delete module tests.system.microsoft.azure.example_adls_list module tests.system.microsoft.azure.example_azure_batch_operator module tests.system.microsoft.azure.example_azure_container_instances module tests.system.microsoft.azure.example_azure_cosmosdb module tests.system.microsoft.azure.example_azure_service_bus module tests.system.microsoft.azure.example_azure_synapse module tests.system.microsoft.azure.example_fileshare module tests.system.microsoft.azure.example_local_to_adls module tests.system.microsoft.azure.example_local_to_wasb module tests.system.microsoft.azure.example_msfabric module tests.system.microsoft.azure.example_msgraph module tests.system.microsoft.azure.example_powerbi module tests.system.microsoft.azure.example_powerbi_dataset_refresh module tests.system.microsoft.azure.example_s3_to_wasb module tests.system.microsoft.azure.example_sftp_to_wasb module tests.system.microsoft.azure.example_synapse_run_pipeline module tests.system.microsoft.azure.example_wasb_sensors module timeout (airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger property) to_httpx_proxies() (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook class method) to_msal_proxies() (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook method) TooManyFilesToMoveException TOPIC_NAME (in module tests.system.microsoft.azure.example_azure_service_bus) transfer_files_to_sftp_step (in module tests.system.microsoft.azure.example_sftp_to_wasb) trigger_dataset_refresh() (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIHook method) trigger_next_link() (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator method) trigger_should_wrap (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler attribute)

U

ui_color (airflow.providers.microsoft.azure.operators.adls.ADLSCreateObjectOperator attribute) (airflow.providers.microsoft.azure.operators.adls.ADLSDeleteOperator attribute) (airflow.providers.microsoft.azure.operators.adls.ADLSListOperator attribute) (airflow.providers.microsoft.azure.operators.adx.AzureDataExplorerQueryOperator attribute) (airflow.providers.microsoft.azure.operators.asb.ASBReceiveSubscriptionMessageOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusCreateQueueOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusDeleteQueueOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusReceiveMessageOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSendMessageOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSubscriptionCreateOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSubscriptionDeleteOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusTopicCreateOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusTopicDeleteOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusUpdateSubscriptionOperator attribute) (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) (airflow.providers.microsoft.azure.operators.cosmos.AzureCosmosInsertDocumentOperator attribute) (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryRunPipelineOperator attribute) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunSparkBatchOperator attribute) (airflow.providers.microsoft.azure.sensors.data_factory.AzureDataFactoryPipelineRunStatusSensor attribute) (airflow.providers.microsoft.azure.transfers.local_to_adls.LocalFilesystemToADLSOperator attribute) (airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake.OracleToAzureDataLakeOperator attribute)

update_dataflow() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) update_dataset() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) update_factory() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) update_linked_service() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) update_pipeline() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) update_trigger() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) upload (in module tests.system.microsoft.azure.example_local_to_wasb) upload() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) upload_data (in module tests.system.microsoft.azure.example_adls_create) upload_file (in module tests.system.microsoft.azure.example_adls_delete) (in module tests.system.microsoft.azure.example_local_to_adls) upload_file() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeHook method) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook method) upload_file_to_directory() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook method) upsert_document() (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook method)

V

Volume (in module airflow.providers.microsoft.azure.operators.container_instances)

W

wait_for_all_node_state() (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook method) wait_for_job_run_status() (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook method) wait_for_job_tasks_to_complete() (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook method) wait_for_pipeline_run_status() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineHook method) wasb_hook() (airflow.providers.microsoft.azure.transfers.s3_to_wasb.S3ToAzureBlobStorageOperator method) wasb_log_exists() (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler method) wasb_read() (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler method) wasb_write() (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler method) WasbAsyncHook (class in airflow.providers.microsoft.azure.hooks.wasb)

WasbBlobSensor (class in airflow.providers.microsoft.azure.sensors.wasb) WasbBlobSensorTrigger (class in airflow.providers.microsoft.azure.triggers.wasb) WasbDeleteBlobOperator (class in airflow.providers.microsoft.azure.operators.wasb_delete_blob) WasbHook (class in airflow.providers.microsoft.azure.hooks.wasb) WasbPrefixSensor (class in airflow.providers.microsoft.azure.sensors.wasb) WasbPrefixSensorTrigger (class in airflow.providers.microsoft.azure.triggers.wasb) WasbTaskHandler (class in airflow.providers.microsoft.azure.log.wasb_task_handler) WILDCARD (in module airflow.providers.microsoft.azure.transfers.sftp_to_wasb) workspaces_task (in module tests.system.microsoft.azure.example_msfabric) (in module tests.system.microsoft.azure.example_powerbi)

PreviousNext

Was this entry helpful?