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。