• Home
• Index

Index

_

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

A

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

airflow.providers.microsoft.azure.triggers.data_factory module airflow.providers.microsoft.azure.triggers.msgraph module airflow.providers.microsoft.azure.triggers.powerbi module airflow.providers.microsoft.azure.triggers.wasb module airflow.providers.microsoft.azure.utils module AIRFLOW_HOME (in module tests.system.microsoft.azure.example_azure_synapse) api_version (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook property) (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator attribute) (airflow.providers.microsoft.azure.operators.powerbi.PowerBIDatasetRefreshOperator property) (airflow.providers.microsoft.azure.sensors.msgraph.MSGraphSensor attribute) (airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger property) (airflow.providers.microsoft.azure.triggers.powerbi.PowerBITrigger property) append_result() (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator class method) ASBReceiveSubscriptionMessageOperator (class in airflow.providers.microsoft.azure.operators.asb) AsyncCredentials (in module airflow.providers.microsoft.azure.hooks.data_factory) (in module airflow.providers.microsoft.azure.hooks.wasb) authorization_rules (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusTopicCreateOperator attribute) auto_delete_on_idle (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSubscriptionCreateOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusTopicCreateOperator attribute) auto_scale_formula (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) aws_conn_id (airflow.providers.microsoft.azure.transfers.s3_to_wasb.S3ToAzureBlobStorageOperator attribute) azure_batch_conn_id (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) azure_batch_operator (in module tests.system.microsoft.azure.example_azure_batch_operator) AZURE_BLOB_NAME (in module tests.system.microsoft.azure.example_local_to_wasb) AZURE_CONTAINER_NAME (in module tests.system.microsoft.azure.example_local_to_wasb) (in module tests.system.microsoft.azure.example_sftp_to_wasb) azure_cosmos_conn_id (airflow.providers.microsoft.azure.operators.cosmos.AzureCosmosInsertDocumentOperator attribute) (airflow.providers.microsoft.azure.sensors.cosmos.AzureCosmosDocumentSensor attribute) azure_data_explorer_conn_id (airflow.providers.microsoft.azure.operators.adx.AzureDataExplorerQueryOperator attribute) azure_data_factory_conn_id (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryRunPipelineOperator attribute) (airflow.providers.microsoft.azure.sensors.data_factory.AzureDataFactoryPipelineRunStatusSensor attribute) (airflow.providers.microsoft.azure.triggers.data_factory.ADFPipelineRunStatusSensorTrigger attribute) (airflow.providers.microsoft.azure.triggers.data_factory.AzureDataFactoryTrigger attribute) azure_data_lake_conn_id (airflow.providers.microsoft.azure.operators.adls.ADLSCreateObjectOperator attribute) (airflow.providers.microsoft.azure.operators.adls.ADLSDeleteOperator attribute) (airflow.providers.microsoft.azure.operators.adls.ADLSListOperator attribute) (airflow.providers.microsoft.azure.transfers.local_to_adls.LocalFilesystemToADLSOperator attribute) (airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake.OracleToAzureDataLakeOperator attribute) azure_data_lake_path (airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake.OracleToAzureDataLakeOperator attribute) azure_service_bus_conn_id (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) AZURE_STORAGE_ACOOUNT (in module tests.system.microsoft.azure.example_azure_container_instances) azure_synapse_conn_id (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunPipelineOperator attribute) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunSparkBatchOperator attribute) azure_synapse_workspace_dev_endpoint (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineHook attribute) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunPipelineOperator attribute) AZURE_VOLUME_SHARE_NAME (in module tests.system.microsoft.azure.example_azure_container_instances) azure_wasb_sensor (in module tests.system.microsoft.azure.example_wasb_sensors) AzureBaseHook (class in airflow.providers.microsoft.azure.hooks.base_azure) AzureBatchHook (class in airflow.providers.microsoft.azure.hooks.batch) AzureBatchOperator (class in airflow.providers.microsoft.azure.operators.batch) AzureContainerInstanceHook (class in airflow.providers.microsoft.azure.hooks.container_instance) AzureContainerInstancesOperator (class in airflow.providers.microsoft.azure.operators.container_instances) AzureContainerRegistryHook (class in airflow.providers.microsoft.azure.hooks.container_registry) AzureContainerVolumeHook (class in airflow.providers.microsoft.azure.hooks.container_volume) AzureCosmosDBHook (class in airflow.providers.microsoft.azure.hooks.cosmos) AzureCosmosDocumentSensor (class in airflow.providers.microsoft.azure.sensors.cosmos) AzureCosmosInsertDocumentOperator (class in airflow.providers.microsoft.azure.operators.cosmos) AzureDataExplorerHook (class in airflow.providers.microsoft.azure.hooks.adx) AzureDataExplorerQueryOperator (class in airflow.providers.microsoft.azure.operators.adx) AzureDataFactoryAsyncHook (class in airflow.providers.microsoft.azure.hooks.data_factory) AzureDataFactoryHook (class in airflow.providers.microsoft.azure.hooks.data_factory) AzureDataFactoryPipelineRunException AzureDataFactoryPipelineRunLink (class in airflow.providers.microsoft.azure.operators.data_factory) AzureDataFactoryPipelineRunStatus (class in airflow.providers.microsoft.azure.hooks.data_factory) AzureDataFactoryPipelineRunStatusSensor (class in airflow.providers.microsoft.azure.sensors.data_factory) AzureDataFactoryRunPipelineOperator (class in airflow.providers.microsoft.azure.operators.data_factory) AzureDataFactoryTrigger (class in airflow.providers.microsoft.azure.triggers.data_factory) AzureDataLakeHook (class in airflow.providers.microsoft.azure.hooks.data_lake) AzureDataLakeStorageV2Hook (class in airflow.providers.microsoft.azure.hooks.data_lake) AzureFileShareHook (class in airflow.providers.microsoft.azure.hooks.fileshare) AzureIdentityCredentialAdapter (class in airflow.providers.microsoft.azure.utils) AzureKeyVaultBackend (class in airflow.providers.microsoft.azure.secrets.key_vault) AzureServiceBusCreateQueueOperator (class in airflow.providers.microsoft.azure.operators.asb) AzureServiceBusDeleteQueueOperator (class in airflow.providers.microsoft.azure.operators.asb) AzureServiceBusReceiveMessageOperator (class in airflow.providers.microsoft.azure.operators.asb) AzureServiceBusSendMessageOperator (class in airflow.providers.microsoft.azure.operators.asb) AzureServiceBusSubscriptionCreateOperator (class in airflow.providers.microsoft.azure.operators.asb) AzureServiceBusSubscriptionDeleteOperator (class in airflow.providers.microsoft.azure.operators.asb) AzureServiceBusTopicCreateOperator (class in airflow.providers.microsoft.azure.operators.asb) AzureServiceBusTopicDeleteOperator (class in airflow.providers.microsoft.azure.operators.asb) AzureServiceBusUpdateSubscriptionOperator (class in airflow.providers.microsoft.azure.operators.asb) AzureSynapseHook (class in airflow.providers.microsoft.azure.hooks.synapse) AzureSynapsePipelineHook (class in airflow.providers.microsoft.azure.hooks.synapse) AzureSynapsePipelineRunException AzureSynapsePipelineRunLink (class in airflow.providers.microsoft.azure.operators.synapse) AzureSynapsePipelineRunStatus (class in airflow.providers.microsoft.azure.hooks.synapse) AzureSynapseRunPipelineOperator (class in airflow.providers.microsoft.azure.operators.synapse) AzureSynapseRunSparkBatchOperator (class in airflow.providers.microsoft.azure.operators.synapse) AzureSynapseSparkBatchRunStatus (class in airflow.providers.microsoft.azure.hooks.synapse)

