• Home
• Index

Index

_

__get_collection_name() (airflow.providers.microsoft.azure.hooks.azure_cosmos.AzureCosmosDBHook method) __get_database_name() (airflow.providers.microsoft.azure.hooks.azure_cosmos.AzureCosmosDBHook method) _check_inputs() (airflow.providers.microsoft.azure.operators.azure_batch.AzureBatchOperator method) _check_name() (airflow.providers.microsoft.azure.operators.azure_container_instances.AzureContainerInstancesOperator static method) _connection() (airflow.providers.microsoft.azure.hooks.azure_batch.AzureBatchHook method)

_get_latest_verified_image_vm_and_sku() (airflow.providers.microsoft.azure.hooks.azure_batch.AzureBatchHook method) _get_secret() (airflow.providers.microsoft.azure.secrets.azure_key_vault.AzureKeyVaultBackend method) _log_last() (airflow.providers.microsoft.azure.operators.azure_container_instances.AzureContainerInstancesOperator method) _monitor_logging() (airflow.providers.microsoft.azure.operators.azure_container_instances.AzureContainerInstancesOperator method) _read() (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler method) _write_temp_file() (airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake.OracleToAzureDataLakeOperator method)

A

add_single_task_to_job() (airflow.providers.microsoft.azure.hooks.azure_batch.AzureBatchHook method) airflow.providers.microsoft.azure module airflow.providers.microsoft.azure.hooks module airflow.providers.microsoft.azure.hooks.adx module airflow.providers.microsoft.azure.hooks.azure_batch module airflow.providers.microsoft.azure.hooks.azure_container_instance module airflow.providers.microsoft.azure.hooks.azure_container_registry module airflow.providers.microsoft.azure.hooks.azure_container_volume module airflow.providers.microsoft.azure.hooks.azure_cosmos module airflow.providers.microsoft.azure.hooks.azure_data_lake module airflow.providers.microsoft.azure.hooks.azure_fileshare module airflow.providers.microsoft.azure.hooks.base_azure 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_list module airflow.providers.microsoft.azure.operators.adx module airflow.providers.microsoft.azure.operators.azure_batch module airflow.providers.microsoft.azure.operators.azure_container_instances module airflow.providers.microsoft.azure.operators.azure_cosmos module

airflow.providers.microsoft.azure.operators.wasb_delete_blob module airflow.providers.microsoft.azure.secrets module airflow.providers.microsoft.azure.secrets.azure_key_vault module airflow.providers.microsoft.azure.sensors module airflow.providers.microsoft.azure.sensors.azure_cosmos module airflow.providers.microsoft.azure.sensors.wasb module airflow.providers.microsoft.azure.transfers module airflow.providers.microsoft.azure.transfers.azure_blob_to_gcs module airflow.providers.microsoft.azure.transfers.file_to_wasb module airflow.providers.microsoft.azure.transfers.local_to_adls module airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake module AzureBaseHook (class in airflow.providers.microsoft.azure.hooks.base_azure) AzureBatchHook (class in airflow.providers.microsoft.azure.hooks.azure_batch) AzureBatchOperator (class in airflow.providers.microsoft.azure.operators.azure_batch) AzureBlobStorageToGCSOperator (class in airflow.providers.microsoft.azure.transfers.azure_blob_to_gcs) AzureContainerInstanceHook (class in airflow.providers.microsoft.azure.hooks.azure_container_instance) AzureContainerInstancesOperator (class in airflow.providers.microsoft.azure.operators.azure_container_instances) AzureContainerRegistryHook (class in airflow.providers.microsoft.azure.hooks.azure_container_registry) AzureContainerVolumeHook (class in airflow.providers.microsoft.azure.hooks.azure_container_volume) AzureCosmosDBHook (class in airflow.providers.microsoft.azure.hooks.azure_cosmos) AzureCosmosDocumentSensor (class in airflow.providers.microsoft.azure.sensors.azure_cosmos) AzureCosmosInsertDocumentOperator (class in airflow.providers.microsoft.azure.operators.azure_cosmos) AzureDataExplorerHook (class in airflow.providers.microsoft.azure.hooks.adx) AzureDataExplorerQueryOperator (class in airflow.providers.microsoft.azure.operators.adx) AzureDataLakeHook (class in airflow.providers.microsoft.azure.hooks.azure_data_lake) AzureDataLakeStorageListOperator (class in airflow.providers.microsoft.azure.operators.adls_list) AzureFileShareHook (class in airflow.providers.microsoft.azure.hooks.azure_fileshare) AzureKeyVaultBackend (class in airflow.providers.microsoft.azure.secrets.azure_key_vault)

