airflow.providers.google.firebase.operators.firestore

模块内容

CloudFirestoreExportDatabaseOperator

将文档从 Google Cloud Firestore 导出到另一个存储系统,例如 Google Cloud Storage。

class airflow.providers.google.firebase.operators.firestore.CloudFirestoreExportDatabaseOperator(*, body, database_id='(default)', project_id=PROVIDE_PROJECT_ID, gcp_conn_id='google_cloud_default', api_version='v1', impersonation_chain=None, **kwargs)[源代码]

基类: airflow.models.BaseOperator

将文档从 Google Cloud Firestore 导出到另一个存储系统,例如 Google Cloud Storage。

另请参阅

有关如何使用此操作符的更多信息,请查看指南:导出数据库

参数
  • database_id (str) – 数据库 ID。

  • body (dict) – 请求正文。请参阅:https://firebase.google.com/docs/firestore/reference/rest/v1beta1/projects.databases/exportDocuments

  • project_id (str) – Google Cloud 项目的 ID,如果为 None,则使用默认的 project_id。

  • gcp_conn_id (str) – 用于连接到 Google Cloud 的连接 ID。

  • api_version (str) – 使用的 API 版本(例如 v1 或 v1beta1)。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务帐户,用于使用短期凭据模拟,或获取列表中最后一个帐户的 access_token 所需的链式帐户列表,该帐户将在请求中被模拟。 如果设置为字符串,则帐户必须授予发起帐户“服务帐户令牌创建者”IAM 角色。 如果设置为序列,则列表中标识必须授予紧随其后的标识“服务帐户令牌创建者”IAM 角色,列表中的第一个帐户将此角色授予发起帐户(已模板化)。

template_fields: collections.abc.Sequence[str] = ('body', 'gcp_conn_id', 'api_version', 'impersonation_chain')[源代码]
execute(context)[源代码]

在创建操作符时派生。

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

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

此条目是否有帮助?