airflow.providers.google.suite.transfers.sql_to_sheets

模块内容

SQLToGoogleSheetsOperator

将 SQL 结果中的数据复制到提供的 Google 电子表格。

class 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 所需的帐户链列表,该 access_token 将在请求中被模拟。如果设置为字符串,则该帐户必须向发起帐户授予服务帐户令牌创建者 IAM 角色。如果设置为序列,则列表中的身份必须向直接前面的身份授予服务帐户令牌创建者 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'[源代码]
execute(context)[源代码]

在创建操作符时派生。

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

有关更多上下文,请参阅 get_template_context。

此条目是否有帮助?