airflow.providers.microsoft.azure.operators.powerbi¶

類¶

`PowerBILink`	構造一個連結以監視 Power BI 中的資料集。
`PowerBIDatasetRefreshOperator`	重新整理 Power BI 資料集。

模組內容¶

class airflow.providers.microsoft.azure.operators.powerbi.PowerBILink[source]¶

基類: airflow.sdk.BaseOperatorLink

構造一個連結以監視 Power BI 中的資料集。

name = 'Monitor PowerBI Dataset'[source]¶: 連結名稱。這將是任務 UI 上的按鈕名稱。

get_link(operator, *, ti_key)[source]¶

外部系統連結。

引數:

operator (airflow.models.BaseOperator) – 與此連結關聯的 Airflow operator 物件。
ti_key (airflow.models.taskinstancekey.TaskInstanceKey) – 返回連結的任務例項 ID。

返回:

外部系統連結

class airflow.providers.microsoft.azure.operators.powerbi.PowerBIDatasetRefreshOperator(*, dataset_id, group_id, conn_id=PowerBIHook.default_conn_name, timeout=60 * 60 * 24 * 7, proxies=None, api_version=None, check_interval=60, **kwargs)[source]¶

基類: airflow.models.BaseOperator

重新整理 Power BI 資料集。

另請參閱

有關如何使用此 operator 的更多資訊，請參閱指南：PowerBIDatasetRefreshOperator

引數:

dataset_id (str) – 資料集 ID。
group_id (str) – 工作區 ID。
conn_id (str) – 包含用於認證的 Power BI 賬戶連線資訊的 Airflow 連線 ID。
timeout (float) – 對於非同步等待，等待資料集達到最終狀態的時間（以秒為單位）。僅在 wait_for_termination 為 True 時使用。
check_interval (int) – 重新檢查重新整理狀態之前等待的秒數。

template_fields: collections.abc.Sequence[str] = ('dataset_id', 'group_id')[source]¶

template_fields_renderers[source]¶

operator_extra_links[source]¶

hook[source]¶

dataset_id[source]¶

group_id[source]¶

wait_for_termination = True[source]¶

conn_id = 'powerbi_default'[source]¶

timeout = 604800[source]¶

check_interval = 60[source]¶

property proxies: dict | None[source]¶

property api_version: str | None[source]¶

execute(context)[source]¶

重新整理 Power BI 資料集。

get_refresh_status(context, event=None)[source]¶

將重新整理 ID 推送到 XCom，然後執行觸發器等待重新整理完成。

execute_complete(context, event)[source]¶

立即返回 - 觸發器觸發時的回撥。

依賴觸發器丟擲異常，否則假定執行成功。