B

BaseAzureServiceBusHook (class in airflow.providers.microsoft.azure.hooks.asb) BaseAzureSynapseHook (class in airflow.providers.microsoft.azure.hooks.synapse) batch (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSendMessageOperator attribute) batch_job_display_name (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) batch_job_id (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) batch_job_manager_task (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) batch_job_preparation_task (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) batch_job_release_task (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) batch_max_retries (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) batch_pool_display_name (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) batch_pool_id (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) batch_pool_vm_size (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) batch_start_task (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) batch_task_command_line (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) batch_task_container_settings (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) batch_task_display_name (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) batch_task_id (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) batch_task_output_files (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) batch_task_resource_files (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) batch_task_user_identity (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute)

begin (in module tests.system.microsoft.azure.example_adf_run_pipeline) (in module tests.system.microsoft.azure.example_synapse_run_pipeline) blob_name (airflow.providers.microsoft.azure.operators.wasb_delete_blob.WasbDeleteBlobOperator attribute) (airflow.providers.microsoft.azure.sensors.wasb.WasbBlobSensor attribute) (airflow.providers.microsoft.azure.transfers.local_to_wasb.LocalFilesystemToWasbOperator attribute) (airflow.providers.microsoft.azure.transfers.s3_to_wasb.S3ToAzureBlobStorageOperator attribute) (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SftpFile attribute) (airflow.providers.microsoft.azure.triggers.wasb.WasbBlobSensorTrigger attribute) BLOB_NAME (in module tests.system.microsoft.azure.example_s3_to_wasb) (in module tests.system.microsoft.azure.example_wasb_sensors) blob_prefix (airflow.providers.microsoft.azure.transfers.s3_to_wasb.S3ToAzureBlobStorageOperator attribute) (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator attribute) BLOB_PREFIX (in module tests.system.microsoft.azure.example_s3_to_wasb) (in module tests.system.microsoft.azure.example_sftp_to_wasb) blob_service_client (airflow.providers.microsoft.azure.hooks.wasb.WasbAsyncHook attribute) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook property) blocksize (airflow.providers.microsoft.azure.transfers.local_to_adls.LocalFilesystemToADLSOperator attribute) buffersize (airflow.providers.microsoft.azure.transfers.local_to_adls.LocalFilesystemToADLSOperator attribute) build_path() (airflow.providers.microsoft.azure.secrets.key_vault.AzureKeyVaultBackend static method) BUSY (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseSparkBatchRunStatus attribute)

C

cached_request_adapters (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook attribute) cancel_dataset_refresh() (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIHook method) cancel_job_run() (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook method) cancel_pipeline_run() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryAsyncHook method) (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) cancel_run_pipeline() (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineHook method) cancel_trigger() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) CANCELING (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryPipelineRunStatus attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineRunStatus attribute) CANCELLED (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryPipelineRunStatus attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineRunStatus attribute) check_for_blob() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) check_for_blob_async() (airflow.providers.microsoft.azure.hooks.wasb.WasbAsyncHook method) check_for_directory() (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook method) check_for_file() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeHook method) check_for_prefix() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) check_for_prefix_async() (airflow.providers.microsoft.azure.hooks.wasb.WasbAsyncHook method) check_interval (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryRunPipelineOperator attribute) (airflow.providers.microsoft.azure.operators.powerbi.PowerBIDatasetRefreshOperator attribute) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunPipelineOperator attribute) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunSparkBatchOperator attribute) (airflow.providers.microsoft.azure.triggers.data_factory.AzureDataFactoryTrigger attribute) (airflow.providers.microsoft.azure.triggers.powerbi.PowerBITrigger attribute) check_options (airflow.providers.microsoft.azure.operators.wasb_delete_blob.WasbDeleteBlobOperator attribute) (airflow.providers.microsoft.azure.sensors.wasb.WasbBlobSensor attribute) (airflow.providers.microsoft.azure.sensors.wasb.WasbPrefixSensor attribute) (airflow.providers.microsoft.azure.triggers.wasb.WasbPrefixSensorTrigger attribute) check_wildcards_limit() (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator method) ci_conn_id (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator attribute) clean_up() (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator method) client (airflow.providers.microsoft.azure.secrets.key_vault.AzureKeyVaultBackend property) client_id (airflow.providers.microsoft.azure.secrets.key_vault.AzureKeyVaultBackend attribute) CLIENT_ID (in module tests.system.microsoft.azure.example_azure_service_bus) (in module tests.system.microsoft.azure.example_powerbi_dataset_refresh) client_secret (airflow.providers.microsoft.azure.secrets.key_vault.AzureKeyVaultBackend attribute) CLIENT_SECRET (in module tests.system.microsoft.azure.example_powerbi_dataset_refresh) close() (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler method) closed (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler attribute) collection_name (airflow.providers.microsoft.azure.operators.cosmos.AzureCosmosInsertDocumentOperator attribute) (airflow.providers.microsoft.azure.sensors.cosmos.AzureCosmosDocumentSensor attribute) command (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator attribute) COMPLETED (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIDatasetRefreshStatus attribute) configure_job() (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook method) configure_pool() (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook method) configure_task() (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook method) conn_id (airflow.providers.microsoft.azure.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_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.msgraph.KiotaRequestAdapterHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.BaseAzureSynapseHook attribute) (airflow.providers.microsoft.azure.hooks.wasb.WasbAsyncHook attribute) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook attribute) (airflow.providers.microsoft.azure.operators.container_instances.Volume attribute) (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator attribute) (airflow.providers.microsoft.azure.operators.powerbi.PowerBIDatasetRefreshOperator attribute) (airflow.providers.microsoft.azure.sensors.msgraph.MSGraphSensor attribute) (airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger property) (airflow.providers.microsoft.azure.triggers.powerbi.PowerBITrigger property) CONN_ID (in module tests.system.microsoft.azure.example_powerbi_dataset_refresh) conn_name_attr (airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook attribute) (airflow.providers.microsoft.azure.hooks.asb.BaseAzureServiceBusHook attribute) (airflow.providers.microsoft.azure.hooks.base_azure.AzureBaseHook attribute) (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook attribute) (airflow.providers.microsoft.azure.hooks.container_instance.AzureContainerInstanceHook attribute) (airflow.providers.microsoft.azure.hooks.container_registry.AzureContainerRegistryHook attribute) (airflow.providers.microsoft.azure.hooks.container_volume.AzureContainerVolumeHook attribute) (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook attribute) (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook attribute) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeHook attribute) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook attribute) (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook attribute) (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook attribute) (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.BaseAzureSynapseHook attribute) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook attribute)

