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]¶

立即返回 - 触发器触发时的回调。

依赖触发器抛出异常，否则假定执行成功。