airflow.providers.tableau.operators.tableau¶

属性¶

RESOURCES_METHODS

类¶

TableauOperator

执行一个 Tableau API 资源。

模块内容¶

airflow.providers.tableau.operators.tableau.RESOURCES_METHODS[源代码]¶

class airflow.providers.tableau.operators.tableau.TableauOperator(*, resource, method, find, match_with='id', site_id=None, blocking_refresh=True, check_interval=20, tableau_conn_id='tableau_default', **kwargs)[源代码]¶

基类: airflow.models.BaseOperator

执行一个 Tableau API 资源。

https://tableau.github.io/server-client-python/docs/api-ref

另请参阅

有关如何使用此操作符的更多信息，请参阅指南： TableauOperator

参数:

resource (str) – 要使用的资源的名称。
method (str) – 要执行的资源的方法的名称。
find (str) – 将接收操作的资源的引用。
match_with (str) – 与 find 参数匹配的资源字段名称。
site_id (str | None) – 工作簿所属站点的 ID。
blocking_refresh (bool) – 默认为阻塞模式，表示将等待直到完成。
check_interval (float) – 每次实例状态检查之间作业应等待的秒数，直到操作完成
tableau_conn_id (str) – 包含用于对 Tableau Server 进行身份验证的凭据的 Tableau 连接 ID。

template_fields: collections.abc.Sequence[str] = ('find', 'match_with')[源代码]¶

resource[源代码]¶

method[源代码]¶

find[源代码]¶

match_with = 'id'[源代码]¶

check_interval = 20[源代码]¶

site_id = None[源代码]¶

blocking_refresh = True[源代码]¶

tableau_conn_id = 'tableau_default'[源代码]¶

execute(context)[源代码]¶

执行 Tableau API 资源并将作业 ID 或下载的文件 URI 推送到 xcom。

参数:: context (airflow.sdk.definitions.context.Context) – 执行期间的任务上下文。
返回:: 执行提取刷新作业的 ID 或下载的文件 URI。
返回类型:: str