Google Cloud Firestore Operator¶

Cloud Firestore 是 Firebase 和 Google Cloud 提供的一个灵活、可扩展的数据库，适用于移动、Web 和服务器开发。与 Firebase Realtime Database 一样，它通过实时监听器在客户端应用程序之间同步数据，并为移动和 Web 提供离线支持，这样你就可以构建响应式应用程序，无论网络延迟或 Internet 连接如何都能正常工作。Cloud Firestore 还与包括 Cloud Functions 在内的其他 Firebase 和 Google Cloud 产品无缝集成。

先决条件任务¶

要使用这些 Operator，您必须完成以下几项操作

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

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

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

导出数据库¶

使用 CloudFirestoreExportDatabaseOperator Operator 执行从 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 参数一起使用，从而动态确定值。

参考¶

更多信息，请查阅