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

模块内容¶

类¶

`PowerBILink`	构建一个链接以在 Power BI 中监控数据集。
`PowerBIDatasetRefreshOperator`	刷新 Power BI 数据集。

class airflow.providers.microsoft.azure.operators.powerbi.PowerBILink[source]¶

基类: airflow.models.BaseOperatorLink

构建一个链接以在 Power BI 中监控数据集。

name = '监控 PowerBI 数据集'[source]¶

get_link(operator, *, ti_key)[source]¶

链接到外部系统。

注意：此函数的旧签名是 (self, operator, dttm: datetime)。这在运行时仍然支持，但已弃用。

参数

operator (airflow.models.BaseOperator) – 与此链接关联的 Airflow 操作符对象。
ti_key (airflow.models.taskinstancekey.TaskInstanceKey) – 用于返回链接的 TaskInstance 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 数据集。

另请参阅

有关如何使用此操作符的更多信息，请查看指南: PowerBIDatasetRefreshOperator

参数

dataset_id (str) – 数据集 ID。
group_id (str) – 工作区 ID。
conn_id (str) – Airflow 连接 ID，其中包含用于身份验证的 Power BI 帐户的连接信息。
timeout (float) – 等待数据集达到异步等待的终端状态的时间（以秒为单位）。仅当 wait_for_termination 为 True 时使用。
check_interval (int) – 重新检查刷新状态前等待的秒数。

property proxies: dict | None[source]¶

property api_version: str | None[source]¶

template_fields: collections.abc.Sequence[str] = ('dataset_id', 'group_id')[source]¶

template_fields_renderers[source]¶

operator_extra_links = ()[source]¶

execute(context)[source]¶

刷新 Power BI 数据集。

execute_complete(context, event)[source]¶

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

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

airflow.providers.microsoft.azure.operators.powerbi¶

模块内容¶

类¶

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