airflow.providers.microsoft.azure.triggers.powerbi¶

類¶

PowerBITrigger

當 Power BI 資料集重新整理完成時觸發。

模組內容¶

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)[原始碼]¶

基礎類: airflow.triggers.base.BaseTrigger

當 Power BI 資料集重新整理完成時觸發。

等待終止將始終為 True。

引數:

conn_id (str) – 用於連線 PowerBI 的連線 ID。
timeout (float) – KiotaRequestAdapter 使用的 HTTP 超時（預設為 None）。當未指定超時或設定為 None 時，每個請求都沒有 HTTP 超時。
proxies (dict | None) – 定義要使用的 HTTP 代理的字典（預設為 None）。
api_version (msgraph_core.APIVersion | str | None) – 要使用的 Microsoft Graph API 版本（預設為 v1）。您可以傳遞一個名為 APIVersion 的列舉，它有兩個可能的成員 v1 和 beta，或者您可以傳遞一個字串，例如 v1.0 或 beta。
dataset_id (str) – 要重新整理的資料集 ID。
dataset_refresh_id (str | None) – 用於輪詢狀態的資料集重新整理 ID，如果未提供，將觸發新的重新整理。
group_id (str) – 資料集所在的工作區 ID。
end_time – 觸發器應停止輪詢的時間（秒）。
check_interval (int) – 每次輪詢之間等待的時間（秒）。
wait_for_termination (bool) – 等待資料集重新整理完成或失敗。

hook[原始碼]¶

dataset_id[原始碼]¶

dataset_refresh_id = None[原始碼]¶

timeout = 604800[原始碼]¶

group_id[原始碼]¶

check_interval = 60[原始碼]¶

wait_for_termination = True[原始碼]¶

serialize()[原始碼]¶: 序列化觸發器例項。

property conn_id: str[原始碼]¶

property proxies: dict | None[原始碼]¶

property api_version: msgraph_core.APIVersion | str[原始碼]¶

async run()[原始碼]¶

非同步連線 PowerBI 並輪詢資料集重新整理狀態。