• Home
• Index

Index

A

add_single_task_to_job() (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook method) 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.hooks module airflow.providers.microsoft.azure.hooks.adx module airflow.providers.microsoft.azure.hooks.asb module airflow.providers.microsoft.azure.hooks.azure_batch module airflow.providers.microsoft.azure.hooks.azure_container_instance module airflow.providers.microsoft.azure.hooks.azure_container_registry module airflow.providers.microsoft.azure.hooks.azure_container_volume module airflow.providers.microsoft.azure.hooks.azure_cosmos module airflow.providers.microsoft.azure.hooks.azure_data_factory module airflow.providers.microsoft.azure.hooks.azure_data_lake module airflow.providers.microsoft.azure.hooks.azure_fileshare 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.adls_delete module airflow.providers.microsoft.azure.operators.adls_list module airflow.providers.microsoft.azure.operators.adx module airflow.providers.microsoft.azure.operators.asb module airflow.providers.microsoft.azure.operators.azure_batch module airflow.providers.microsoft.azure.operators.azure_container_instances module airflow.providers.microsoft.azure.operators.azure_cosmos 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.azure_key_vault module airflow.providers.microsoft.azure.secrets.key_vault module airflow.providers.microsoft.azure.sensors module airflow.providers.microsoft.azure.sensors.azure_cosmos 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.file_to_wasb 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_HOME (in module tests.system.providers.microsoft.azure.example_azure_synapse) ASBReceiveSubscriptionMessageOperator (class in airflow.providers.microsoft.azure.operators.asb) AZURE_CONTAINER_NAME (in module tests.system.providers.microsoft.azure.example_azure_blob_to_gcs) (in module tests.system.providers.microsoft.azure.example_sftp_to_wasb) 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) 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) AzureDataLakeHook (class in airflow.providers.microsoft.azure.hooks.data_lake) AzureDataLakeStorageDeleteOperator (class in airflow.providers.microsoft.azure.operators.adls_delete) AzureDataLakeStorageListOperator (class in airflow.providers.microsoft.azure.operators.adls_list) AzureFileShareHook (class in airflow.providers.microsoft.azure.hooks.fileshare) 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) 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) BLOB_NAME (in module tests.system.providers.microsoft.azure.example_azure_blob_to_gcs)

BLOB_PREFIX (in module tests.system.providers.microsoft.azure.example_sftp_to_wasb) 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.AzureDataFactoryHook method) cancel_trigger() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) CANCELING (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryPipelineRunStatus attribute) CANCELLED (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryPipelineRunStatus attribute) check_for_blob() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) check_for_directory() (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook method) check_for_file() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeHook method) (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook method) check_for_prefix() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook 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.fileshare.AzureFileShareHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook 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.fileshare.AzureFileShareHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook attribute) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook attribute)

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.fileshare.AzureFileShareHook method) create_factory() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook 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.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_blob_to_gcs) (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.AzureDataFactoryHook attribute) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeHook attribute) (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook 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_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_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_blob_to_gcs) (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) environment variable PYTHONPATH 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.AzureSynapseRunSparkBatchOperator method) (airflow.providers.microsoft.azure.operators.wasb_delete_blob.WasbDeleteBlobOperator method) (airflow.providers.microsoft.azure.transfers.azure_blob_to_gcs.AzureBlobStorageToGCSOperator 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)

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

factory_name (airflow.providers.microsoft.azure.hooks.data_factory.PipelineRunInfo attribute)

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

G

GCP_BUCKET_FILE_PATH (in module tests.system.providers.microsoft.azure.example_azure_blob_to_gcs) GCP_BUCKET_NAME (in module tests.system.providers.microsoft.azure.example_azure_blob_to_gcs) GCP_OBJECT_NAME (in module tests.system.providers.microsoft.azure.example_azure_blob_to_gcs) get_blobs_list() (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_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.fileshare.AzureFileShareHook method) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook 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 static method) (airflow.providers.microsoft.azure.hooks.base_azure.AzureBaseHook static method) (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook 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.fileshare.AzureFileShareHook static method) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook 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_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_file() (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook method) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook 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_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) 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.AzureDataFactoryHook method) get_pipeline_run_status() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook 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_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 static 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 static 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.fileshare.AzureFileShareHook static method) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook 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) 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.fileshare.AzureFileShareHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook 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) insert_documents() (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook method)

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_files() (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_stream() (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook method) load_string() (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook method) (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) LocalToAzureDataLakeStorageOperator (class in airflow.providers.microsoft.azure.transfers.local_to_adls)

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.hooks airflow.providers.microsoft.azure.hooks.adx airflow.providers.microsoft.azure.hooks.asb airflow.providers.microsoft.azure.hooks.azure_batch airflow.providers.microsoft.azure.hooks.azure_container_instance airflow.providers.microsoft.azure.hooks.azure_container_registry airflow.providers.microsoft.azure.hooks.azure_container_volume airflow.providers.microsoft.azure.hooks.azure_cosmos airflow.providers.microsoft.azure.hooks.azure_data_factory airflow.providers.microsoft.azure.hooks.azure_data_lake airflow.providers.microsoft.azure.hooks.azure_fileshare 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.adls_delete airflow.providers.microsoft.azure.operators.adls_list airflow.providers.microsoft.azure.operators.adx airflow.providers.microsoft.azure.operators.asb airflow.providers.microsoft.azure.operators.azure_batch airflow.providers.microsoft.azure.operators.azure_container_instances airflow.providers.microsoft.azure.operators.azure_cosmos 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.azure_key_vault airflow.providers.microsoft.azure.secrets.key_vault airflow.providers.microsoft.azure.sensors airflow.providers.microsoft.azure.sensors.azure_cosmos 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.file_to_wasb 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 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_blob_to_gcs 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

N

name (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryPipelineRunLink 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.AzureSynapseRunSparkBatchOperator method)

operator_extra_links (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryRunPipelineOperator 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) PipelineRunInfo (class in airflow.providers.microsoft.azure.hooks.data_factory) 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)

provide_targeted_factory() (in module airflow.providers.microsoft.azure.hooks.data_factory) PYTHONPATH

Q

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

QUEUED (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryPipelineRunStatus 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) 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)

resource_group_name (airflow.providers.microsoft.azure.hooks.data_factory.PipelineRunInfo attribute) run_id (airflow.providers.microsoft.azure.hooks.data_factory.PipelineRunInfo attribute) run_pipeline() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook 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) 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) set_context() (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler 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) SHUTTING_DOWN (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseSparkBatchRunStatus attribute) 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) SUCCESS (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseSparkBatchRunStatus attribute)

T

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.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.azure_blob_to_gcs.AzureBlobStorageToGCSOperator 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.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.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_blob_to_gcs) (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) 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_blob_to_gcs 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 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)

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) 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_blob (in module tests.system.providers.microsoft.azure.example_azure_blob_to_gcs) 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) 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) WasbBlobSensor (class in airflow.providers.microsoft.azure.sensors.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) 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?