跳至主要内容
Google Cloud
文档 技术领域
  • AI 和机器学习
  • 应用开发
  • 应用托管
  • 计算
  • 数据分析和流水线
  • 数据库
  • 分布式云、混合云和多云
  • 生成式 AI
  • 行业解决方案
  • 网络
  • 可观测性和监控
  • 安全
  • Storage
跨产品工具
  • 访问权限和资源管理
  • 费用和用量管理
  • Google Cloud SDK、语言、框架和工具
  • 基础架构即代码
  • 迁移
相关网站
  • Google Cloud 首页
  • 免费试用和免费层级
  • 架构中心
  • 博客
  • 联系销售团队
  • Google Cloud 开发者中心
  • Google 开发者中心
  • Google Cloud Marketplace
  • Google Cloud Marketplace 文档
  • Google Cloud Skills Boost
  • Google Cloud Solution Center
  • Google Cloud 支持团队
  • Google Cloud Tech YouTube 频道
/
  • English
  • Deutsch
  • Español – América Latina
  • Français
  • Indonesia
  • Italiano
  • Português – Brasil
  • 中文 – 简体
  • 中文 – 繁體
  • 日本語
  • 한국어
控制台 登录
  • Pub/Sub
概览 指南 参考文档 示例 资源
联系我们 免费开始使用吧
Google Cloud
  • 文档
    • 概览
    • 指南
    • 参考文档
    • 示例
    • 资源
  • 技术领域
    • 更多
  • 跨产品工具
    • 更多
  • 相关网站
    • 更多
  • 控制台
  • 联系我们
  • 免费开始使用吧
  • Discover
  • 产品概览
  • 选择 Pub/Sub 或 Cloud Managed Service for Apache Kafka
  • 选择 Pub/Sub 或 Cloud Tasks
  • Pub/Sub 架构概览
  • Pub/Sub 可靠性
  • Pub/Sub 精简版文档
  • 开始使用
  • Pub/Sub 服务概览
  • 使用客户端库发布和订阅
  • 使用 gcloud CLI 发布和订阅
  • 使用控制台发布和订阅
  • 保护和控制访问权限
  • 对 Pub/Sub 进行身份验证
  • Pub/Sub 的访问权限控制
  • 配置消息加密
  • 配置消息存储政策
  • 发布消息
  • 发布消息概览
  • 创建主题
    • 标准主题
    • Amazon Kinesis Data Streams 导入主题
    • Cloud Storage 导入主题
    • Azure 事件中心导入主题
    • Amazon Managed Streaming for Apache Kafka (MSK) 导入主题
    • Confluent Cloud 导入主题
  • 管理主题
    • 更改主题类型
    • 删除主题
    • 列出主题
  • 发布消息
  • 配置发布选项
    • 压缩消息
    • 重试请求
    • 流控制
    • 并发控制
    • 批量消息传递
  • 使用架构
    • 架构概览
    • 创建架构
    • 将架构与主题相关联
    • 向具有架构的主题发布消息
    • 管理架构
      • 提交架构修订版本
      • 删除架构
      • 删除架构修订版本
      • 列出架构
      • 列出架构的修订版本
      • 回滚架构修订版本
      • 查看架构详情
      • 验证架构定义
      • 验证消息是否符合架构要求
  • 使用 SMT
    • SMT 概览
    • UDF 概览
    • 选择主题或订阅 SMT
    • 创建主题 SMT
    • 更新主题 SMT
    • 删除主题 SMT
  • 发布方面的最佳实践
  • 接收消息
  • 订阅概览
  • 选择订阅类型
  • 订阅的运作方式
    • 拉取订阅
    • 推送订阅
    • BigQuery 订阅
    • Cloud Storage 订阅
  • 创建订阅
    • 拉取订阅
    • 推送订阅
    • BigQuery 订阅
    • Cloud Storage 订阅
  • 管理订阅
    • 更改订阅类型
    • 列出订阅
    • 将订阅与主题分离
    • 删除订阅
  • 使用 SMT
    • SMT 概览
    • UDF 概览
    • 选择主题或订阅 SMT
    • 创建订阅 SMT
    • 更新订阅 SMT
    • 删除订阅 SMT
  • 配置投放选项
    • 流控制
    • 处理消息故障
    • 重放和完全清除消息
    • 租赁管理
    • 有序消息
    • 过滤消息
    • 验证架构
    • 仅传送一次
    • 并发控制
    • 推送订阅身份验证
    • 载荷解封
  • 订阅方面的最佳实践
  • 监控和审核
  • 在 Cloud Monitoring 中监控 Pub/Sub
  • 监控 Pub/Sub 中的主题
  • 监控 Pub/Sub 中的订阅
  • 查看 Pub/Sub 审核日志
  • 查看带标签的 Pub/Sub 报告
  • 使用 OpenTelemetry 跟踪
  • 扩缩指标的最佳实践
  • 构建 Pub/Sub 系统
  • 构建一对多 Pub/Sub 系统
  • 使用跳转功能重放消息
  • 从 Kafka 迁移到 Pub/Sub
  • 测试和集成
  • 使用 Pub/Sub 模拟器在本地进行测试
  • 将 Pub/Sub 连接到 Apache Kafka
  • Spring 应用中的 Pub/Sub
  • Pub/Sub 与 Cloud Run
  • 将 Pub/Sub 与 Cloud Functions 集成
    • Cloud Functions 中的 Pub/Sub 触发器
    • 光学字符识别 (OCR)
  • 将 Pub/Sub 与 Dataflow 集成
    • 使用 Dataflow 将数据从 Pub/Sub 流式传输到 Cloud Storage
    • 从 Pub/Sub 流式传输到 BigQuery
    • 使用 Pub/Sub 和 Dataflow 进行流式传输
    • 使用 Pub/Sub 和 Dataflow 将日志流式传输到 Splunk
  • 在 App Engine 中处理消息
  • 通过 WebSocket 流式传输 Pub/Sub 消息
  • 排查问题
  • 常规问题排查
  • 使用审核日志进行问题排查
  • 问题排查主题
    • 排查标准主题
    • 排查导入主题问题
      • 使用平台日志排查导入主题的问题
      • 排查 Amazon Kinesis Data Streams 导入主题的问题
      • 排查 Cloud Storage 导入问题
      • 排查 Azure 事件中心导入主题的问题
      • 排查 Amazon MSK 导入主题的问题
      • 排查 Confluent Cloud 导入主题的问题
  • 排查订阅问题
    • 排查拉取订阅问题
    • 排查推送订阅问题
    • 排查推送载荷解封问题
    • 排查 BigQuery 订阅问题
    • 排查 Cloud Storage 订阅问题
    • 使用 SMT 排查订阅问题
  • 使用 GCPDiag 进行问题排查
    • 使用 GCPDiag 排查拉取订阅问题
  • 代码示例
  • Pub/Sub 代码示例
  • AI 和机器学习
  • 应用开发
  • 应用托管
  • 计算
  • 数据分析和流水线
  • 数据库
  • 分布式云、混合云和多云
  • 生成式 AI
  • 行业解决方案
  • 网络
  • 可观测性和监控
  • 安全
  • Storage
  • 访问权限和资源管理
  • 费用和用量管理
  • Google Cloud SDK、语言、框架和工具
  • 基础架构即代码
  • 迁移
  • Google Cloud 首页
  • 免费试用和免费层级
  • 架构中心
  • 博客
  • 联系销售团队
  • Google Cloud 开发者中心
  • Google 开发者中心
  • Google Cloud Marketplace
  • Google Cloud Marketplace 文档
  • Google Cloud Skills Boost
  • Google Cloud Solution Center
  • Google Cloud 支持团队
  • Google Cloud Tech YouTube 频道