conn_type (airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook attribute) (airflow.providers.microsoft.azure.hooks.asb.BaseAzureServiceBusHook attribute) (airflow.providers.microsoft.azure.hooks.base_azure.AzureBaseHook attribute) (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook attribute) (airflow.providers.microsoft.azure.hooks.container_instance.AzureContainerInstanceHook attribute) (airflow.providers.microsoft.azure.hooks.container_registry.AzureContainerRegistryHook attribute) (airflow.providers.microsoft.azure.hooks.container_volume.AzureContainerVolumeHook attribute) (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook attribute) (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook attribute) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeHook attribute) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook attribute) (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook attribute) (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook attribute) (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.BaseAzureSynapseHook attribute) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook attribute) connection (airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook property) (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook property) (airflow.providers.microsoft.azure.hooks.container_instance.AzureContainerInstanceHook property) (airflow.providers.microsoft.azure.hooks.container_registry.AzureContainerRegistryHook property) container_name (airflow.providers.microsoft.azure.operators.wasb_delete_blob.WasbDeleteBlobOperator attribute) (airflow.providers.microsoft.azure.sensors.wasb.WasbBlobSensor attribute) (airflow.providers.microsoft.azure.sensors.wasb.WasbPrefixSensor attribute) (airflow.providers.microsoft.azure.transfers.local_to_wasb.LocalFilesystemToWasbOperator attribute) (airflow.providers.microsoft.azure.transfers.s3_to_wasb.S3ToAzureBlobStorageOperator attribute) (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator attribute) (airflow.providers.microsoft.azure.triggers.wasb.WasbBlobSensorTrigger attribute) (airflow.providers.microsoft.azure.triggers.wasb.WasbPrefixSensorTrigger attribute) CONTAINER_NAME (in module tests.system.microsoft.azure.example_wasb_sensors) CONTAINER_REGISTRY_SERVER (in module tests.system.microsoft.azure.example_azure_container_instances) copy_blobs() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) copy_files_to_wasb() (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator method) cpu (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator attribute) create_collection() (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook method) create_connection() (in module tests.system.microsoft.azure.example_powerbi_dataset_refresh) create_container (airflow.providers.microsoft.azure.transfers.local_to_wasb.LocalFilesystemToWasbOperator attribute) (airflow.providers.microsoft.azure.transfers.s3_to_wasb.S3ToAzureBlobStorageOperator attribute) (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator attribute) create_container() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) create_database() (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook method) create_dataflow() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) create_dataset() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) create_directory() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook method) (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook method) create_factory() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) create_file() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook method) create_file_system() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook method) create_fileshare() (in module tests.system.microsoft.azure.example_fileshare) create_job() (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook method) create_linked_service() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) create_or_update() (airflow.providers.microsoft.azure.hooks.container_instance.AzureContainerInstanceHook method) create_pipeline() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) create_pool() (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook method) create_queue() (airflow.providers.microsoft.azure.hooks.asb.AdminClientHook method) create_service_bus_queue (in module tests.system.microsoft.azure.example_azure_service_bus) create_share() (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook method) create_subscription() (airflow.providers.microsoft.azure.hooks.asb.AdminClientHook method) create_topic() (airflow.providers.microsoft.azure.hooks.asb.AdminClientHook method) create_trigger() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) Credentials (in module airflow.providers.microsoft.azure.hooks.data_factory) (in module airflow.providers.microsoft.azure.hooks.data_lake) (in module airflow.providers.microsoft.azure.hooks.synapse)

D

DAG_ID (in module tests.system.microsoft.azure.example_adf_run_pipeline) (in module tests.system.microsoft.azure.example_adls_create) (in module tests.system.microsoft.azure.example_adls_delete) (in module tests.system.microsoft.azure.example_adls_list) (in module tests.system.microsoft.azure.example_azure_container_instances) (in module tests.system.microsoft.azure.example_azure_cosmosdb) (in module tests.system.microsoft.azure.example_fileshare) (in module tests.system.microsoft.azure.example_local_to_adls) (in module tests.system.microsoft.azure.example_local_to_wasb) (in module tests.system.microsoft.azure.example_msfabric) (in module tests.system.microsoft.azure.example_msgraph) (in module tests.system.microsoft.azure.example_powerbi) (in module tests.system.microsoft.azure.example_powerbi_dataset_refresh) (in module tests.system.microsoft.azure.example_s3_to_wasb) (in module tests.system.microsoft.azure.example_sftp_to_wasb) data (airflow.providers.microsoft.azure.operators.adls.ADLSCreateObjectOperator attribute) (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator attribute) (airflow.providers.microsoft.azure.sensors.msgraph.MSGraphSensor attribute) (airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger attribute) database (airflow.providers.microsoft.azure.operators.adx.AzureDataExplorerQueryOperator attribute) database_name (airflow.providers.microsoft.azure.operators.cosmos.AzureCosmosInsertDocumentOperator attribute) (airflow.providers.microsoft.azure.sensors.cosmos.AzureCosmosDocumentSensor attribute) dataset_id (airflow.providers.microsoft.azure.operators.powerbi.PowerBIDatasetRefreshOperator attribute) (airflow.providers.microsoft.azure.triggers.powerbi.PowerBITrigger attribute) DATASET_ID (in module tests.system.microsoft.azure.example_powerbi_dataset_refresh) dataset_refresh_id (airflow.providers.microsoft.azure.triggers.powerbi.PowerBITrigger attribute) DEAD (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseSparkBatchRunStatus attribute) dead_lettering_on_message_expiration (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusCreateQueueOperator attribute) default_args (in module tests.system.microsoft.azure.example_azure_synapse) DEFAULT_AZURE_DATA_LAKE_CONN_ID (in module airflow.providers.microsoft.azure.operators.adls) default_collection_name (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook attribute) default_conn_name (airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook attribute) (airflow.providers.microsoft.azure.hooks.asb.BaseAzureServiceBusHook attribute) (airflow.providers.microsoft.azure.hooks.base_azure.AzureBaseHook attribute) (airflow.providers.microsoft.azure.hooks.batch.AzureBatchHook attribute) (airflow.providers.microsoft.azure.hooks.container_instance.AzureContainerInstanceHook attribute) (airflow.providers.microsoft.azure.hooks.container_registry.AzureContainerRegistryHook attribute) (airflow.providers.microsoft.azure.hooks.container_volume.AzureContainerVolumeHook attribute) (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook attribute) (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryAsyncHook attribute) (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook attribute) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeHook attribute) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook attribute) (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook attribute) (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook attribute) (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineHook attribute) (airflow.providers.microsoft.azure.hooks.synapse.BaseAzureSynapseHook attribute) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook attribute) DEFAULT_CPU (in module airflow.providers.microsoft.azure.operators.container_instances) default_database_name (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook attribute) DEFAULT_ENVIRONMENT_VARIABLES (in module airflow.providers.microsoft.azure.operators.container_instances)

