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, proxies=None, api_version=None, check_interval=60, wait_for_termination=True)[source]

基类: 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 的 API 版本（默认为 v1）。你可以传递一个名为 APIVersion 的枚举，它有两个可能的成员 v1 和 beta，或者你可以传递一个字符串，如 v1.0 或 beta。

  • dataset_id (str) – 要刷新的数据集 ID。

  • group_id (str) – 数据集所在的工作区 ID。

  • end_time – 触发器应停止轮询的秒数。

  • check_interval (int) – 每次轮询之间等待的秒数。

  • wait_for_termination (bool) – 等待数据集刷新完成或失败。

property conn_id: str[source]
property proxies: dict | None[source]
property api_version: msgraph_core.APIVersion | str[source]
serialize()[source]

序列化触发器实例。

async run()[source]

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

此条目是否有帮助？