• 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) 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.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.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.wasb module

airflow.providers.microsoft.azure.transfers module airflow.providers.microsoft.azure.transfers.azure_blob_to_gcs 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.sftp_to_wasb module airflow.providers.microsoft.azure.triggers module airflow.providers.microsoft.azure.triggers.data_factory module airflow.providers.microsoft.azure.triggers.wasb module airflow.providers.microsoft.azure.utils module AIRFLOW_HOME (in module tests.system.providers.microsoft.azure.example_azure_synapse) 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.providers.microsoft.azure.example_azure_batch_operator) AZURE_BLOB_NAME (in module tests.system.providers.microsoft.azure.example_local_to_wasb) AZURE_CONTAINER_NAME (in module tests.system.providers.microsoft.azure.example_local_to_wasb) (in module tests.system.providers.microsoft.azure.example_sftp_to_wasb) AZURE_STORAGE_ACOOUNT (in module tests.system.providers.microsoft.azure.example_azure_container_instances) AZURE_VOLUME_SHARE_NAME (in module tests.system.providers.microsoft.azure.example_azure_container_instances) azure_wasb_sensor (in module tests.system.providers.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) AzureBlobStorageToGCSOperator (class in airflow.providers.microsoft.azure.transfers.azure_blob_to_gcs) 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) begin (in module tests.system.providers.microsoft.azure.example_adf_run_pipeline) (in module tests.system.providers.microsoft.azure.example_synapse_run_pipeline) BLOB_NAME (in module tests.system.providers.microsoft.azure.example_wasb_sensors)

BLOB_PREFIX (in module tests.system.providers.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

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.providers.microsoft.azure.example_azure_service_bus) close() (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler method) 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_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.synapse.AzureSynapseHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineHook 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.synapse.AzureSynapseHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineHook 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.providers.microsoft.azure.example_wasb_sensors) CONTAINER_REGISTRY_SERVER (in module tests.system.providers.microsoft.azure.example_azure_container_instances) 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_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.providers.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.providers.microsoft.azure.example_azure_service_bus) create_share() (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook 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.providers.microsoft.azure.example_adf_run_pipeline) (in module tests.system.providers.microsoft.azure.example_adls_delete) (in module tests.system.providers.microsoft.azure.example_azure_container_instances) (in module tests.system.providers.microsoft.azure.example_azure_cosmosdb) (in module tests.system.providers.microsoft.azure.example_fileshare) (in module tests.system.providers.microsoft.azure.example_local_to_adls) (in module tests.system.providers.microsoft.azure.example_local_to_wasb) (in module tests.system.providers.microsoft.azure.example_sftp_to_wasb) DEAD (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseSparkBatchRunStatus attribute) default_args (in module tests.system.providers.microsoft.azure.example_azure_synapse) 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.synapse.AzureSynapseHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineHook 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_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) 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.providers.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.providers.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) DIRECTORY (in module tests.system.providers.microsoft.azure.example_fileshare) 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

ENV_ID (in module tests.system.providers.microsoft.azure.example_adf_run_pipeline) (in module tests.system.providers.microsoft.azure.example_adls_delete) (in module tests.system.providers.microsoft.azure.example_azure_container_instances) (in module tests.system.providers.microsoft.azure.example_azure_cosmosdb) (in module tests.system.providers.microsoft.azure.example_fileshare) (in module tests.system.providers.microsoft.azure.example_local_to_adls) (in module tests.system.providers.microsoft.azure.example_local_to_wasb) (in module tests.system.providers.microsoft.azure.example_sftp_to_wasb) (in module tests.system.providers.microsoft.azure.example_synapse_run_pipeline) ERROR (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseSparkBatchRunStatus attribute) execute() (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.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.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.sftp_to_wasb.SFTPToWasbOperator method)

