如何判断Google PubSub订阅在上下文取消后是否已创建？

当调用CreateSubscription时因上下文取消返回rpc error: code = Canceled desc = context canceled，由于分布式系统的最终一致性特性，订阅是否创建成功处于不确定状态。以下是更规范、可靠的处理方案，无需轮询或重复创建的复杂分支：

核心思路：利用幂等API保证最终状态 #

PubSub的API支持幂等操作，我们可以通过**"确保订阅存在 → 强制删除"**的两步流程，最终达到"目标订阅不存在"的确定性状态：

1. 确保订阅存在：使用新的、超时充足的Context，调用带"忽略已存在"选项的CreateSubscription。这一步的作用是：

   • 如果之前的创建已成功，调用不会报错，直接确认订阅存在；
   • 如果之前的创建未成功，会重新创建订阅；
   • 即便再次出现非致命错误（如临时网络波动），也不影响后续删除步骤的执行。

2. 强制删除订阅：调用DeleteSubscription，并忽略"订阅不存在"（NOT_FOUND）的错误。因为我们的目标是让订阅最终不存在，不管它原本是否存在，这个操作都能达到预期结果。

代码示例（Go客户端） #

import (
    "context"
    "errors"
    "log"
    "time"

    "cloud.google.com/go/pubsub"
    "google.golang.org/grpc/codes"
    "google.golang.org/grpc/status"
)

func cleanupPotentialSubscription(client *pubsub.Client, subID string, topicID string) error {
    // 创建新的Context，设置足够长的超时，避免再次被取消
    ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
    defer cancel()

    // 第一步：确保订阅存在（忽略已存在错误）
    _, err := client.CreateSubscription(ctx, subID, pubsub.SubscriptionConfig{
        Topic: client.Topic(topicID), // 复用之前创建订阅时指定的Topic
    }, pubsub.WithIgnoreAlreadyExists())

    // 仅处理严重错误，已存在/取消错误不影响后续删除
    if err != nil {
        if errors.Is(err, pubsub.ErrSubscriptionAlreadyExists) || status.Code(err) == codes.Canceled {
            log.Printf("subscription already exists or create was canceled, proceeding to delete")
        } else {
            log.Printf("failed to ensure subscription exists: %v, still attempting delete", err)
        }
    }

    // 第二步：删除订阅，忽略不存在的错误
    sub := client.Subscription(subID)
    deleteErr := sub.Delete(ctx)
    if deleteErr != nil {
        if status.Code(deleteErr) == codes.NotFound {
            // 订阅本来就不存在，清理完成
            return nil
        }
        return deleteErr
    }

    return nil
}

方案优势 #

• 避免轮询的不确定性：无需通过Exists轮询，减少API调用次数和延迟带来的误判；
• 利用API幂等性：通过忽略已存在和不存在的错误，保证操作的最终一致性；
• 逻辑简洁可靠：两步流程覆盖所有可能的场景，无需复杂的分支判断。

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