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

模块内容¶

类¶

`PowerBIDatasetRefreshFields`	Power BI 数据集刷新详细信息。
`PowerBIDatasetRefreshStatus`	Power BI 数据集刷新状态。
`PowerBIHook`	一个用于与 Power BI 交互的异步 Hook。

class airflow.providers.microsoft.azure.hooks.powerbi.PowerBIDatasetRefreshFields[source]¶

基类：enum.Enum

Power BI 数据集刷新详细信息。

REQUEST_ID = 'request_id'[source]¶

STATUS = 'status'[source]¶

ERROR = 'error'[source]¶

class airflow.providers.microsoft.azure.hooks.powerbi.PowerBIDatasetRefreshStatus[source]¶

Power BI 数据集刷新状态。

IN_PROGRESS = 'In Progress'[source]¶

FAILED = 'Failed'[source]¶

COMPLETED = 'Completed'[source]¶

DISABLED = 'Disabled'[source]¶

TERMINAL_STATUSES[source]¶

FAILURE_STATUSES[source]¶

exception airflow.providers.microsoft.azure.hooks.powerbi.PowerBIDatasetRefreshException[source]¶

基类：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)[source]¶

基类：airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook

一个用于与 Power BI 交互的异步 Hook。

参数: conn_id (str) – Power BI 连接 ID。

conn_type: str = 'powerbi'[source]¶

conn_name_attr: str = 'conn_id'[source]¶

default_conn_name: str = 'powerbi_default'[source]¶

hook_name: str = 'Power BI'[source]¶

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。

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

模块内容¶

类¶

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