本地测试GCP Pub/Sub触发的Cloud Functions无响应问题排查

可能的原因及解决方法 #

1. 函数代码中主题路径存在语法错误

你的代码里主题路径的写法存在语法问题：

onMessagePublished("projects/"id-of-project"/topics/"my-topic"", ...)

双引号嵌套未转义，会导致JavaScript解析错误，或是生成不符合格式要求的主题路径，模拟器无法匹配到正确的主题。

解决方法：
使用模板字符串或正确的字符串拼接方式指定主题路径：

// 推荐：用环境变量或模板字符串动态传入项目ID
export const onPubSubMessage = onMessagePublished(`projects/${process.env.PROJECT_ID}/topics/my-topic`, (event) => {
    console.log('Message received')
    const message = event.data?.message;
    if (!message) {
        console.log("No message received");
        return;
    }

    const data = message.data ? Buffer.from(message.data, "base64").toString() : "{}";
    console.log("Message reçu :", data);
});

或直接写入正确的静态路径（替换your-project-id为实际项目ID）：

export const onPubSubMessage = onMessagePublished("projects/your-project-id/topics/my-topic", (event) => {
    // 函数逻辑保持不变
});

2. 消息发布到了线上Pub/Sub主题而非本地模拟器

你提到消息能在订阅中显示，但如果是发布到Google Cloud线上的主题，本地模拟器中的函数无法接收到消息。

解决方法：
发布消息时指定本地模拟器的Pub/Sub端点：

• 使用gcloud命令：

gcloud pubsub topics publish my-topic --message "测试消息" --endpoint=http://localhost:8085

• 或使用Firebase Functions Shell：
  1. 终端执行firebase functions:shell
  2. 在shell中执行：

pubsub.topic('my-topic').publish({data: Buffer.from('测试内容').toString('base64')})

3. 本地模拟器未正确创建函数对应的订阅

启动模拟器时，若控制台未输出类似Function onPubSubMessage subscribed to projects/xxx/topics/my-topic的日志，说明函数未成功绑定到主题。

解决方法：

• 确保代码编译无错误：检查npm run build或npm run build:watch的输出，修复所有语法错误；
• 重启模拟器：先停止模拟器，重新执行npm run build && firebase emulators:start --only functions,pubsub，确保构建完成后再启动模拟器；
• 手动创建订阅（若自动创建失败）：

gcloud pubsub subscriptions create my-topic-sub --topic my-topic --push-endpoint=http://localhost:5001/your-project-id/us-central1/onPubSubMessage --endpoint=http://localhost:8085

（替换your-project-id为实际项目ID，us-central1为函数部署区域）

4. 本地模拟器中目标主题不存在

若本地模拟器未创建my-topic主题，函数无法绑定到不存在的主题。

解决方法：
创建本地主题：

gcloud pubsub topics create my-topic --endpoint=http://localhost:8085

创建后可验证主题存在：

gcloud pubsub topics list --endpoint=http://localhost:8085

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