B

BlockBlobService (in module airflow.providers.microsoft.azure.hooks.wasb)

build_path() (airflow.providers.microsoft.azure.secrets.azure_key_vault.AzureKeyVaultBackend static method)

C

check_for_blob() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) check_for_directory() (airflow.providers.microsoft.azure.hooks.azure_fileshare.AzureFileShareHook method) check_for_file() (airflow.providers.microsoft.azure.hooks.azure_data_lake.AzureDataLakeHook method) (airflow.providers.microsoft.azure.hooks.azure_fileshare.AzureFileShareHook method) check_for_prefix() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) clean_up() (airflow.providers.microsoft.azure.operators.azure_batch.AzureBatchOperator method) client() (airflow.providers.microsoft.azure.secrets.azure_key_vault.AzureKeyVaultBackend method) close() (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler method) configure_job() (airflow.providers.microsoft.azure.hooks.azure_batch.AzureBatchHook method) configure_pool() (airflow.providers.microsoft.azure.hooks.azure_batch.AzureBatchHook method) configure_task() (airflow.providers.microsoft.azure.hooks.azure_batch.AzureBatchHook method) conn_name_attr (airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook attribute) (airflow.providers.microsoft.azure.hooks.azure_batch.AzureBatchHook attribute) (airflow.providers.microsoft.azure.hooks.azure_container_instance.AzureContainerInstanceHook attribute) (airflow.providers.microsoft.azure.hooks.azure_cosmos.AzureCosmosDBHook attribute) (airflow.providers.microsoft.azure.hooks.azure_data_lake.AzureDataLakeHook attribute) (airflow.providers.microsoft.azure.hooks.base_azure.AzureBaseHook attribute) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook attribute)

conn_type (airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook attribute) (airflow.providers.microsoft.azure.hooks.azure_batch.AzureBatchHook attribute) (airflow.providers.microsoft.azure.hooks.azure_container_instance.AzureContainerInstanceHook attribute) (airflow.providers.microsoft.azure.hooks.azure_cosmos.AzureCosmosDBHook attribute) (airflow.providers.microsoft.azure.hooks.azure_data_lake.AzureDataLakeHook attribute) (airflow.providers.microsoft.azure.hooks.base_azure.AzureBaseHook attribute) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook attribute) create_collection() (airflow.providers.microsoft.azure.hooks.azure_cosmos.AzureCosmosDBHook method) create_database() (airflow.providers.microsoft.azure.hooks.azure_cosmos.AzureCosmosDBHook method) create_directory() (airflow.providers.microsoft.azure.hooks.azure_fileshare.AzureFileShareHook method) create_job() (airflow.providers.microsoft.azure.hooks.azure_batch.AzureBatchHook method) create_or_update() (airflow.providers.microsoft.azure.hooks.azure_container_instance.AzureContainerInstanceHook method) create_pool() (airflow.providers.microsoft.azure.hooks.azure_batch.AzureBatchHook method) create_share() (airflow.providers.microsoft.azure.hooks.azure_fileshare.AzureFileShareHook method)

D

default_conn_name (airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook attribute) (airflow.providers.microsoft.azure.hooks.azure_batch.AzureBatchHook attribute) (airflow.providers.microsoft.azure.hooks.azure_container_instance.AzureContainerInstanceHook attribute) (airflow.providers.microsoft.azure.hooks.azure_cosmos.AzureCosmosDBHook attribute) (airflow.providers.microsoft.azure.hooks.azure_data_lake.AzureDataLakeHook attribute) (airflow.providers.microsoft.azure.hooks.base_azure.AzureBaseHook attribute) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook attribute) DEFAULT_CPU (in module airflow.providers.microsoft.azure.operators.azure_container_instances) DEFAULT_ENVIRONMENT_VARIABLES (in module airflow.providers.microsoft.azure.operators.azure_container_instances) DEFAULT_MEMORY_IN_GB (in module airflow.providers.microsoft.azure.operators.azure_container_instances)

