Google Cloud Kubernetes 上任务队列的替代方案

2024-05-09

我发现任务队列主要用于App Engine标准环境。我正在将现有服务从 App Engine 迁移到 Kubernetes。任务队列的一个好的替代方案是什么?推送队列是当前正在使用的队列。

我在线阅读文档并浏览了此链接:何时使用 PubSub 与任务队列 https://groups.google.com/forum/#!topic/google-appengine/IcIjLfgnNXs但对于 Kubernetes 上的 Pub/Sub 是否是一个好的替代方案,还没有明确的答案。

Edit:

我当前的用例是,服务对一组 ID 执行类似的任务,并且某些任务需要一些时间才能完成,因此队列将接受此任务并处理它,同时服务可以并行执行其他操作。虽然我们主要需要发布者和订阅者,但服务本身有一些任务需要保持并行处理!


我会想云发布/订阅 https://cloud.google.com/pubsub/是一个很棒的消息队列工具。它与您部署/运行服务的方式正交,无论是使用 Kubernetes 还是其他方式。

有很多关于在 GCP 上将 pubsub 与 Kubernetes 结合使用的相关文档,例如这一页 https://cloud.google.com/kubernetes-engine/docs/tutorials/connect-to-cloud-pubsub-via-service-broker.

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

Google Cloud Kubernetes 上任务队列的替代方案 的相关文章

  • 适用于 python2.7 谷歌应用引擎的云任务 API

    我在 Google App Engine Python 2 7 下创建了一个项目 我使用创建了一些任务queue yaml并与部署glcoud命令 当我转到 任务队列 部分下的 Google App Engine 控制台时 它会重定向到 云
  • 如何读取大型平面文件

    我有一个平面文件 其中包含 339276 行文本 大小为 62 1 MB 我试图读入所有行 根据我所拥有的某些条件解析它们 然后将它们插入数据库 我最初尝试使用 bufio Scan 循环和 bufio Text 来获取该行 但缓冲区空间不
  • 使用 Python37 运行时通过 Cloud Functions 生成缩略图

    我有一个由 Firebase 存储触发的 Google Cloud 函数 我想生成缩略图 虽然 Node js 文档有一个使用 ImageMagick 的示例 https cloud google com functions docs tu
  • 解压文件的简单方法

    有没有一种简单的方法可以用 Go 解压文件 现在我的代码是 func Unzip src dest string error r err zip OpenReader src if err nil return err defer r Cl
  • 如何更改Firebase默认存储桶?

    我有2个存储桶 一个来自Google云存储 一个由firebase创建 firebase创建的存储桶是默认的 我想更改默认存储桶并删除firebase创建的存储桶 您无法从 Firebase 控制台执行此操作 您需要转到 Google Cl
  • 实现具有更广泛方法签名的接口

    在Go中 是否有一种方法可以使用方法来实现接口 其中实现中相应方法的返回类型 比 预期返回类型 更宽 这很难解释 所以这里有一个例子 在 Go Playground 中运行以下示例代码时出现此错误 prog go 36 14 cannot
  • GoLang 中的 HTML 部分

    我刚刚开始使用 Go 我想用它创建一个网络应用程序 我现在尝试的是以handlebarsjs 式的方式使用模板 我想将页眉和页脚从主页中取出 以便可以将它们注入到每个网页上 我当前的设置应该是解析主页 页眉和页脚 HTML 文件并缓存它们
  • Google Cloud Stackdriver 监控计算引擎磁盘使用情况

    我最近已经启动并运行了 Google 计算引擎实例 我探索了 Google Cloud stackdriver 用于监控 CPU 使用情况等 我已将 Stackdriver 代理安装到其中一个 Compute Engine 实例上进行测试
  • 我可以强制 Firestore 文档具有特定类型或数据模型(即静态类型)吗?

    例如 如果我有一个如下所示的 Firestore 文档 threadId abc authorId abc content blah blah blahh 如果我不小心编写了一些添加另一个字段的代码 我可以让 Firebase 抛出错误吗
  • Go 编译器有窗口化设置选项吗?

    我正在使用 Go 6g 编译 GTK 应用程序 我想知道是否有编译器 链接器选项使其成为 Windows 可执行文件而不是控制台可执行文件 MinGW 有一个 mwindows 选项来实现此目的 目前我必须使用十六进制编辑器手动更改 PE
  • 我刚刚被收取 134.53 美元的 Google 云托管 DNS 费用 [已关闭]

    Closed 这个问题不符合堆栈溢出指南 help closed questions 目前不接受答案 我知道这不是它的地方 但谷歌云绝对没有任何指南来解释为什么我要为他们托管的域名收取那么多费用 我需要了解发生了什么 这样我明天就不会再收费
  • 从 Cloud Run 实例调用 Google Cloud API 的延迟

    当我出于某种原因从 Cloud Run 实例调用其他云 API 时 响应会出现巨大的延迟 一切都在 1 个项目内进行 即使从本地计算机调用也更快 几秒钟 但部署在云中 某些请求需要几分钟才能完成 据我所知 它与所有 API 相关 除了 Fi
  • 我可以在私有 GCP 网络子网中启动 Google 容器引擎 (GKE) 吗?

    我正在尝试在私有 GCP 网络子网中启动 Google 容器引擎 GKE 我创建了自定义 Google Cloud VPC 然后我也在该 VPC 下创建了自定义专用网络访问子网 1 当我使用私有子网创建 GKE 集群时 我的 Kuberne
  • 为什么 DER ASN.1 大整数的解组在 Golang 中仅限于 SEQUENCE?

    我希望能够使用encoding asn1 包从 DER 文件中解组一个大整数 但它看起来只适用于整数序列 例如 这不起作用 这很奇怪 因为 Big Int 的编组效果很好 https play golang org p Wkj0jAA6bp
  • go json marshal 的默认大小写选项?

    我有以下结构要导出为 json type ExportedIncident struct Title string json title Host string json host Status string json status Dat
  • 运行最新版本时没有“最新”消息?

    我正在尝试使用Sparkle https sparkle project org与 Qt Go 的绑定 https github com therecipe qt app 闪光 m import
  • 从 Golang 调用 C 函数

    我想在 Golang 中编写控制器逻辑并处理 json 和数据库 同时在 C 中使用我的数学处理模型 在我看来 调用 C 函数的开销必须尽可能低 就像设置寄存器 rcx rdx rsi rdi 一样 执行一些操作fastcall 并获取 r
  • Google 计算负载均衡器在 DELETE 时抛出 400 Bad Request

    我通过实例模板创建了一个实例组 并将该实例组与 http 负载均衡器使用的后端服务对齐 现在 当我从我创建的实例组中打开实例虚拟机的 URL 时 我可以执行以下操作GET POST and DELETE请求和所有请求都很快 一切都按预期进行
  • App Engine Flex 服务正在运行但找不到

    如何关闭我已删除且无法访问的 App Engine Flex 服务 昨天 我部署了一项新的 App Engine Flex 服务 然后将其删除 无论出于何种原因 该服务在一天后仍在运行 我可以通过查看日志查看器来确认它仍在运行并生成日志 当
  • Bigtable 性能影响列族

    我们目前正在调查使用多个列族对 bigtable 查询性能的影响 我们发现将列拆分为多个列族并不会提高性能 有人有过类似的经历吗 有关我们的基准设置的更多详细信息 此时 生产表中的每一行包含大约 5 列 每列包含 0 1 到 1 KB 的数

随机推荐