airflow.providers.microsoft.azure.triggers.powerbi¶
Classes¶
Triggers when Power BI dataset refresh is completed. |
|
Triggers a call to the API to request the available workspace IDs. |
|
Triggers a call to the API to request the available dataset IDs. |
Module Contents¶
- class airflow.providers.microsoft.azure.triggers.powerbi.PowerBITrigger(conn_id, dataset_id, group_id, timeout=60 * 60 * 24 * 7, dataset_refresh_id=None, proxies=None, api_version=None, check_interval=60, wait_for_termination=True)[source]¶
Bases:
airflow.triggers.base.BaseTrigger
Triggers when Power BI dataset refresh is completed.
Wait for termination will always be True.
- Parameters:
conn_id (str) – The connection Id to connect to PowerBI.
timeout (float) – The HTTP timeout being used by the KiotaRequestAdapter (default is None). When no timeout is specified or set to None then there is no HTTP timeout on each request.
proxies (dict | None) – A dict defining the HTTP proxies to be used (default is None).
api_version (msgraph_core.APIVersion | str | None) – The API version of the Microsoft Graph API to be used (default is v1). You can pass an enum named APIVersion which has 2 possible members v1 and beta, or you can pass a string as v1.0 or beta.
dataset_id (str) – The dataset Id to refresh.
dataset_refresh_id (str | None) – The dataset refresh Id to poll for the status, if not provided a new refresh will be triggered.
group_id (str) – The workspace Id where dataset is located.
end_time – Time in seconds when trigger should stop polling.
check_interval (int) – Time in seconds to wait between each poll.
wait_for_termination (bool) – Wait for the dataset refresh to complete or fail.
- class airflow.providers.microsoft.azure.triggers.powerbi.PowerBIWorkspaceListTrigger(conn_id, workspace_ids=None, timeout=60 * 60 * 24 * 7, proxies=None, api_version=None)[source]¶
Bases:
airflow.triggers.base.BaseTrigger
Triggers a call to the API to request the available workspace IDs.
- Parameters:
conn_id (str) – The connection Id to connect to PowerBI.
timeout (float) – The HTTP timeout being used by the KiotaRequestAdapter. Default is 1 week (60s * 60m * 24h * 7d). When no timeout is specified or set to None then there is no HTTP timeout on each request.
proxies (dict | None) – A dict defining the HTTP proxies to be used (default is None).
api_version (msgraph_core.APIVersion | str | None) – The API version of the Microsoft Graph API to be used (default is v1). You can pass an enum named APIVersion which has 2 possible members v1 and beta, or you can pass a string as v1.0 or beta.
- class airflow.providers.microsoft.azure.triggers.powerbi.PowerBIDatasetListTrigger(conn_id, group_id, dataset_ids=None, timeout=60 * 60 * 24 * 7, proxies=None, api_version=None)[source]¶
Bases:
airflow.triggers.base.BaseTrigger
Triggers a call to the API to request the available dataset IDs.
- Parameters:
conn_id (str) – The connection Id to connect to PowerBI.
group_id (str) – The group Id to list discoverable datasets.
timeout (float) – The HTTP timeout being used by the KiotaRequestAdapter. Default is 1 week (60s * 60m * 24h * 7d). When no timeout is specified or set to None then there is no HTTP timeout on each request.
proxies (dict | None) – A dict defining the HTTP proxies to be used (default is None).
api_version (msgraph_core.APIVersion | str | None) – The API version of the Microsoft Graph API to be used (default is v1). You can pass an enum named APIVersion which has 2 possible members v1 and beta, or you can pass a string as v1.0 or beta.