Firebase Emulator Suite简单PubSub示例无法触发onPublish回调问题

• 导出语法错误：单JS模块不允许存在多个export default声明，你写的第二个HTTP云函数会覆盖前一个PubSub触发器函数，导致模拟器无法识别注册PubSub消费函数。
• PubSub客户端未指向本地模拟器：@google-cloud/pubsub客户端默认会连接GCP公网服务，未配置本地端点的情况下，哪怕本地启动了PubSub模拟器，消息也会发送到公网实例，或者无法被本地模拟器接收。

1. 修复导出语法 #

将两个云函数分别命名导出，不要使用重复的default导出：

// 接收主题消息
export const pubsubConsumer = functions.pubsub
  .topic(TOPIC_NAME)
  .onPublish((message, context) => {
    console.log(`got new message!!! ${JSON.stringify(message, null, 2)}`);
    return true;
  });

// 向主题发布消息
export const httpTestPublish = functions.https.onRequest(async (req, res) => {
  // 原有逻辑保持不变
})

2. 配置PubSub客户端连接本地模拟器 #

有两种可选方案，推荐用环境变量方案，无需修改业务代码即可兼容本地调试和云端部署：

方案A：环境变量配置（推荐） #

Firebase PubSub模拟器默认端口为8085，在云函数运行环境中添加环境变量PUBSUB_EMULATOR_HOST=localhost:8085即可，@google-cloud/pubsub客户端会自动识别该变量，连接本地模拟器而非公网。
你可以直接在启动模拟器前在终端执行：

export PUBSUB_EMULATOR_HOST=localhost:8085
firebase emulators:start --only functions,firestore,pubsub

方案B：手动修改客户端初始化参数 #

直接在初始化PublisherClient时指定本地模拟器端点：

const publisherClient = new v1.PublisherClient({
  projectId: process.env.GCLOUD_PROJECT,
  apiEndpoint: 'localhost:8085',
  ssl: false
});

启动模拟器后，查看控制台日志确认两个云函数都被成功加载，且PubSub触发器已注册到本地MY_TEST_TOPIC主题。再调用HTTP发布接口，即可触发onPublish回调，看到对应的日志输出。

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