default_event_handler() (in module airflow.providers.microsoft.azure.operators.msgraph) DEFAULT_HEADERS (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook attribute) DEFAULT_MEMORY_IN_GB (in module airflow.providers.microsoft.azure.operators.container_instances) default_message_time_to_live (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSubscriptionCreateOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusTopicCreateOperator attribute) default_partition_key (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook attribute) DEFAULT_SCOPE (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook attribute) DEFAULT_SECURED_VARIABLES (in module airflow.providers.microsoft.azure.operators.container_instances) DEFAULT_VOLUMES (in module airflow.providers.microsoft.azure.operators.container_instances) DefaultResponseHandler (class in airflow.providers.microsoft.azure.hooks.msgraph) deferrable (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryRunPipelineOperator 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) delete() (airflow.providers.microsoft.azure.hooks.container_instance.AzureContainerInstanceHook method) delete_blobs() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) delete_collection() (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook method) delete_container() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) delete_database() (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook method) delete_dataflow() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) delete_dataset() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) delete_directory() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook method) delete_document() (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook method) delete_factory() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) delete_file() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) delete_file_system() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook method) delete_files() (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator method) delete_fileshare() (in module tests.system.microsoft.azure.example_fileshare) delete_linked_service() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) delete_local_copy (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler attribute) delete_pipeline() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) delete_queue() (airflow.providers.microsoft.azure.hooks.asb.AdminClientHook method) delete_sftp_file() (in module tests.system.microsoft.azure.example_sftp_to_wasb) delete_share() (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook method) delete_subscription() (airflow.providers.microsoft.azure.hooks.asb.AdminClientHook method) delete_trigger() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) delimiter (airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake.OracleToAzureDataLakeOperator attribute) deserialize() (airflow.providers.microsoft.azure.triggers.msgraph.ResponseSerializer method) diagnostics (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator attribute) DIRECTORY (in module tests.system.microsoft.azure.example_fileshare) directory_path (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook attribute) DISABLED (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIDatasetRefreshStatus attribute) dl_on_filter_evaluation_exceptions (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSubscriptionCreateOperator attribute) dl_on_message_expiration (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSubscriptionCreateOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusUpdateSubscriptionOperator attribute) dns_config (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator attribute) document (airflow.providers.microsoft.azure.operators.cosmos.AzureCosmosInsertDocumentOperator attribute) document_id (airflow.providers.microsoft.azure.sensors.cosmos.AzureCosmosDocumentSensor attribute) does_collection_exist() (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook method) does_database_exist() (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook method) download() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) download_file() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeHook method) dry_run() (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator method) duplicate_detection_history_time_window (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusTopicCreateOperator attribute)

E

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

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

F

factory_name (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryRunPipelineOperator attribute) (airflow.providers.microsoft.azure.sensors.data_factory.AzureDataFactoryPipelineRunStatusSensor attribute) (airflow.providers.microsoft.azure.triggers.data_factory.ADFPipelineRunStatusSensorTrigger attribute) (airflow.providers.microsoft.azure.triggers.data_factory.AzureDataFactoryTrigger attribute) fail_if_exists (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator attribute) FAILED (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryPipelineRunStatus attribute) (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIDatasetRefreshStatus attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineRunStatus attribute) FAILURE_STATES (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryPipelineRunStatus attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineRunStatus attribute) FAILURE_STATUSES (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIDatasetRefreshStatus attribute)

FILE_COMPLETE_PATH (in module tests.system.microsoft.azure.example_sftp_to_wasb) file_name (airflow.providers.microsoft.azure.operators.adls.ADLSCreateObjectOperator attribute) file_path (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook attribute) (airflow.providers.microsoft.azure.transfers.local_to_wasb.LocalFilesystemToWasbOperator attribute) file_system_name (airflow.providers.microsoft.azure.operators.adls.ADLSCreateObjectOperator attribute) filename (airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake.OracleToAzureDataLakeOperator attribute) filter_rule (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSubscriptionCreateOperator attribute) filter_rule_name (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSubscriptionCreateOperator attribute) filtering_messages_before_publishing (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusTopicCreateOperator attribute) format_no_proxy_url() (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook static method) forward_dead_lettered_messages_to (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSubscriptionCreateOperator attribute) forward_to (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSubscriptionCreateOperator attribute)

G

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

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

H

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

host (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook attribute)

I

IDLE (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseSparkBatchRunStatus attribute) ignore_if_missing (airflow.providers.microsoft.azure.operators.wasb_delete_blob.WasbDeleteBlobOperator attribute) ignore_not_found (airflow.providers.microsoft.azure.operators.adls.ADLSDeleteOperator attribute) image (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator attribute) IN_PROGRESS (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryPipelineRunStatus attribute) (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIDatasetRefreshStatus attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineRunStatus attribute) insert_documents() (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook method)

INTERMEDIATE_STATES (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryPipelineRunStatus attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineRunStatus attribute) InvalidAzureBlobParameters InvalidKeyComponents ip_address (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator attribute) is_prefix (airflow.providers.microsoft.azure.operators.wasb_delete_blob.WasbDeleteBlobOperator attribute) is_recovery (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryRunPipelineOperator attribute) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunPipelineOperator attribute)

J

job_id (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook attribute) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunSparkBatchOperator attribute)

K

key (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator attribute) KILLED (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseSparkBatchRunStatus attribute)

