airflow.providers.microsoft.azure.hooks.powerbi¶

異常¶

PowerBIDatasetRefreshException

表示資料集重新整理未能完成的異常。

類¶

`PowerBIDatasetRefreshFields`	Power BI 重新整理資料集詳情。
`PowerBIDatasetRefreshStatus`	Power BI 重新整理資料集狀態。
`PowerBIHook`	用於與 Power BI 互動的非同步 Hook。

模組內容¶

class airflow.providers.microsoft.azure.hooks.powerbi.PowerBIDatasetRefreshFields[原始碼]¶

Bases: enum.Enum

Power BI 重新整理資料集詳情。

REQUEST_ID = 'request_id'[原始碼]¶

STATUS = 'status'[原始碼]¶

ERROR = 'error'[原始碼]¶

class airflow.providers.microsoft.azure.hooks.powerbi.PowerBIDatasetRefreshStatus[原始碼]¶

Power BI 重新整理資料集狀態。

IN_PROGRESS = 'In Progress'[原始碼]¶

FAILED = 'Failed'[原始碼]¶

COMPLETED = 'Completed'[原始碼]¶

DISABLED = 'Disabled'[原始碼]¶

TERMINAL_STATUSES[原始碼]¶

FAILURE_STATUSES[原始碼]¶

exception airflow.providers.microsoft.azure.hooks.powerbi.PowerBIDatasetRefreshException[原始碼]¶

Bases: airflow.exceptions.AirflowException

表示資料集重新整理未能完成的異常。

class airflow.providers.microsoft.azure.hooks.powerbi.PowerBIHook(conn_id=default_conn_name, proxies=None, timeout=60 * 60 * 24 * 7, api_version=None)[原始碼]¶

Bases: airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook

用於與 Power BI 互動的非同步 Hook。

引數：: conn_id (str) – Power BI 連線 ID。

conn_type: str = 'powerbi'[原始碼]¶

conn_name_attr: str = 'conn_id'[原始碼]¶

default_conn_name: str = 'powerbi_default'[原始碼]¶

hook_name: str = 'Power BI'[原始碼]¶

classmethod get_connection_form_widgets()[原始碼]¶

返回要新增到連線表單的連線小部件。

classmethod get_ui_field_behaviour()[原始碼]¶

返回自定義欄位行為。

async get_refresh_history(dataset_id, group_id)[原始碼]¶

從給定組 ID 中檢索指定資料集的刷新歷史記錄。

引數：

dataset_id (str) – 資料集 ID。
group_id (str) – 工作區 ID。

返回：

包含資料集所有刷新歷史記錄的字典。

返回型別：

list[dict[str, str]]

classmethod raw_to_refresh_details(refresh_details)[原始碼]¶

將原始重新整理詳情轉換為包含所需欄位的字典。

引數：: refresh_details (dict) – 原始重新整理詳情物件。

async get_refresh_details_by_refresh_id(dataset_id, group_id, refresh_id)[原始碼]¶

獲取給定請求 ID 的重新整理詳情。

引數：: refresh_id (str) – 資料集重新整理的請求 ID。

async trigger_dataset_refresh(*, dataset_id, group_id)[原始碼]¶

觸發給定組 ID 中指定資料集的重新整理。

引數：

dataset_id (str) – 資料集 ID。
group_id (str) – 工作區 ID。

返回：

資料集重新整理請求的請求 ID。

返回型別：

str

async cancel_dataset_refresh(dataset_id, group_id, dataset_refresh_id)[原始碼]¶

取消資料集重新整理。

引數：

dataset_id (str) – 資料集 ID。
group_id (str) – 工作區 ID。
dataset_refresh_id (str) – 資料集重新整理 ID。