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)[source]¶

基類: airflow.models.BaseOperator

將文件從 Google Cloud Firestore 匯出到其他儲存系統，例如 Google Cloud Storage。

另請參閱

有關如何使用此運算子的更多資訊，請參閱指南：Export database

引數::

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 所需的帳號鏈式列表，該帳號將在請求中被模擬。如果設定為字串，則該帳號必須授予原始帳號 Service Account Token Creator IAM 角色。如果設定為序列，則列表中的身份必須將 Service Account Token Creator IAM 角色授予緊接在前的身份，列表中第一個帳號將此角色授予原始帳號（可模板化）。

template_fields: collections.abc.Sequence[str] = ('body', 'gcp_conn_id', 'api_version', 'impersonation_chain')[source]¶

database_id = '(default)'[source]¶

body[source]¶

project_id = None[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

api_version = 'v1'[source]¶

impersonation_chain = None[source]¶

execute(context)[source]¶

建立運算子時實現此方法。

Context 是與渲染 Jinja 模板時使用的相同的字典。

有關更多上下文，請參閱 get_template_context。