KiotaRequestAdapterHook (class in airflow.providers.microsoft.azure.hooks.msgraph) kwargs (airflow.providers.microsoft.azure.secrets.key_vault.AzureKeyVaultBackend attribute)

L

length (airflow.providers.microsoft.azure.operators.adls.ADLSCreateObjectOperator attribute) 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_options (airflow.providers.microsoft.azure.transfers.local_to_wasb.LocalFilesystemToWasbOperator attribute) (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator attribute)

load_string() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) LOCAL_FILE_PATH (in module tests.system.microsoft.azure.example_adls_delete) (in module tests.system.microsoft.azure.example_adls_list) (in module tests.system.microsoft.azure.example_local_to_adls) (in module tests.system.microsoft.azure.example_sftp_to_wasb) local_path (airflow.providers.microsoft.azure.transfers.local_to_adls.LocalFilesystemToADLSOperator attribute) LocalFilesystemToADLSOperator (class in airflow.providers.microsoft.azure.transfers.local_to_adls) LocalFilesystemToWasbOperator (class in airflow.providers.microsoft.azure.transfers.local_to_wasb) lock_duration (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSubscriptionCreateOperator attribute) log_relative_path (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler attribute)

M

managed_identity_client_id (airflow.providers.microsoft.azure.secrets.key_vault.AzureKeyVaultBackend attribute) max_delivery_count (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusCreateQueueOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSubscriptionCreateOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusUpdateSubscriptionOperator attribute) max_message_count (airflow.providers.microsoft.azure.operators.asb.ASBReceiveSubscriptionMessageOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusReceiveMessageOperator attribute) max_message_size_in_kilobytes (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusTopicCreateOperator attribute) max_size_in_megabytes (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusTopicCreateOperator attribute) max_wait_time (airflow.providers.microsoft.azure.operators.asb.ASBReceiveSubscriptionMessageOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusReceiveMessageOperator attribute) memory_in_gb (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator attribute) message (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSendMessageOperator attribute) MESSAGE (in module tests.system.microsoft.azure.example_azure_service_bus) message_callback (airflow.providers.microsoft.azure.operators.asb.ASBReceiveSubscriptionMessageOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusReceiveMessageOperator attribute) MESSAGE_LIST (in module tests.system.microsoft.azure.example_azure_service_bus) MessageCallback (in module airflow.providers.microsoft.azure.hooks.asb) (in module airflow.providers.microsoft.azure.operators.asb) MessageHook (class in airflow.providers.microsoft.azure.hooks.asb) method (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator attribute) (airflow.providers.microsoft.azure.sensors.msgraph.MSGraphSensor attribute) (airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger attribute) module airflow.providers.microsoft.azure airflow.providers.microsoft.azure.fs airflow.providers.microsoft.azure.fs.adls airflow.providers.microsoft.azure.hooks airflow.providers.microsoft.azure.hooks.adx airflow.providers.microsoft.azure.hooks.asb airflow.providers.microsoft.azure.hooks.base_azure airflow.providers.microsoft.azure.hooks.batch airflow.providers.microsoft.azure.hooks.container_instance airflow.providers.microsoft.azure.hooks.container_registry airflow.providers.microsoft.azure.hooks.container_volume airflow.providers.microsoft.azure.hooks.cosmos airflow.providers.microsoft.azure.hooks.data_factory airflow.providers.microsoft.azure.hooks.data_lake airflow.providers.microsoft.azure.hooks.fileshare airflow.providers.microsoft.azure.hooks.msgraph airflow.providers.microsoft.azure.hooks.powerbi airflow.providers.microsoft.azure.hooks.synapse airflow.providers.microsoft.azure.hooks.wasb airflow.providers.microsoft.azure.log airflow.providers.microsoft.azure.log.wasb_task_handler airflow.providers.microsoft.azure.operators airflow.providers.microsoft.azure.operators.adls airflow.providers.microsoft.azure.operators.adx airflow.providers.microsoft.azure.operators.asb airflow.providers.microsoft.azure.operators.batch airflow.providers.microsoft.azure.operators.container_instances airflow.providers.microsoft.azure.operators.cosmos airflow.providers.microsoft.azure.operators.data_factory airflow.providers.microsoft.azure.operators.msgraph airflow.providers.microsoft.azure.operators.powerbi airflow.providers.microsoft.azure.operators.synapse airflow.providers.microsoft.azure.operators.wasb_delete_blob airflow.providers.microsoft.azure.secrets airflow.providers.microsoft.azure.secrets.key_vault airflow.providers.microsoft.azure.sensors airflow.providers.microsoft.azure.sensors.cosmos airflow.providers.microsoft.azure.sensors.data_factory airflow.providers.microsoft.azure.sensors.msgraph airflow.providers.microsoft.azure.sensors.wasb airflow.providers.microsoft.azure.transfers airflow.providers.microsoft.azure.transfers.local_to_adls airflow.providers.microsoft.azure.transfers.local_to_wasb airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake airflow.providers.microsoft.azure.transfers.s3_to_wasb airflow.providers.microsoft.azure.transfers.sftp_to_wasb airflow.providers.microsoft.azure.triggers airflow.providers.microsoft.azure.triggers.data_factory airflow.providers.microsoft.azure.triggers.msgraph airflow.providers.microsoft.azure.triggers.powerbi airflow.providers.microsoft.azure.triggers.wasb airflow.providers.microsoft.azure.utils tests.system.microsoft.azure tests.system.microsoft.azure.example_adf_run_pipeline tests.system.microsoft.azure.example_adls_create tests.system.microsoft.azure.example_adls_delete tests.system.microsoft.azure.example_adls_list tests.system.microsoft.azure.example_azure_batch_operator tests.system.microsoft.azure.example_azure_container_instances tests.system.microsoft.azure.example_azure_cosmosdb tests.system.microsoft.azure.example_azure_service_bus tests.system.microsoft.azure.example_azure_synapse tests.system.microsoft.azure.example_fileshare tests.system.microsoft.azure.example_local_to_adls tests.system.microsoft.azure.example_local_to_wasb tests.system.microsoft.azure.example_msfabric tests.system.microsoft.azure.example_msgraph tests.system.microsoft.azure.example_powerbi tests.system.microsoft.azure.example_powerbi_dataset_refresh tests.system.microsoft.azure.example_s3_to_wasb tests.system.microsoft.azure.example_sftp_to_wasb tests.system.microsoft.azure.example_synapse_run_pipeline tests.system.microsoft.azure.example_wasb_sensors

mount_path (airflow.providers.microsoft.azure.operators.container_instances.Volume attribute) move_file() (airflow.providers.microsoft.azure.transfers.s3_to_wasb.S3ToAzureBlobStorageOperator method) move_object (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator attribute) MSGraphAsyncOperator (class in airflow.providers.microsoft.azure.operators.msgraph) MSGraphSensor (class in airflow.providers.microsoft.azure.sensors.msgraph) MSGraphTrigger (class in airflow.providers.microsoft.azure.triggers.msgraph)