DEFAULT_SECURED_VARIABLES (in module airflow.providers.microsoft.azure.operators.azure_container_instances) DEFAULT_VOLUMES (in module airflow.providers.microsoft.azure.operators.azure_container_instances) delete() (airflow.providers.microsoft.azure.hooks.azure_container_instance.AzureContainerInstanceHook method) delete_collection() (airflow.providers.microsoft.azure.hooks.azure_cosmos.AzureCosmosDBHook method) delete_database() (airflow.providers.microsoft.azure.hooks.azure_cosmos.AzureCosmosDBHook method) delete_document() (airflow.providers.microsoft.azure.hooks.azure_cosmos.AzureCosmosDBHook method) delete_file() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) delete_share() (airflow.providers.microsoft.azure.hooks.azure_fileshare.AzureFileShareHook method) does_collection_exist() (airflow.providers.microsoft.azure.hooks.azure_cosmos.AzureCosmosDBHook method) does_database_exist() (airflow.providers.microsoft.azure.hooks.azure_cosmos.AzureCosmosDBHook method) download_file() (airflow.providers.microsoft.azure.hooks.azure_data_lake.AzureDataLakeHook method)

E

environment variable PYTHONPATH execute() (airflow.providers.microsoft.azure.operators.adls_list.AzureDataLakeStorageListOperator method) (airflow.providers.microsoft.azure.operators.adx.AzureDataExplorerQueryOperator method) (airflow.providers.microsoft.azure.operators.azure_batch.AzureBatchOperator method) (airflow.providers.microsoft.azure.operators.azure_container_instances.AzureContainerInstancesOperator method) (airflow.providers.microsoft.azure.operators.azure_cosmos.AzureCosmosInsertDocumentOperator method) (airflow.providers.microsoft.azure.operators.wasb_delete_blob.WasbDeleteBlobOperator method) (airflow.providers.microsoft.azure.transfers.azure_blob_to_gcs.AzureBlobStorageToGCSOperator method) (airflow.providers.microsoft.azure.transfers.file_to_wasb.FileToWasbOperator method) (airflow.providers.microsoft.azure.transfers.local_to_adls.LocalToAzureDataLakeStorageOperator method) (airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake.OracleToAzureDataLakeOperator method)

exists() (airflow.providers.microsoft.azure.hooks.azure_container_instance.AzureContainerInstanceHook method)

F

FileToWasbOperator (class in airflow.providers.microsoft.azure.transfers.file_to_wasb)

G

get_blobs_list() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) get_collection_link() (in module airflow.providers.microsoft.azure.hooks.azure_cosmos) get_config() (airflow.providers.microsoft.azure.secrets.azure_key_vault.AzureKeyVaultBackend method) get_conn() (airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook method) (airflow.providers.microsoft.azure.hooks.azure_batch.AzureBatchHook method) (airflow.providers.microsoft.azure.hooks.azure_container_registry.AzureContainerRegistryHook method) (airflow.providers.microsoft.azure.hooks.azure_cosmos.AzureCosmosDBHook method) (airflow.providers.microsoft.azure.hooks.azure_data_lake.AzureDataLakeHook method) (airflow.providers.microsoft.azure.hooks.azure_fileshare.AzureFileShareHook method) (airflow.providers.microsoft.azure.hooks.base_azure.AzureBaseHook method) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) get_conn_uri() (airflow.providers.microsoft.azure.secrets.azure_key_vault.AzureKeyVaultBackend method) get_database_link() (in module airflow.providers.microsoft.azure.hooks.azure_cosmos) get_document() (airflow.providers.microsoft.azure.hooks.azure_cosmos.AzureCosmosDBHook method)