execute_complete() (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryRunPipelineOperator method) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunPipelineOperator 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) EXECUTION_TIMEOUT (in module tests.system.providers.microsoft.azure.example_azure_service_bus) (in module tests.system.providers.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.synapse.AzureSynapsePipelineRunStatus attribute)

FAILURE_STATES (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryPipelineRunStatus attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineRunStatus attribute) FILE_COMPLETE_PATH (in module tests.system.providers.microsoft.azure.example_sftp_to_wasb)

G

get_adf_pipeline_run_status() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryAsyncHook 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.synapse.AzureSynapseHook method) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineHook method) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) get_conn_uri() (airflow.providers.microsoft.azure.secrets.key_vault.AzureKeyVaultBackend 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 static method) (airflow.providers.microsoft.azure.hooks.base_azure.AzureBaseHook static method) (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook class method) (airflow.providers.microsoft.azure.hooks.container_registry.AzureContainerRegistryHook static method) (airflow.providers.microsoft.azure.hooks.container_volume.AzureContainerVolumeHook static method) (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook static method) (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook static method) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeHook static method) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook class method) (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook static method) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook static method) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineHook static method) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook static 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_default_delete_local_copy() (in module airflow.providers.microsoft.azure.log.wasb_task_handler) 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_fs() (in module airflow.providers.microsoft.azure.fs.adls) get_full_path_blob() (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator method) get_hook() (airflow.providers.microsoft.azure.operators.adx.AzureDataExplorerQueryOperator method) (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator 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.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_messages() (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_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_state_exitcode_details() (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 static method) (airflow.providers.microsoft.azure.hooks.base_azure.AzureBaseHook static 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 static method) (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook static method) (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook static method) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeHook static method) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook class method) (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook static method) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook static method) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineHook static method) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook static method) get_variable() (airflow.providers.microsoft.azure.secrets.key_vault.AzureKeyVaultBackend method)

H

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.synapse.AzureSynapseHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineHook 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.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)

K

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

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.providers.microsoft.azure.example_adls_delete) (in module tests.system.providers.microsoft.azure.example_local_to_adls) (in module tests.system.providers.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.providers.microsoft.azure.example_azure_service_bus) MESSAGE_LIST (in module tests.system.providers.microsoft.azure.example_azure_service_bus) 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.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.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.wasb airflow.providers.microsoft.azure.transfers airflow.providers.microsoft.azure.transfers.azure_blob_to_gcs 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.sftp_to_wasb airflow.providers.microsoft.azure.triggers airflow.providers.microsoft.azure.triggers.data_factory airflow.providers.microsoft.azure.triggers.wasb airflow.providers.microsoft.azure.utils tests.system.providers.microsoft.azure tests.system.providers.microsoft.azure.example_adf_run_pipeline tests.system.providers.microsoft.azure.example_adls_delete tests.system.providers.microsoft.azure.example_azure_batch_operator tests.system.providers.microsoft.azure.example_azure_container_instances tests.system.providers.microsoft.azure.example_azure_cosmosdb tests.system.providers.microsoft.azure.example_azure_service_bus tests.system.providers.microsoft.azure.example_azure_synapse tests.system.providers.microsoft.azure.example_fileshare tests.system.providers.microsoft.azure.example_local_to_adls tests.system.providers.microsoft.azure.example_local_to_wasb tests.system.providers.microsoft.azure.example_sftp_to_wasb tests.system.providers.microsoft.azure.example_synapse_run_pipeline tests.system.providers.microsoft.azure.example_wasb_sensors

N

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

NAME (in module tests.system.providers.microsoft.azure.example_fileshare) 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.synapse.AzureSynapseRunPipelineOperator attribute) OracleToAzureDataLakeOperator (class in airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake)

P

PATH_TO_UPLOAD_FILE (in module tests.system.providers.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.providers.microsoft.azure.example_azure_batch_operator) PREFIX (in module tests.system.providers.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)

Q