N

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

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

O

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

options (airflow.providers.microsoft.azure.operators.adx.AzureDataExplorerQueryOperator attribute) oracle_conn_id (airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake.OracleToAzureDataLakeOperator attribute) OracleToAzureDataLakeOperator (class in airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake) os_family (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) os_type (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator attribute) os_version (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) overwrite (airflow.providers.microsoft.azure.transfers.local_to_adls.LocalFilesystemToADLSOperator attribute)

P

paginate() (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator static method) pagination_function (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator attribute) parameters (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryRunPipelineOperator attribute) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunPipelineOperator attribute) parse_blob_account_url() (in module airflow.providers.microsoft.azure.utils) PartitionKeyType (in module airflow.providers.microsoft.azure.hooks.cosmos) path (airflow.providers.microsoft.azure.operators.adls.ADLSDeleteOperator attribute) (airflow.providers.microsoft.azure.operators.adls.ADLSListOperator attribute) path_parameters (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator attribute) (airflow.providers.microsoft.azure.sensors.msgraph.MSGraphSensor attribute) (airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger attribute) PATH_TO_UPLOAD_FILE (in module tests.system.microsoft.azure.example_local_to_wasb) payload (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunSparkBatchOperator attribute) pipeline_name (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryRunPipelineOperator attribute) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunPipelineOperator attribute) 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) poke_interval (airflow.providers.microsoft.azure.triggers.data_factory.ADFPipelineRunStatusSensorTrigger attribute) (airflow.providers.microsoft.azure.triggers.wasb.WasbBlobSensorTrigger attribute) (airflow.providers.microsoft.azure.triggers.wasb.WasbPrefixSensorTrigger attribute) POOL_ID (in module tests.system.microsoft.azure.example_azure_batch_operator) ports (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator attribute) PowerBIDatasetRefreshException PowerBIDatasetRefreshFields (class in airflow.providers.microsoft.azure.hooks.powerbi)

PowerBIDatasetRefreshOperator (class in airflow.providers.microsoft.azure.operators.powerbi) PowerBIDatasetRefreshStatus (class in airflow.providers.microsoft.azure.hooks.powerbi) PowerBIHook (class in airflow.providers.microsoft.azure.hooks.powerbi) PowerBILink (class in airflow.providers.microsoft.azure.operators.powerbi) PowerBITrigger (class in airflow.providers.microsoft.azure.triggers.powerbi) prefix (airflow.providers.microsoft.azure.sensors.wasb.WasbPrefixSensor attribute) (airflow.providers.microsoft.azure.triggers.wasb.WasbPrefixSensorTrigger attribute) PREFIX (in module tests.system.microsoft.azure.example_wasb_sensors) priority (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator attribute) provide_targeted_factory() (in module airflow.providers.microsoft.azure.hooks.data_factory) provide_targeted_factory_async() (in module airflow.providers.microsoft.azure.hooks.data_factory) proxies (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook attribute) (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator attribute) (airflow.providers.microsoft.azure.operators.powerbi.PowerBIDatasetRefreshOperator property) (airflow.providers.microsoft.azure.sensors.msgraph.MSGraphSensor attribute) (airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger property) (airflow.providers.microsoft.azure.triggers.powerbi.PowerBITrigger property) public_read (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook attribute) (airflow.providers.microsoft.azure.hooks.wasb.WasbAsyncHook attribute) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook attribute) (airflow.providers.microsoft.azure.sensors.wasb.WasbBlobSensor attribute) (airflow.providers.microsoft.azure.sensors.wasb.WasbPrefixSensor attribute) (airflow.providers.microsoft.azure.triggers.wasb.WasbBlobSensorTrigger attribute) (airflow.providers.microsoft.azure.triggers.wasb.WasbPrefixSensorTrigger attribute) pull_xcom() (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator method) push_xcom() (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator method)

Q

query (airflow.providers.microsoft.azure.operators.adx.AzureDataExplorerQueryOperator attribute) query_parameters (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator attribute) (airflow.providers.microsoft.azure.sensors.msgraph.MSGraphSensor attribute) (airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger attribute) queue_name (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)

QUEUE_NAME (in module tests.system.microsoft.azure.example_azure_service_bus) QUEUED (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryPipelineRunStatus attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineRunStatus attribute) quotechar (airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake.OracleToAzureDataLakeOperator attribute) quoting (airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake.OracleToAzureDataLakeOperator attribute)

R

raw_to_refresh_details() (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIHook class method) read_file() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) read_only (airflow.providers.microsoft.azure.operators.container_instances.Volume attribute) receive_message() (airflow.providers.microsoft.azure.hooks.asb.MessageHook method) receive_subscription_message() (airflow.providers.microsoft.azure.hooks.asb.MessageHook method) recursive (airflow.providers.microsoft.azure.operators.adls.ADLSDeleteOperator attribute) reference_pipeline_run_id (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryRunPipelineOperator attribute) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunPipelineOperator attribute) 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) region (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator attribute) registry_conn_id (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator attribute) remote_base (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler attribute) REMOTE_FILE_PATH (in module tests.system.microsoft.azure.example_adls_create) (in module tests.system.microsoft.azure.example_adls_delete) (in module tests.system.microsoft.azure.example_adls_list) (in module tests.system.microsoft.azure.example_local_to_adls) remote_path (airflow.providers.microsoft.azure.transfers.local_to_adls.LocalFilesystemToADLSOperator attribute) remove() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeHook method) remove_on_error (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator attribute) replace (airflow.providers.microsoft.azure.operators.adls.ADLSCreateObjectOperator attribute) (airflow.providers.microsoft.azure.transfers.s3_to_wasb.S3ToAzureBlobStorageOperator attribute) REQUEST_ID (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIDatasetRefreshFields attribute) request_information() (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook method) requires_duplicate_detection (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusTopicCreateOperator attribute) requires_session (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSubscriptionCreateOperator attribute) rerun_trigger() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) resolve_api_version_from_value() (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook static method)

