SuperAPI AI 工具集

gcp-pubsub

编程与开发

查看项目

更新于 10-15 20:34

技能介绍

用途:用 Python 构建生产级事件驱动系统,通过 Google Cloud Pub/Sub 实现服务间可靠消息传递,支持至少一次投递保证与高吞吐场景,并提供本地模拟器开发方式。

主要能力:创建主题与订阅;发布消息(含消息属性);订阅并处理消息,可用 ack/nack 与流控(如 max_messages、max_bytes);配置死信队列(DeadLetterPolicy、max_delivery_attempts)与重试策略(RetryPolicy、最小/最大退避);实现幂等处理避免重复;使用模拟器本地开发;日志与订阅信息监控。

使用方式:安装依赖 pip install google-cloud-pubsub,并通过 gcloud auth application-default login 认证;生产环境可用 export GOOGLE_APPLICATION_CREDENTIALS="/path/to/service-account-key.json"。模拟器需 gcloud components install pubsub-emulator 与 gcloud beta emulators pubsub start,再设置 export PUBSUB_EMULATOR_HOST=localhost:8085。

适用场景:事件驱动架构、服务间消息队列、至少一次投递、每秒 1000+ 消息高吞吐系统、失败消息处理与本地开发。

限制与要求:需 Python 3.7+、google-cloud-pubsub>=2.18.0、已启用 Pub/Sub API 的 GCP 项目与相应 IAM 权限(publisher、subscriber、admin)。具体收费与价格暂未提供。更多生产模式参见 references/detailed-guide.md 与 examples/examples.md。