get_document_link() (in module airflow.providers.microsoft.azure.hooks.azure_cosmos) get_documents() (airflow.providers.microsoft.azure.hooks.azure_cosmos.AzureCosmosDBHook method) get_file() (airflow.providers.microsoft.azure.hooks.azure_fileshare.AzureFileShareHook method) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) get_file_to_stream() (airflow.providers.microsoft.azure.hooks.azure_fileshare.AzureFileShareHook method) get_file_volume() (airflow.providers.microsoft.azure.hooks.azure_container_volume.AzureContainerVolumeHook method) get_hook() (airflow.providers.microsoft.azure.operators.adx.AzureDataExplorerQueryOperator method) (airflow.providers.microsoft.azure.operators.azure_batch.AzureBatchOperator method) get_logs() (airflow.providers.microsoft.azure.hooks.azure_container_instance.AzureContainerInstanceHook method) get_messages() (airflow.providers.microsoft.azure.hooks.azure_container_instance.AzureContainerInstanceHook method) get_state() (airflow.providers.microsoft.azure.hooks.azure_container_instance.AzureContainerInstanceHook method) get_state_exitcode_details() (airflow.providers.microsoft.azure.hooks.azure_container_instance.AzureContainerInstanceHook method) get_storagekey() (airflow.providers.microsoft.azure.hooks.azure_container_volume.AzureContainerVolumeHook method) get_variable() (airflow.providers.microsoft.azure.secrets.azure_key_vault.AzureKeyVaultBackend method)

H

hook() (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler method) hook_name (airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook attribute) (airflow.providers.microsoft.azure.hooks.azure_batch.AzureBatchHook attribute) (airflow.providers.microsoft.azure.hooks.azure_container_instance.AzureContainerInstanceHook attribute) (airflow.providers.microsoft.azure.hooks.azure_cosmos.AzureCosmosDBHook attribute) (airflow.providers.microsoft.azure.hooks.azure_data_lake.AzureDataLakeHook attribute) (airflow.providers.microsoft.azure.hooks.base_azure.AzureBaseHook attribute) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook attribute)

I

insert_documents() (airflow.providers.microsoft.azure.hooks.azure_cosmos.AzureCosmosDBHook method)

L

list() (airflow.providers.microsoft.azure.hooks.azure_data_lake.AzureDataLakeHook method) list_directories_and_files() (airflow.providers.microsoft.azure.hooks.azure_fileshare.AzureFileShareHook method) list_files() (airflow.providers.microsoft.azure.hooks.azure_fileshare.AzureFileShareHook method) load_file() (airflow.providers.microsoft.azure.hooks.azure_fileshare.AzureFileShareHook method) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method)

load_stream() (airflow.providers.microsoft.azure.hooks.azure_fileshare.AzureFileShareHook method) load_string() (airflow.providers.microsoft.azure.hooks.azure_fileshare.AzureFileShareHook method) (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method) LocalToAzureDataLakeStorageOperator (class in airflow.providers.microsoft.azure.transfers.local_to_adls)

M

module airflow.providers.microsoft.azure airflow.providers.microsoft.azure.hooks airflow.providers.microsoft.azure.hooks.adx airflow.providers.microsoft.azure.hooks.azure_batch airflow.providers.microsoft.azure.hooks.azure_container_instance airflow.providers.microsoft.azure.hooks.azure_container_registry airflow.providers.microsoft.azure.hooks.azure_container_volume airflow.providers.microsoft.azure.hooks.azure_cosmos airflow.providers.microsoft.azure.hooks.azure_data_lake airflow.providers.microsoft.azure.hooks.azure_fileshare airflow.providers.microsoft.azure.hooks.base_azure 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_list airflow.providers.microsoft.azure.operators.adx airflow.providers.microsoft.azure.operators.azure_batch airflow.providers.microsoft.azure.operators.azure_container_instances airflow.providers.microsoft.azure.operators.azure_cosmos airflow.providers.microsoft.azure.operators.wasb_delete_blob airflow.providers.microsoft.azure.secrets airflow.providers.microsoft.azure.secrets.azure_key_vault airflow.providers.microsoft.azure.sensors airflow.providers.microsoft.azure.sensors.azure_cosmos airflow.providers.microsoft.azure.sensors.wasb airflow.providers.microsoft.azure.transfers airflow.providers.microsoft.azure.transfers.azure_blob_to_gcs airflow.providers.microsoft.azure.transfers.file_to_wasb airflow.providers.microsoft.azure.transfers.local_to_adls airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake

