如何在Cloud Run服务中合理初始化Pub/Sub订阅？

针对你遇到的重复调用createSubscription报错的问题，这里有几个实用方案，比无脑吞错误更靠谱：

方案1：先检查订阅是否存在，再决定是否创建 #

核心思路是先尝试获取目标订阅，只有当订阅确实不存在时才执行创建操作，避免重复调用报错。

以Node.js SDK为例，代码可以这么写：

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

async function initSubscription(topicName, subscriptionName) {
  try {
    // 尝试获取订阅，验证是否存在
    await pubsub.subscription(subscriptionName).get();
    console.log(`订阅 ${subscriptionName} 已存在，跳过创建`);
  } catch (err) {
    // 只处理"订阅不存在"的错误（gRPC错误码为5）
    if (err.code === 5) {
      await pubsub.topic(topicName).createSubscription(subscriptionName, {
        // 根据你的需求配置订阅参数，比如推送端点、确认超时等
        pushConfig: {
          pushEndpoint: 'https://your-cloud-run-service.run.app/pubsub/push'
        },
        ackDeadlineSeconds: 60
      });
      console.log(`订阅 ${subscriptionName} 创建成功`);
    } else {
      // 其他错误（比如权限不足、参数错误）直接抛出，不要忽略
      throw err;
    }
  }
}

需要确保Cloud Run的服务账号拥有pubsub.subscriptions.get和pubsub.subscriptions.create的权限。

方案2：把订阅创建移到部署流程中 #

如果你的项目有CI/CD部署流程，完全可以把订阅创建从服务启动逻辑中剥离，用部署工具提前创建好订阅。

比如用gcloud命令行在部署Cloud Run前执行：

gcloud pubsub subscriptions create your-subscription-name \
  --topic your-topic-name \
  --push-endpoint=https://your-cloud-run-service.run.app/pubsub/push \
  --ack-deadline=60

也可以用Terraform、Cloud Deployment Manager等基础设施即代码工具来管理订阅，好处是订阅配置和服务代码解耦，服务启动时直接消费即可，不用处理初始化逻辑。

方案3：合理使用try/catch（并非不可取） #

如果不想加额外的检查逻辑，直接用try/catch也没问题，但必须只忽略特定错误，不能吞掉所有异常。比如只捕获“订阅已存在”的错误，其他如权限不足、参数错误等异常正常抛出，避免隐藏问题。

这种方式代码更简洁，但要准确识别对应的错误码（不同语言SDK的错误码可能略有差异，比如Java中NOT_FOUND的状态码是404）。

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