Google Cloud Firestore 操作符¶

Cloud Firestore 是来自 Firebase 和 Google Cloud 的一个灵活、可扩展的数据库，适用于移动、Web 和服务器开发。与 Firebase Realtime Database 类似，它通过实时监听器使您的数据在客户端应用之间保持同步，并为移动和 Web 提供离线支持，以便您可以构建响应迅速的应用，而无论网络延迟或 Internet 连接如何。Cloud Firestore 还提供与其他 Firebase 和 Google Cloud 产品（包括 Cloud Functions）的无缝集成。

先决条件任务¶

要使用这些操作符，您必须执行以下几项操作

使用 Cloud Console 选择或创建 Cloud Platform 项目。

为您的项目启用结算，如 Google Cloud 文档中所述。

启用 API，如 Cloud Console 文档中所述。
通过 pip 安装 API 库。
pip install 'apache-airflow[google]'
详细信息请参阅安装。
设置 Google Cloud 连接.

导出数据库¶

使用 CloudFirestoreExportDatabaseOperator 操作符将 Google Cloud Firestore 中的全部或部分文档副本导出到 Google Cloud Storage。

tests/system/google/cloud/gcs/example_firestore.py[源代码]

export_database_to_gcs = CloudFirestoreExportDatabaseOperator(
    task_id="export_database_to_gcs",
    project_id=PROJECT_ID,
    body={"outputUriPrefix": EXPORT_DESTINATION_URL, "collectionIds": [EXPORT_COLLECTION_ID]},
)

您可以将 Jinja 模板与 body, gcp_conn_id, api_version, impersonation_chain 参数一起使用，这允许您动态确定值。

参考¶

有关更多信息，请查看