此页面由 Cloud Translation API 翻译。
  • Home
  • 文档
  • Pub/Sub
  • Documentation
  • 指南

将 Pub/Sub 与 Dataflow 搭配使用
使用集合让一切井井有条 根据您的偏好保存内容并对其进行分类。

您可以使用 Pub/Sub 和 Dataflow 将消息从 Pub/Sub 流式传输到 Cloud Storage。

如需了解如何组合使用这些服务,请参阅使用 Pub/Sub 进行流式传输。

如未另行说明,那么本页面中的内容已根据知识共享署名 4.0 许可获得了许可,并且代码示例已根据 Apache 2.0 许可获得了许可。有关详情,请参阅 Google 开发者网站政策。Java 是 Oracle 和/或其关联公司的注册商标。

最后更新时间 (UTC):2025-06-02。

  • 为什么选择 Google

    • 选择 Google Cloud
    • 信任与安全
    • 现代基础架构云
    • 多云
    • 全球基础架构
    • 客户和案例研究
    • 分析师报告
    • 白皮书
  • 产品和价格

    • 查看所有产品
    • 查看所有解决方案
    • Google Cloud 创业公司计划
    • Google Cloud Marketplace
    • Google Cloud 价格
    • 与销售人员联系
  • 支持

    • Google Cloud 社区
    • 支持
    • 版本说明
    • 系统状态
  • 资源

    • GitHub
    • Google Cloud 使用入门
    • Google Cloud 文档
    • 代码示例
    • 云架构中心
    • 培训和认证
    • 开发者中心
  • 互动

    • 博客
    • 活动
    • X (Twitter)
    • Google Cloud 在 YouTube 上的频道
    • YouTube 上的 Google Cloud Tech
    • 成为合作伙伴
    • Google Cloud Affiliate Program
    • 媒体资讯角
  • 关于 Google
  • 隐私权政策
  • 网站条款
  • Google Cloud 条款
  • Manage cookies
  • 环境行动的第三个十年:加入我们
  • 订阅 Google Cloud 简报 订阅
  • English
  • Deutsch
  • Español – América Latina
  • Français
  • Indonesia
  • Italiano
  • Português – Brasil
  • 中文 – 简体
  • 中文 – 繁體
  • 日本語
  • 한국어