airflow.providers.microsoft.azure.triggers.powerbi¶

类¶

PowerBITrigger

当 Power BI 数据集刷新完成时触发。

模块内容¶

class airflow.providers.microsoft.azure.triggers.powerbi.PowerBITrigger(conn_id, dataset_id, group_id, timeout=60 * 60 * 24 * 7, dataset_refresh_id=None, proxies=None, api_version=None, check_interval=60, wait_for_termination=True)[源代码]¶

基础类: airflow.triggers.base.BaseTrigger

当 Power BI 数据集刷新完成时触发。

等待终止将始终为 True。

参数:

conn_id (str) – 用于连接 PowerBI 的连接 ID。
timeout (float) – KiotaRequestAdapter 使用的 HTTP 超时（默认为 None）。当未指定超时或设置为 None 时，每个请求都没有 HTTP 超时。
proxies (dict | None) – 定义要使用的 HTTP 代理的字典（默认为 None）。
api_version (msgraph_core.APIVersion | str | None) – 要使用的 Microsoft Graph API 版本（默认为 v1）。您可以传递一个名为 APIVersion 的枚举，它有两个可能的成员 v1 和 beta，或者您可以传递一个字符串，例如 v1.0 或 beta。
dataset_id (str) – 要刷新的数据集 ID。
dataset_refresh_id (str | None) – 用于轮询状态的数据集刷新 ID，如果未提供，将触发新的刷新。
group_id (str) – 数据集所在的工作区 ID。
end_time – 触发器应停止轮询的时间（秒）。
check_interval (int) – 每次轮询之间等待的时间（秒）。
wait_for_termination (bool) – 等待数据集刷新完成或失败。

hook[源代码]¶

dataset_id[源代码]¶

dataset_refresh_id = None[源代码]¶

timeout = 604800[源代码]¶

group_id[源代码]¶

check_interval = 60[源代码]¶

wait_for_termination = True[源代码]¶

serialize()[源代码]¶: 序列化触发器实例。

property conn_id: str[源代码]¶

property proxies: dict | None[源代码]¶

property api_version: msgraph_core.APIVersion | str[源代码]¶

async run()[源代码]¶

异步连接 PowerBI 并轮询数据集刷新状态。