Google Cloud Firestore 运算符¶

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

先决条件任务¶

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

使用Cloud 控制台选择或创建 Cloud Platform 项目。

为你的项目启用帐单，如Google Cloud 文档中所述。

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

导出数据库¶

使用 CloudFirestoreExportDatabaseOperator 运算符可将 Google Cloud Firestore 中所有文档或部分文档的副本导出到 Google Cloud Storage。

tests/system/providers/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 参数一起使用，它允许你动态确定值。

参考¶

有关更多信息，请参阅