Firebase Cloud Function执行正常但无法向Pub/Sub Topic推送消息

你提到Cloud Function能正常触发，但用gcloud pubsub subscriptions pull --auto-ack MySub收不到消息，这里最核心的问题大概率是混淆了Firebase Cloud Messaging（FCM）主题和Google Cloud Pub/Sub的Topic，我整理了具体的排查点和解决办法：

1. 核心误解：FCM主题 ≠ Cloud Pub/Sub Topic #

你的代码里调用的admin.messaging().sendToTopic("topic", payload)是FCM的API，它的作用是给订阅了该FCM主题的移动/网页客户端推送通知，不会把消息发送到Cloud Pub/Sub的Topic里。这是两个完全独立的服务，所以你用Pub/Sub的订阅自然收不到消息。

如果你的目标是向Cloud Pub/Sub的Topic发送消息，需要改用Cloud Pub/Sub的官方客户端库，修正后的代码如下：

const admin = require('firebase-admin');
const { PubSub } = require('@google-cloud/pubsub');

admin.initializeApp();
const pubsub = new PubSub();

exports.createNotification = functions.firestore
  .document('sensor-readings/{sensorId}')
  .onCreate(async (snap, context) => {
    // 构造Pub/Sub消息，可传递传感器相关结构化内容
    const messagePayload = {
      data: {
        title: 'New Sensor Reading',
        body: 'A new sensor reading has been added',
        sensorData: JSON.stringify(snap.data())
      }
    };

    try {
      const messageId = await pubsub.topic('topic').publishMessage(messagePayload);
      console.log(`Message ${messageId} published to Pub/Sub Topic`);
      return messageId;
    } catch (error) {
      console.error('Error publishing message:', error);
      throw error;
    }
  });

2. 确认订阅与Topic的关联 #

如果已经改用Pub/Sub API，还要检查：

• 你测试的订阅MySub是否确实关联了代码里的"topic"这个Topic。可以用命令gcloud pubsub subscriptions describe MySub查看它的topic字段，确认名称完全一致（注意大小写敏感）。
• 确认topic这个Topic已存在，用gcloud pubsub topics list可列出项目下所有Pub/Sub Topic。

3. 检查Cloud Function的权限 #

Cloud Function的默认服务账号需要拥有Pub/Sub Publisher权限才能发送消息：

• 打开Google Cloud控制台的IAM页面，找到你的Cloud Function对应的服务账号（格式通常是PROJECT_ID@appspot.gserviceaccount.com）。
• 给该账号添加Pub/Sub Publisher角色，或用命令行配置：

gcloud projects add-iam-policy-binding YOUR_PROJECT_ID \
  --member=serviceAccount:YOUR_PROJECT_ID@appspot.gserviceaccount.com \
  --role=roles/pubsub.publisher

4. 查看Function执行日志排查隐性错误 #

即使Function显示“执行成功”，也可能在发送消息环节出现隐性错误：

• 打开Firebase控制台的Functions页面，找到createNotification函数，点击“查看日志”。
• 检查是否有报错信息，比如权限不足、Topic不存在、消息格式错误等，这些都会导致消息无法正常发布。

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