O

on_kill() (airflow.providers.microsoft.azure.operators.azure_batch.AzureBatchOperator method) (airflow.providers.microsoft.azure.operators.azure_container_instances.AzureContainerInstancesOperator method)

OracleToAzureDataLakeOperator (class in airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake)

P

poke() (airflow.providers.microsoft.azure.sensors.azure_cosmos.AzureCosmosDocumentSensor method) (airflow.providers.microsoft.azure.sensors.wasb.WasbBlobSensor method) (airflow.providers.microsoft.azure.sensors.wasb.WasbPrefixSensor method)

PYTHONPATH

R

read_file() (airflow.providers.microsoft.azure.hooks.wasb.WasbHook method)

run_query() (airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook method)

S

set_context() (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler method)

T

template_ext (airflow.providers.microsoft.azure.operators.adx.AzureDataExplorerQueryOperator attribute) template_fields (airflow.providers.microsoft.azure.operators.adls_list.AzureDataLakeStorageListOperator attribute) (airflow.providers.microsoft.azure.operators.adx.AzureDataExplorerQueryOperator attribute) (airflow.providers.microsoft.azure.operators.azure_batch.AzureBatchOperator attribute) (airflow.providers.microsoft.azure.operators.azure_container_instances.AzureContainerInstancesOperator attribute) (airflow.providers.microsoft.azure.operators.azure_cosmos.AzureCosmosInsertDocumentOperator attribute) (airflow.providers.microsoft.azure.operators.wasb_delete_blob.WasbDeleteBlobOperator attribute) (airflow.providers.microsoft.azure.sensors.azure_cosmos.AzureCosmosDocumentSensor attribute) (airflow.providers.microsoft.azure.sensors.wasb.WasbBlobSensor attribute) (airflow.providers.microsoft.azure.sensors.wasb.WasbPrefixSensor attribute) (airflow.providers.microsoft.azure.transfers.azure_blob_to_gcs.AzureBlobStorageToGCSOperator attribute) (airflow.providers.microsoft.azure.transfers.file_to_wasb.FileToWasbOperator attribute) (airflow.providers.microsoft.azure.transfers.local_to_adls.LocalToAzureDataLakeStorageOperator attribute) (airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake.OracleToAzureDataLakeOperator attribute)

U

ui_color (airflow.providers.microsoft.azure.operators.adls_list.AzureDataLakeStorageListOperator attribute) (airflow.providers.microsoft.azure.operators.adx.AzureDataExplorerQueryOperator attribute) (airflow.providers.microsoft.azure.operators.azure_batch.AzureBatchOperator attribute) (airflow.providers.microsoft.azure.operators.azure_cosmos.AzureCosmosInsertDocumentOperator attribute) (airflow.providers.microsoft.azure.transfers.local_to_adls.LocalToAzureDataLakeStorageOperator attribute) (airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake.OracleToAzureDataLakeOperator attribute)

upload_file() (airflow.providers.microsoft.azure.hooks.azure_data_lake.AzureDataLakeHook method) upsert_document() (airflow.providers.microsoft.azure.hooks.azure_cosmos.AzureCosmosDBHook method)

V

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

W

wait_for_all_node_state() (airflow.providers.microsoft.azure.hooks.azure_batch.AzureBatchHook method) wait_for_job_tasks_to_complete() (airflow.providers.microsoft.azure.hooks.azure_batch.AzureBatchHook method) wasb_log_exists() (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler method) wasb_read() (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler method) wasb_write() (airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler method)

WasbBlobSensor (class in airflow.providers.microsoft.azure.sensors.wasb) WasbDeleteBlobOperator (class in airflow.providers.microsoft.azure.operators.wasb_delete_blob) WasbHook (class in airflow.providers.microsoft.azure.hooks.wasb) WasbPrefixSensor (class in airflow.providers.microsoft.azure.sensors.wasb) WasbTaskHandler (class in airflow.providers.microsoft.azure.log.wasb_task_handler)

PreviousNext

Was this entry helpful?