resolve_type() (airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger class method) resource_group (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator attribute) resource_group_name (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryRunPipelineOperator attribute) (airflow.providers.microsoft.azure.sensors.data_factory.AzureDataFactoryPipelineRunStatusSensor attribute) (airflow.providers.microsoft.azure.triggers.data_factory.ADFPipelineRunStatusSensorTrigger attribute) (airflow.providers.microsoft.azure.triggers.data_factory.AzureDataFactoryTrigger attribute) response_type (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator attribute) (airflow.providers.microsoft.azure.sensors.msgraph.MSGraphSensor attribute) (airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger attribute) ResponseSerializer (class in airflow.providers.microsoft.azure.triggers.msgraph) restart_policy (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator attribute) result_processor (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator attribute) (airflow.providers.microsoft.azure.sensors.msgraph.MSGraphSensor attribute) retry_execute() (airflow.providers.microsoft.azure.sensors.msgraph.MSGraphSensor method) run() (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook method) (airflow.providers.microsoft.azure.triggers.data_factory.ADFPipelineRunStatusSensorTrigger method) (airflow.providers.microsoft.azure.triggers.data_factory.AzureDataFactoryTrigger method) (airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger method) (airflow.providers.microsoft.azure.triggers.powerbi.PowerBITrigger method) (airflow.providers.microsoft.azure.triggers.wasb.WasbBlobSensorTrigger method) (airflow.providers.microsoft.azure.triggers.wasb.WasbPrefixSensorTrigger method) run_id (airflow.providers.microsoft.azure.sensors.data_factory.AzureDataFactoryPipelineRunStatusSensor attribute) (airflow.providers.microsoft.azure.triggers.data_factory.ADFPipelineRunStatusSensorTrigger attribute) (airflow.providers.microsoft.azure.triggers.data_factory.AzureDataFactoryTrigger attribute) run_pipeline() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineHook method) run_query() (airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook method) run_spark_job (in module tests.system.microsoft.azure.example_azure_synapse) run_spark_job() (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook method) RUNNING (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseSparkBatchRunStatus attribute)

S

s3_bucket (airflow.providers.microsoft.azure.transfers.s3_to_wasb.S3ToAzureBlobStorageOperator attribute) s3_extra_args (airflow.providers.microsoft.azure.transfers.s3_to_wasb.S3ToAzureBlobStorageOperator attribute) s3_hook (airflow.providers.microsoft.azure.transfers.s3_to_wasb.S3ToAzureBlobStorageOperator property) s3_key (airflow.providers.microsoft.azure.transfers.s3_to_wasb.S3ToAzureBlobStorageOperator attribute) S3_KEY (in module tests.system.microsoft.azure.example_s3_to_wasb) s3_prefix (airflow.providers.microsoft.azure.transfers.s3_to_wasb.S3ToAzureBlobStorageOperator attribute) S3_PREFIX (in module tests.system.microsoft.azure.example_s3_to_wasb) s3_verify (airflow.providers.microsoft.azure.transfers.s3_to_wasb.S3ToAzureBlobStorageOperator attribute) S3ToAzureBlobStorageOperator (class in airflow.providers.microsoft.azure.transfers.s3_to_wasb) SAMPLE_FILENAME (in module tests.system.microsoft.azure.example_sftp_to_wasb) schemes (in module airflow.providers.microsoft.azure.fs.adls) scopes (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator attribute) (airflow.providers.microsoft.azure.sensors.msgraph.MSGraphSensor attribute) sdk_client (airflow.providers.microsoft.azure.hooks.base_azure.AzureBaseHook attribute) secured_variables (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator attribute) 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) sep (airflow.providers.microsoft.azure.secrets.key_vault.AzureKeyVaultBackend attribute) serialize() (airflow.providers.microsoft.azure.triggers.data_factory.ADFPipelineRunStatusSensorTrigger method) (airflow.providers.microsoft.azure.triggers.data_factory.AzureDataFactoryTrigger method) (airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger method) (airflow.providers.microsoft.azure.triggers.msgraph.ResponseSerializer method) (airflow.providers.microsoft.azure.triggers.powerbi.PowerBITrigger method) (airflow.providers.microsoft.azure.triggers.wasb.WasbBlobSensorTrigger method) (airflow.providers.microsoft.azure.triggers.wasb.WasbPrefixSensorTrigger method) serializer (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator attribute) (airflow.providers.microsoft.azure.sensors.msgraph.MSGraphSensor attribute) (airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger attribute) service_client (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook property) set_context() (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler method) set_token() (airflow.providers.microsoft.azure.utils.AzureIdentityCredentialAdapter method) set_up_connection (in module tests.system.microsoft.azure.example_powerbi_dataset_refresh) sftp_conn_id (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator attribute) SFTP_FILE_COMPLETE_PATH (in module tests.system.microsoft.azure.example_sftp_to_wasb) sftp_file_path (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SftpFile attribute) sftp_hook (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator property) sftp_source_path (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator attribute)

SFTP_SRC_PATH (in module tests.system.microsoft.azure.example_sftp_to_wasb) SftpFile (class in 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_name (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook attribute) (airflow.providers.microsoft.azure.operators.container_instances.Volume attribute) share_service_client (airflow.providers.microsoft.azure.hooks.fileshare.AzureFileShareHook property) should_delete_job (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) should_delete_pool (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) SHUTTING_DOWN (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseSparkBatchRunStatus attribute) signed_session() (airflow.providers.microsoft.azure.utils.AzureIdentityCredentialAdapter method) site_task (in module tests.system.microsoft.azure.example_msgraph) size_in_bytes (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusTopicCreateOperator attribute) sku_starts_with (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) source_path_contains_wildcard (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator property) SPARK_JOB_PAYLOAD (in module tests.system.microsoft.azure.example_azure_synapse) spark_pool (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseHook attribute) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunSparkBatchOperator attribute) sql (airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake.OracleToAzureDataLakeOperator attribute) sql_params (airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake.OracleToAzureDataLakeOperator attribute) start_activity_name (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryRunPipelineOperator attribute) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunPipelineOperator attribute) start_from_failure (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryRunPipelineOperator attribute) start_trigger() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) STARTING (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseSparkBatchRunStatus attribute) STATUS (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIDatasetRefreshFields attribute) stop_trigger() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) subnet_ids (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator attribute) subscription_name (airflow.providers.microsoft.azure.operators.asb.ASBReceiveSubscriptionMessageOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSubscriptionCreateOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSubscriptionDeleteOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusUpdateSubscriptionOperator attribute) SUBSCRIPTION_NAME (in module tests.system.microsoft.azure.example_azure_service_bus) SUCCEEDED (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryPipelineRunStatus attribute) (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapsePipelineRunStatus attribute) SUCCESS (airflow.providers.microsoft.azure.hooks.synapse.AzureSynapseSparkBatchRunStatus attribute) support_ordering (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusTopicCreateOperator attribute) sys_test_context_task (in module tests.system.microsoft.azure.example_s3_to_wasb)

T

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