QUEUE_NAME (in module tests.system.providers.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

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.providers.microsoft.azure.example_adls_delete) (in module tests.system.providers.microsoft.azure.example_local_to_adls) remove() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeHook method) rerun_trigger() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method)

run() (airflow.providers.microsoft.azure.triggers.data_factory.ADFPipelineRunStatusSensorTrigger method) (airflow.providers.microsoft.azure.triggers.data_factory.AzureDataFactoryTrigger 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.providers.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

SAMPLE_FILENAME (in module tests.system.providers.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.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) SFTP_FILE_COMPLETE_PATH (in module tests.system.providers.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.providers.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) source_path_contains_wildcard (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator property) SPARK_JOB_PAYLOAD (in module tests.system.providers.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) stop_trigger() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) SUBSCRIPTION_NAME (in module tests.system.providers.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)

T

T (in module airflow.providers.microsoft.azure.hooks.data_factory) t1 (in module tests.system.providers.microsoft.azure.example_azure_container_instances) (in module tests.system.providers.microsoft.azure.example_azure_cosmosdb) template_ext (airflow.providers.microsoft.azure.operators.adx.AzureDataExplorerQueryOperator attribute) template_fields (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.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.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.sftp_to_wasb.SFTPToWasbOperator 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.synapse.AzureSynapseRunSparkBatchOperator attribute) (airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake.OracleToAzureDataLakeOperator attribute) TERMINAL_STATUSES (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryPipelineRunStatus 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.wasb.WasbHook method)

test_run (in module tests.system.providers.microsoft.azure.example_adf_run_pipeline) (in module tests.system.providers.microsoft.azure.example_adls_delete) (in module tests.system.providers.microsoft.azure.example_azure_batch_operator) (in module tests.system.providers.microsoft.azure.example_azure_container_instances) (in module tests.system.providers.microsoft.azure.example_azure_cosmosdb) (in module tests.system.providers.microsoft.azure.example_azure_service_bus) (in module tests.system.providers.microsoft.azure.example_azure_synapse) (in module tests.system.providers.microsoft.azure.example_fileshare) (in module tests.system.providers.microsoft.azure.example_local_to_adls) (in module tests.system.providers.microsoft.azure.example_local_to_wasb) (in module tests.system.providers.microsoft.azure.example_sftp_to_wasb) (in module tests.system.providers.microsoft.azure.example_synapse_run_pipeline) (in module tests.system.providers.microsoft.azure.example_wasb_sensors) tests.system.providers.microsoft.azure module tests.system.providers.microsoft.azure.example_adf_run_pipeline module tests.system.providers.microsoft.azure.example_adls_delete module tests.system.providers.microsoft.azure.example_azure_batch_operator module tests.system.providers.microsoft.azure.example_azure_container_instances module tests.system.providers.microsoft.azure.example_azure_cosmosdb module tests.system.providers.microsoft.azure.example_azure_service_bus module tests.system.providers.microsoft.azure.example_azure_synapse module tests.system.providers.microsoft.azure.example_fileshare module tests.system.providers.microsoft.azure.example_local_to_adls module tests.system.providers.microsoft.azure.example_local_to_wasb module tests.system.providers.microsoft.azure.example_sftp_to_wasb module tests.system.providers.microsoft.azure.example_synapse_run_pipeline module tests.system.providers.microsoft.azure.example_wasb_sensors module TOPIC_NAME (in module tests.system.providers.microsoft.azure.example_azure_service_bus) transfer_files_to_sftp_step (in module tests.system.providers.microsoft.azure.example_sftp_to_wasb) trigger_should_wrap (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler attribute)

U

ui_color (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.providers.microsoft.azure.example_local_to_wasb) upload() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) upload_file (in module tests.system.providers.microsoft.azure.example_adls_delete) (in module tests.system.providers.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_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)

WasbBlobAsyncSensor (class in airflow.providers.microsoft.azure.sensors.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)

PreviousNext

Was this entry helpful?