如何不使用datastore_admin通过cron定时备份Datastore？

我来帮你搞定这个问题——既然datastore_admin即将被弃用，咱们可以改用官方推荐的Datastore Export API（也就是gcloud datastore export背后的底层API），结合定时任务来实现自动备份。下面给你两种实用的方案，你可以根据自己的现有架构选择：

方案一：Cloud Scheduler + Cloud Functions（轻量化推荐） #

这种方案不需要改动现有App Engine代码，用Serverless组件就能搞定，非常省心：

步骤1：创建Cloud Function执行备份 #

写一个简单的函数来调用Datastore Export API，以Python为例：

from google.cloud import datastore_admin_v1
import os

def export_datastore(event, context):
    # 初始化Datastore Admin客户端
    client = datastore_admin_v1.DatastoreAdminClient()
    # 获取当前项目ID（自动从环境变量读取）
    project_id = os.environ.get('GCP_PROJECT')
    # 替换成你的存储桶和要备份的实体类型
    bucket_name = "whitsend"
    target_kinds = ["LogTitle", "EventLog"]

    # 构造导出请求
    export_request = {
        "project_id": project_id,
        "output_url_prefix": f"gs://{bucket_name}/BackupToCloud",
        "entity_filter": {
            "kinds": target_kinds
        }
    }

    # 触发导出操作并等待完成
    operation = client.export_entities(request=export_request)
    operation.result()

部署这个函数时，记得给它的服务账号添加Datastore Admin和Storage Object Creator权限，不然没法完成备份操作。

步骤2：配置Cloud Scheduler定时触发 #

在Cloud Console里创建一个Cloud Scheduler任务：

• 目标类型选HTTP
• 填入Cloud Function的触发URL
• 请求方法选POST
• 调度频率设为every 12 hours（和你原来的配置一致）

这样就实现了定时自动备份，完全不需要依赖datastore_admin。

方案二：App Engine自定义Handler + 原cron.yaml #

如果你想继续用App Engine的cron.yaml，可以自己写一个Handler来替代原来的/_ah/datastore_admin/backup.create端点：

步骤1：添加自定义备份Handler #

在你的App Engine应用里新增一个Handler，比如用Flask框架的示例：

from flask import Flask
from google.cloud import datastore_admin_v1
import os

app = Flask(__name__)

@app.route('/backup-datastore')
def initiate_backup():
    client = datastore_admin_v1.DatastoreAdminClient()
    project_id = os.environ.get('GOOGLE_CLOUD_PROJECT')
    bucket_name = "whitsend"
    target_kinds = ["LogTitle", "EventLog"]

    export_request = {
        "project_id": project_id,
        "output_url_prefix": f"gs://{bucket_name}/BackupToCloud",
        "entity_filter": {
            "kinds": target_kinds
        }
    }

    operation = client.export_entities(request=export_request)
    operation.result()
    return "Backup started successfully", 200

if __name__ == '__main__':
    app.run(host='0.0.0.0', port=int(os.environ.get('PORT', 8080)))

步骤2：更新cron.yaml #

把原来的配置替换成指向自定义Handler：

- description: My Daily Backup
  url: /backup-datastore
  schedule: every 12 hours
  target: ah-builtin-python-bundle  # 保持你原来的服务目标即可

步骤3：配置权限 #

确保App Engine的默认服务账号拥有Datastore Admin和Storage Object Creator权限，这样才能执行导出操作。

注意事项 #

• 存储桶需要和你的Datastore实例处于同一区域，或者配置好跨区域访问权限
• 如果备份的数据量很大，记得调整Cloud Function的超时时间（最长支持9分钟），避免任务中途被终止
• 可以通过Cloud Monitoring监控备份任务的执行状态，确保备份正常完成

内容的提问来源于stack exchange，提问作者stack_user