tests.system.microsoft.azure module tests.system.microsoft.azure.example_adf_run_pipeline module tests.system.microsoft.azure.example_adls_create module tests.system.microsoft.azure.example_adls_delete module tests.system.microsoft.azure.example_adls_list module tests.system.microsoft.azure.example_azure_batch_operator module tests.system.microsoft.azure.example_azure_container_instances module tests.system.microsoft.azure.example_azure_cosmosdb module tests.system.microsoft.azure.example_azure_service_bus module tests.system.microsoft.azure.example_azure_synapse module tests.system.microsoft.azure.example_fileshare module tests.system.microsoft.azure.example_local_to_adls module tests.system.microsoft.azure.example_local_to_wasb module tests.system.microsoft.azure.example_msfabric module tests.system.microsoft.azure.example_msgraph module tests.system.microsoft.azure.example_powerbi module tests.system.microsoft.azure.example_powerbi_dataset_refresh module tests.system.microsoft.azure.example_s3_to_wasb module tests.system.microsoft.azure.example_sftp_to_wasb module tests.system.microsoft.azure.example_synapse_run_pipeline module tests.system.microsoft.azure.example_wasb_sensors module timeout (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook attribute) (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryRunPipelineOperator attribute) (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator attribute) (airflow.providers.microsoft.azure.operators.powerbi.PowerBIDatasetRefreshOperator attribute) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunPipelineOperator attribute) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunSparkBatchOperator attribute) (airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger property) (airflow.providers.microsoft.azure.triggers.powerbi.PowerBITrigger attribute) to_httpx_proxies() (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook class method) to_msal_proxies() (airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook method) TooManyFilesToMoveException topic_name (airflow.providers.microsoft.azure.operators.asb.ASBReceiveSubscriptionMessageOperator 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) TOPIC_NAME (in module tests.system.microsoft.azure.example_azure_service_bus) transfer_files_to_sftp_step (in module tests.system.microsoft.azure.example_sftp_to_wasb) trigger_dataset_refresh() (airflow.providers.microsoft.azure.hooks.powerbi.PowerBIHook method) trigger_next_link() (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator method) trigger_should_wrap (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler attribute)

U

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

update_factory() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) update_linked_service() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) update_pipeline() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) update_subscription() (airflow.providers.microsoft.azure.hooks.asb.AdminClientHook method) update_trigger() (airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook method) upload (in module tests.system.microsoft.azure.example_local_to_wasb) upload() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) upload_data (in module tests.system.microsoft.azure.example_adls_create) upload_file (in module tests.system.microsoft.azure.example_adls_delete) (in module tests.system.microsoft.azure.example_local_to_adls) upload_file() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeHook method) (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook method) upload_file_to_directory() (airflow.providers.microsoft.azure.hooks.data_lake.AzureDataLakeStorageV2Hook method) upload_on_close (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler attribute) upsert_document() (airflow.providers.microsoft.azure.hooks.cosmos.AzureCosmosDBHook method) url (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator attribute) (airflow.providers.microsoft.azure.sensors.msgraph.MSGraphSensor attribute) (airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger attribute) url_template (airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator attribute) (airflow.providers.microsoft.azure.sensors.msgraph.MSGraphSensor attribute) (airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger attribute) use_latest_image (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) user_metadata (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusSubscriptionCreateOperator attribute) (airflow.providers.microsoft.azure.operators.asb.AzureServiceBusTopicCreateOperator attribute)

V

vault_url (airflow.providers.microsoft.azure.secrets.key_vault.AzureKeyVaultBackend attribute) vm_node_agent_sku_id (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) vm_offer (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) vm_publisher (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute)

vm_sku (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) vm_version (airflow.providers.microsoft.azure.operators.batch.AzureBatchOperator attribute) Volume (class in airflow.providers.microsoft.azure.operators.container_instances) volumes (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator attribute)

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) wait_for_termination (airflow.providers.microsoft.azure.operators.data_factory.AzureDataFactoryRunPipelineOperator attribute) (airflow.providers.microsoft.azure.operators.powerbi.PowerBIDatasetRefreshOperator attribute) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunPipelineOperator attribute) (airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunSparkBatchOperator attribute) (airflow.providers.microsoft.azure.triggers.data_factory.AzureDataFactoryTrigger attribute) (airflow.providers.microsoft.azure.triggers.powerbi.PowerBITrigger attribute) wasb_conn_id (airflow.providers.microsoft.azure.operators.wasb_delete_blob.WasbDeleteBlobOperator attribute) (airflow.providers.microsoft.azure.sensors.wasb.WasbBlobSensor attribute) (airflow.providers.microsoft.azure.sensors.wasb.WasbPrefixSensor attribute) (airflow.providers.microsoft.azure.transfers.local_to_wasb.LocalFilesystemToWasbOperator attribute) (airflow.providers.microsoft.azure.transfers.s3_to_wasb.S3ToAzureBlobStorageOperator attribute) (airflow.providers.microsoft.azure.transfers.sftp_to_wasb.SFTPToWasbOperator attribute) (airflow.providers.microsoft.azure.triggers.wasb.WasbBlobSensorTrigger attribute) (airflow.providers.microsoft.azure.triggers.wasb.WasbPrefixSensorTrigger attribute)

wasb_container (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler attribute) wasb_extra_args (airflow.providers.microsoft.azure.transfers.s3_to_wasb.S3ToAzureBlobStorageOperator attribute) wasb_hook (airflow.providers.microsoft.azure.transfers.s3_to_wasb.S3ToAzureBlobStorageOperator property) wasb_log_exists() (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler method) wasb_read() (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler method) wasb_write() (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler method) WasbAsyncHook (class in airflow.providers.microsoft.azure.hooks.wasb) WasbBlobSensor (class in airflow.providers.microsoft.azure.sensors.wasb) WasbBlobSensorTrigger (class in airflow.providers.microsoft.azure.triggers.wasb) WasbDeleteBlobOperator (class in airflow.providers.microsoft.azure.operators.wasb_delete_blob) WasbHook (class in airflow.providers.microsoft.azure.hooks.wasb) WasbPrefixSensor (class in airflow.providers.microsoft.azure.sensors.wasb) WasbPrefixSensorTrigger (class in airflow.providers.microsoft.azure.triggers.wasb) WasbTaskHandler (class in airflow.providers.microsoft.azure.log.wasb_task_handler) WILDCARD (in module airflow.providers.microsoft.azure.transfers.sftp_to_wasb) workload_identity_tenant_id (airflow.providers.microsoft.azure.secrets.key_vault.AzureKeyVaultBackend attribute) workspaces_task (in module tests.system.microsoft.azure.example_msfabric) (in module tests.system.microsoft.azure.example_powerbi)

X

xcom_all (airflow.providers.microsoft.azure.operators.container_instances.AzureContainerInstancesOperator attribute)

PreviousNext

Was this entry helpful?