Google Storage存储桶文件变更时调用应用API的实现咨询

这个需求可以通过GCS事件通知+Cloud Functions的原生组合直接实现，无需复杂的Pub/Sub手动对接，具体操作步骤如下：

前置准备 #

• 已开通Google Cloud Storage、Cloud Functions、Cloud Build服务（Cloud Functions部署依赖Cloud Build完成构建）
• 提前获取目标应用API的调用地址、鉴权规则（如有）
• 已创建好用于接收上传文件的GCS目标存储桶

步骤1：创建绑定GCS事件的Cloud Functions #

• 进入Cloud Functions控制台，点击「创建函数」
• 触发类型选择Cloud Storage，事件类型根据需求选择：仅监听新文件上传选最终化/创建，需要覆盖更新、删除等全量变更事件可按需勾选对应选项
• 存储桶选择你要监听的目标桶，勾选触发权限确认项后进入下一步
• 运行时环境选择你熟悉的技术栈即可，Node.js、Python、Go、Java均支持

步骤2：编写函数核心逻辑 #

核心逻辑只需要实现两个能力：从事件参数中提取上传文件名、调用指定API传递文件名，以下是Python版本的示例代码：

import requests

def gcs_change_handler(event, context):
    # 从GCS事件参数中提取文件名、桶名等信息
    file_name = event["name"]
    bucket_name = event["bucket"]
    print(f"监听到存储桶{bucket_name}有文件变更，文件名：{file_name}")

    # 调用目标应用API
    target_api_url = "替换为你的应用API地址"
    payload = {
        "file_name": file_name,
        # 可追加其他需要传递的业务参数
    }
    headers = {
        "Content-Type": "application/json",
        # 如果API需要鉴权，在这里补充Authorization等请求头
    }

    resp = requests.post(target_api_url, json=payload, headers=headers)
    # 可自定义错误处理、重试逻辑
    if resp.status_code != 200:
        print(f"API调用失败，状态码：{resp.status_code}，错误信息：{resp.text}")
    else:
        print(f"API调用成功，返回结果：{resp.text}")

• 把函数依赖的第三方库写到对应配置文件中，比如Python环境的requirements.txt需要添加requests>=2.31.0

步骤3：部署测试 #

• 确认配置无误后点击部署，等待函数部署完成
• 测试流程：往目标GCS存储桶上传一个测试文件，查看Cloud Functions运行日志，确认触发成功、API调用正常即可

可选可靠性优化 #

如果你担心目标API临时不可用导致事件丢失，可以先把GCS事件通知配置为发送到Pub/Sub主题，再用Cloud Functions订阅该Pub/Sub主题，利用Pub/Sub的重试、死信队列能力保证事件不会丢失。

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