如何获取Google Pubsub推送订阅被第三方端点拒绝的响应体内容？

目前Google Pubsub本身不会自动保存第三方端点返回的响应体，但可以通过以下两种方式实现需求：

• 使用Cloud Functions作为中间层代理

  1. 创建Cloud Function作为Pubsub推送的目标端点，替代直接指向第三方服务
  2. 在Cloud Function内将Pubsub请求转发给第三方端点
  3. 捕获第三方返回的响应体，将其写入Cloud Logging（原Stackdriver），或存储到Cloud Storage/BigQuery中留存
  4. 根据第三方的响应结果，向Pubsub返回对应状态码：第三方处理成功则返回200，失败则返回非200状态码，触发Pubsub重试或死信逻辑
     示例伪代码（Node.js）：

  exports.pubsubProxy = async (req, res) => {
    const pubsubMessage = req.body.message;
    const payload = JSON.parse(Buffer.from(pubsubMessage.data, 'base64').toString());
    
    // 转发请求到第三方端点
    const thirdPartyResponse = await fetch('https://your-third-party-endpoint', {
      method: 'POST',
      body: JSON.stringify(payload),
      headers: { 'Content-Type': 'application/json' }
    });
    
    // 捕获并记录响应体
    const responseBody = await thirdPartyResponse.text();
    console.log(`Third party response: ${responseBody}, status: ${thirdPartyResponse.status}`);
    
    // 根据第三方响应返回状态给Pubsub
    if (thirdPartyResponse.ok) {
      res.status(200).send('Success');
    } else {
      res.status(thirdPartyResponse.status).send(responseBody);
    }
  };
  

• 利用Pubsub订阅的日志增强配置
  虽然Pubsub默认不记录响应体，但可通过配置订阅日志选项结合Cloud Logging过滤尝试获取细节：

  1. 将Pubsub订阅的日志级别设置为DEBUG
  2. 进入Cloud Logging，使用过滤条件：resource.type="pubsub_subscription" AND logName:"projects/[你的项目ID]/logs/cloudaudit.googleapis.com%2Fdata_access"
  3. 检查日志条目是否包含第三方响应的相关信息（注：这种方式不一定能获取完整响应体，取决于Pubsub的日志覆盖范围）

两种方式中，中间层代理的方式最可靠，能完全控制请求转发和响应体的捕获存储，适合需要详细排查错误的场景。

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