如何通过GCP服务实现Pub/Sub消息按国家代码路由？

问题描述 #

我有一个GCP Pub/Sub主题，外部应用会向该主题发布CustomerCreatedEvent类型的消息，流程如下：

external-app --> pub/sub

消息中包含国家代码，我希望根据这个代码将消息分流到两个不同的主题，比如美国客户的消息进入一个主题，英国客户的消息进入另一个主题，流程如下：

external-app --> pub/sub --> 根据国家代码路由

请问能否通过GCP服务实现这个需求？

方案1：Cloud Functions + Pub/Sub订阅 #

• 创建一个订阅绑定到接收CustomerCreatedEvent的原始主题
• 编写Cloud Functions函数，触发方式选择该Pub/Sub订阅
• 在函数内解析消息内容，提取国家代码（如US、GB）
• 根据代码将消息重新发布到对应的目标主题（例如customer-created-us、customer-created-gb）
• 转发成功后再确认原始消息，失败则让Pub/Sub自动重试

方案2：Dataflow流式处理管道 #

• 构建Dataflow流式管道，以原始Pub/Sub主题作为输入源
• 在管道中添加分支过滤逻辑，基于消息中的国家代码实现分流
• 将不同分支的消息分别写入对应的目标Pub/Sub主题
• 适合后续需要扩展复杂路由规则的场景，Dataflow支持更灵活的流式处理逻辑

注意事项 #

• 确保消息解析逻辑适配CustomerCreatedEvent的实际格式（如JSON、Protobuf）
• 为转发服务（Cloud Functions/Dataflow）配置目标主题的发布权限
• 可给分流后的主题创建独立订阅，供下游消费服务对接

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