airflow.providers.google.firebase.hooks.firestore¶

Google Cloud Firestore 服務的 Hook。

屬性¶

TIME_TO_SLEEP_IN_SECONDS

類¶

CloudFirestoreHook

用於 Google Firestore API 的 Hook。

模組內容¶

airflow.providers.google.firebase.hooks.firestore.TIME_TO_SLEEP_IN_SECONDS = 5[source]¶

class airflow.providers.google.firebase.hooks.firestore.CloudFirestoreHook(api_version='v1', gcp_conn_id='google_cloud_default', impersonation_chain=None)[source]¶

基類: airflow.providers.google.common.hooks.base_google.GoogleBaseHook

用於 Google Firestore API 的 Hook。

Hook 中所有使用 project_id 的方法都必須使用關鍵字引數呼叫，而不是位置引數。

引數:

api_version (str) – 使用的 API 版本（例如 v1 或 v1beta1）。
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 角色，列表中第一個賬號將此角色授予原始賬號。

api_version = 'v1'[source]¶

get_conn()[source]¶

檢索到 Cloud Firestore 的連線。

返回:: Google Cloud Firestore 服務物件。

export_documents(body, database_id='(default)', project_id=PROVIDE_PROJECT_ID)[source]¶

使用指定的配置開始匯出。

引數:

database_id (str) – 資料庫 ID。
body (dict) – 請求體。參閱：https://firebase.google.com/docs/firestore/reference/rest/v1beta1/projects.databases/exportDocuments
project_id (str) – 可選，資料庫所屬的 Google Cloud Project 的 project_id。如果設定為 None 或缺失，將使用 Google Cloud 連線中的預設 project_id。