使用服务器启动代码或初始化代码拉取 SQS 消息 (Ruby Rails)

发布于 2024-11-06 09:04:52 字数 256 浏览 1 评论 0原文

我正在实施 Amazon SQS 服务来处理大量消息以将其保存在数据库中。我可以使用 right_aws gem 推送消息。我还可以通过为 gem 提供的示例来提取消息。

我最终可能会拥有多个 ruby​​/rails 服务器拉取和处理消息的实例(使用 SQS 的锁定和超时功能)。我想探索使用一些启动脚本提取消息的机会,或者在启动 ruby​​/rails 服务器期间进行初始化,并使组件始终运行并处理消息,直到服务器停止。

有人可以分享一些关于如何实施的参考吗?

I am process of implementing Amazon SQS service for processing lot of messages to persist it database. I am able to push the message using right_aws gem. I am also able to pull the message with example provided for gem.

I may end-up having multiple instances of ruby/rails server pulling and processing message (using lock and timeout feature of SQS). I would like to explore opportunity to pull the message using some start-up script or initialize during starting ruby/rails server and have component always running and processing messages till server is stopped.

Can someone please share some reference on how this can be implemented?

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

以可爱出名 2024-11-13 09:04:52

如果处理不是您需要回答的在线请求的一部分,那么最好的方法是编写专用脚本,该脚本将始终运行一个循环(如果没有太多工作要做,则可能会休眠)。

您将拉取一条消息,处理它,删除它,然后继续下一条。

在机器启动时运行这些进程,并使用 Supervisord 之类的东西来监视它们

The best way to do that, if the processing is not part of a online request you need to answer is by writing dedicated scripts that will have a loop always running (and maybe sleeping if there isn't much work to do).

You will pull a message, process it, delete it and continue to the next.

Run these processes at the machine startup and monitor them using something like Supervisord

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文