airflow.providers.google.suite.transfers.sql_to_sheets¶

类¶

SQLToGoogleSheetsOperator

将 SQL 结果数据复制到指定的 Google 表格中。

模块内容¶

类 airflow.providers.google.suite.transfers.sql_to_sheets.SQLToGoogleSheetsOperator(*, sql, spreadsheet_id, sql_conn_id, parameters=None, database=None, spreadsheet_range='Sheet1', gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[来源]¶

基类: airflow.providers.common.sql.operators.sql.BaseSQLOperator

将 SQL 结果数据复制到指定的 Google 表格中。

参数:

sql (str) – 要执行的 SQL 语句。
spreadsheet_id (str) – 要交互的 Google 表格 ID。
conn_id – 用于连接到数据库的连接 ID。
parameters (collections.abc.Iterable | collections.abc.Mapping[str, Any] | None) – 用于渲染 SQL 查询的参数。
database (str | None) – 数据库名称，将覆盖连接中定义的名称
spreadsheet_range (str) – 要检索值的 A1 表示法范围。
gcp_conn_id (str) – 获取连接信息时使用的连接 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务账号，用于使用短期凭据进行模拟，或者获取列表中最后一个账号的 access_token 所需的账号链式列表，该账号将在请求中被模拟。如果设置为字符串，则该账号必须授予发起账号 Service Account Token Creator IAM 角色。如果设置为序列，则列表中的身份必须授予紧接在其之前的身份 Service Account Token Creator IAM 角色，其中列表中的第一个账号授予发起账号此角色（模板化）。

template_fields: collections.abc.Sequence[str] = ('sql', 'spreadsheet_id', 'spreadsheet_range', 'impersonation_chain')[来源]¶

template_fields_renderers[来源]¶

template_ext: collections.abc.Sequence[str] = ('.sql',)[来源]¶

ui_color = '#a0e08c'[来源]¶

sql[来源]¶

conn_id[来源]¶

database = None[来源]¶

parameters = None[来源]¶

gcp_conn_id = 'google_cloud_default'[来源]¶

spreadsheet_id[来源]¶

spreadsheet_range = 'Sheet1'[来源]¶

impersonation_chain = None[来源]¶

execute(context)[来源]¶

创建操作符时派生。

上下文是与渲染 Jinja 模板时使用的相同字典。

有关更多上下文信息，请参阅 get_template_context。