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]'有关安装的详细信息,请参阅。
导出数据库¶
使用 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
参数一起使用,从而动态确定值。
参考¶
更多信息,请查阅