如何缩放activejob-google_cloud_pubsub worker?

埃里尔·马里蒙

总览

我有一个使用gem activejob-google_cloud_pubsub的Rails ActiveJob 简短的用法教程)。我的应用程序已部署到ruby flex环境上的AppEngine。虽然我的应用程序可以按预期运行,但我很难扩展使用Google Cloud PubSub消息的辅助服务。gem的README文档提到了一种从终端而不是Rails应用程序中指定Worker的max_threads的方法。当我阅读gem的源代码时,我看到initializeworker的接受了该变量max_threads(默认为内核数)。问题是我看不到如何使用默认配置初始化工作程序,因此我可以增加线程数。

问题摘要:

1-如何activejob-google_cloud_pubsub使用更多线程初始化Worker?

2-不建议使用比计算机中的处理器更多的线程来初始化工作线程?

其他详情:

  • 我使用app.yaml之外的worker.yaml将工作程序部署在与Rails Server分开的服务上
  • 辅助服务已手动扩展到3个实例,但仍每秒仅处理10条消息(精简消息处理器,仅记录输出和返回)

任何有关如何扩展此类队列处理的输入都将有所帮助。

埃里尔·马里蒙

1-如何使用更多线程初始化activejob-google_cloud_pubsub Worker?

worker.yaml

--max_threads按照gem自述文件中的说明添加终端标志

runtime: ruby
env: flex
service: <xxx>
entrypoint: bundle exec activejob-google_cloud_pubsub-worker --max_threads=5
...

这将在每个实例中创建5个工作线程。默认值为逻辑核心数。

本文收集自互联网,转载请注明来源。

如有侵权,请联系[email protected] 删除。

编辑于
0

我来说两句

0条评论
登录后参与评论

相关文章

来自分类Dev

如何屏蔽 Google Service Worker?

来自分类Dev

如何使用Azure Worker Role和OWIN缩放SignalR

来自分类Dev

如何在Google App Engine上部署Celery Worker

来自分类Dev

hgearman worker 是如何工作的?

来自分类Dev

Google Cloud PubSub-如何将多个参数发送到Cloud Function

来自分类Dev

如何停止Azure Worker角色

来自分类Dev

如何在Service Worker中访问Web Worker?

来自分类Dev

如何使用Angular 的safety-worker.js 卸载Service Worker?

来自分类Dev

如何在Azure Cloud Service Worker角色-PAAS上监视本地存储磁盘空间

来自分类Dev

如何仅使用主题名称(而不是订阅名称)订阅Google Cloud pubsub?

来自分类Dev

如何通过Terraform使用服务帐户创建Google Cloud pubsub订阅?

来自分类Dev

如何在使用Service Worker时缓存Google Maps之类的API

来自分类Dev

如何在Service Worker中保留数据

来自分类Dev

如何从Web Worker访问chrome.history?

来自分类Dev

如何从内部阻止JS Web Worker?

来自分类Dev

如何在Web Worker中访问变量?

来自分类Dev

如何告诉Service Worker缓存哪些文件

来自分类Dev

如何在 Web Worker 中使用 PixiJS

来自分类Dev

如何在Google Cloud App Engine上使用PubSub创建订阅者,以通过Publisher从Google Cloud App Engine Flex收听消息?

来自分类Dev

如何使用celery worker从SQS轮询消息,消息为JSON格式,worker无法解码该格式

来自分类Dev

如何在Nginx中优化worker_processes和worker_connections?

来自分类Dev

如何将 booleon 从 Worker_ProgressChanged 传递回 Worker_DoWork

来自分类Dev

如何更改Google MyMaps iframe嵌入缩放?

来自分类Dev

如何保持Google地图的缩放级别?

来自分类Dev

如何保持Google地图的缩放级别?

来自分类Dev

如何更改Google Maps缩放控件样式?

来自分类Dev

并非由Google API请求触发的Service Worker提取事件

来自分类Dev

如何将current_user传递给Sidekiq的Worker

来自分类Dev

如何实现作为Web Worker的递归功能?

Related 相关文章

  1. 1

    如何屏蔽 Google Service Worker?

  2. 2

    如何使用Azure Worker Role和OWIN缩放SignalR

  3. 3

    如何在Google App Engine上部署Celery Worker

  4. 4

    hgearman worker 是如何工作的?

  5. 5

    Google Cloud PubSub-如何将多个参数发送到Cloud Function

  6. 6

    如何停止Azure Worker角色

  7. 7

    如何在Service Worker中访问Web Worker?

  8. 8

    如何使用Angular 的safety-worker.js 卸载Service Worker?

  9. 9

    如何在Azure Cloud Service Worker角色-PAAS上监视本地存储磁盘空间

  10. 10

    如何仅使用主题名称(而不是订阅名称)订阅Google Cloud pubsub?

  11. 11

    如何通过Terraform使用服务帐户创建Google Cloud pubsub订阅?

  12. 12

    如何在使用Service Worker时缓存Google Maps之类的API

  13. 13

    如何在Service Worker中保留数据

  14. 14

    如何从Web Worker访问chrome.history?

  15. 15

    如何从内部阻止JS Web Worker?

  16. 16

    如何在Web Worker中访问变量?

  17. 17

    如何告诉Service Worker缓存哪些文件

  18. 18

    如何在 Web Worker 中使用 PixiJS

  19. 19

    如何在Google Cloud App Engine上使用PubSub创建订阅者,以通过Publisher从Google Cloud App Engine Flex收听消息?

  20. 20

    如何使用celery worker从SQS轮询消息,消息为JSON格式,worker无法解码该格式

  21. 21

    如何在Nginx中优化worker_processes和worker_connections?

  22. 22

    如何将 booleon 从 Worker_ProgressChanged 传递回 Worker_DoWork

  23. 23

    如何更改Google MyMaps iframe嵌入缩放?

  24. 24

    如何保持Google地图的缩放级别?

  25. 25

    如何保持Google地图的缩放级别?

  26. 26

    如何更改Google Maps缩放控件样式?

  27. 27

    并非由Google API请求触发的Service Worker提取事件

  28. 28

    如何将current_user传递给Sidekiq的Worker

  29. 29

    如何实现作为Web Worker的递归功能?

热门标签

归档