Available Modules
Modules are Python callables available from this provider package.
Types:
SensorsHooksOperatorsTransfersLogSecrets
Waits for blobs matching a prefix to arrive on Azure Blob Storage.
Interacts with Azure Blob Storage through the wasb:// protocol.
Waits for a blob to arrive on Azure Blob Storage.
Deletes blob(s) on Azure Blob Storage.
Upload file(s) to Azure Data Lake
Delete files in the specified path.
Moves data from Oracle to Azure Data Lake. The operator runs the query against Oracle and stores the file locally before loading it into Azure Data La…
List all files from the specified path
Operator transfers data from Azure Blob Storage to specified bucket in Google Cloud Storage
This hook acts as a base hook for azure services. It offers several authentication mechanisms to authenticate the client library used for upstream azu…
FileTaskHandler is a python log handler that handles and reads task instance logs. It creates and delegates log handling to logging.FileHandler after …
Uploads a file to Azure Blob Storage.
Interacts with Azure Data Explorer (Kusto).
Operator for querying Azure Data Explorer (Kusto).
Checks the status of a pipeline run.
Executes a data factory pipeline.
Uploads a file to Azure Blob Storage.
Upload file(s) to Azure Data Lake
A hook to interact with Azure Data Factory.
Retrieves Airflow Connections or Variables from Azure Key Vault secrets.
Interacts with Azure FileShare Storage.
Interacts with Azure Data Lake.
Checks for the existence of a document which matches the given query in CosmosDB. Example:
Inserts a new document into the specified Cosmos database and collection It will create both the database and collection if they do not already exist
Interacts with Azure CosmosDB.
A hook to communicate with a Azure Container Registry.
A hook which wraps an Azure Volume.
Start a container on Azure Container Instances
Executes a job on Azure Batch Service
A hook to communicate with Azure Container Instances.
Hook for Azure Batch APIs
Transfer files to Azure Blob Storage from SFTP server.
Delete files in the specified path.
List all files from the specified path