如何提取背景事件？Pub/Sub触发Cloud Function报错求助

错误unable to extract background event from {...}的核心原因是：你启用了Pub/Sub推送订阅的Push payload unwrapping功能，此时推送的请求体直接是原始的消息JSON内容，而非CloudEvents格式结构，但你的函数注册的是CloudEvent类型处理函数，Functions Framework尝试将请求解析为CloudEvent失败，从而抛出该错误。

有两种可行修复方式，可根据需求选择：

方案1：关闭Push payload unwrapping功能 #

若想继续使用CloudEvent类型函数，需在Pub/Sub订阅配置中关闭Push payload unwrapping。关闭后推送的请求会是标准CloudEvent格式，包含data字段包裹消息内容，现有代码即可正常解析。

方案2：将函数改为HTTP类型处理（适配当前Unwrapping配置） #

因为已启用Unwrapping，直接将函数改为HTTP类型接收原始JSON payload即可，修改后的代码如下：

package functions

import (
    "context"
    "encoding/json"
    "log"
    "net/http"

    "github.com/Capstone/models"
    "github.com/GoogleCloudPlatform/functions-framework-go/functions"
)

func init() {
    // 注册HTTP函数替代CloudEvent函数
    functions.HTTP("StoreAuditRecords", StoreAuditRecords)
}

func StoreAuditRecords(w http.ResponseWriter, r *http.Request) {
    ctx := r.Context()

    // 直接解析请求体的JSON内容
    var auditRecord models.AuditRecord
    if err := json.NewDecoder(r.Body).Decode(&auditRecord); err != nil {
        log.Printf("Error decoding request body: %v", err)
        w.WriteHeader(http.StatusBadRequest)
        return
    }

    // 存储到Firestore
    _, _, err := firestoreClient.Collection("audit-records").Add(ctx, auditRecord)
    if err != nil {
        log.Printf("Error storing data to Firestore: %v", err)
        w.WriteHeader(http.StatusInternalServerError)
        return
    }

    w.WriteHeader(http.StatusOK)
}

修改要点： #

• 将functions.CloudEvent替换为functions.HTTP注册函数
• 函数参数改为http.ResponseWriter和*http.Request
• 直接从r.Body解析JSON，无需处理CloudEvent的data字段

1. 重新部署修改后的Cloud Function
2. 向Pub/Sub主题发布测试消息，确认函数能正常接收并存储到Firestore集合中

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