如何设置特定的sidekiq队列一次运行一个任务？
在设置特定的sidekiq队列一次运行一个任务时，可以通过以下步骤实现：
- 创建一个新的Sidekiq队列：首先，需要在Sidekiq配置文件中定义一个新的队列。在配置文件中，可以指定队列的名称、优先级和并发数等参数。
- 定义一个新的Worker类：接下来，需要创建一个新的Worker类，用于处理特定队列中的任务。这个Worker类需要继承自Sidekiq::Worker，并实现perform方法来执行具体的任务逻辑。
- 将任务推送到特定队列：在代码中，可以使用Sidekiq的API将任务推送到特定队列中。通过指定队列名称，可以确保任务被放入到正确的队列中。
- 配置Sidekiq的并发数：为了确保特定队列一次只运行一个任务，需要在Sidekiq配置文件中将并发数设置为1。这样，Sidekiq将只会从队列中取出一个任务进行处理，直到任务完成后再取出下一个任务。
设置特定的sidekiq队列一次运行一个任务的优势是可以控制任务的执行顺序和并发度，适用于一些需要顺序执行或者对资源有限制的场景。
以下是腾讯云相关产品和产品介绍链接地址，供参考：
- 腾讯云云服务器（CVM）：提供弹性计算能力，支持多种操作系统和应用场景。详情请参考：https://cloud.tencent.com/product/cvm
- 腾讯云容器服务（TKE）：提供高度可扩展的容器化应用管理平台，支持Kubernetes。详情请参考：https://cloud.tencent.com/product/tke
- 腾讯云数据库（TencentDB）：提供多种数据库产品，包括关系型数据库、NoSQL数据库和数据仓库等。详情请参考：https://cloud.tencent.com/product/cdb
- 腾讯云对象存储（COS）：提供安全、稳定、低成本的云存储服务，适用于各种数据存储需求。详情请参考：https://cloud.tencent.com/product/cos
相关·内容
我有一个从instagram检索数据的模块(使用cookie，即登录用户)，但instagram阻止发送大量请求，所以我正在寻找解决方案，以执行一个工人的任务在时间(没有并行任务的同一个工人)。从类似的主题中，我确实找到了一些解决方案，比如将并发设置为1或使用gem ，但我不想因为特定的一个而减少所有队列的并发性，而且sidekiq</e
浏览 58提问于2019-07-22得票数 0
1回答
下面是一些关于ActiveJobs的问题：
假设我已经通过ActiveJobs在sidekiq上的作业队列中排队了n个作业。在我的EC2上，我已经将美洲狮设置为有4个工作人员，每个线程有5个线程。这是否意味着多达20个并发作业将同时运行？当任务空闲时，每个线程会接收一个排队的作业并只处理它吗？我尝试过这个设置，但它似乎仍然在处理它的串行-1作业一次。我还需要做
浏览 9提问于2017-06-22得票数 1
1回答
我想做一个for循环，每一个工作人员之间都有5分钟的延迟。但是当我试图将它部署到Heroku时，它会使我的应用程序崩溃。class DelayedCallWorker include Sidekiq::Status::Worker
def perform我还尝试了一种变体，通过控制器中的引线，使用perform_in(5.minutes, survey_id)创建了每个工作人员延迟更长的<
浏览 5提问于2015-10-23得票数 0
回答已采纳
sidekiq.yml:pidfile: ./tmp/pids/sidekiq.pid:concurrency: 5 - ["queue1", 1] - ["queue3", 1] - ["queue5"
浏览 0提问于2019-03-21得票数 2
我有两个队列：development和ar_updater。我有一群sidekiq工作人员在不断地更新ActiveRecord对象，但有时他们会同时查询记录，而不是在另一个更新后才查询记录。因此，我在考虑创建一个队列并将其并发数限制为1，这样就可以追加正确的数据。schedule.current_progress end
end 有没有办法确保这些工作者在这个
浏览 15提问于2020-11-03得票数 0
sidekiq文档显示我只能控制Sidekiq的全局并发，而不是每个队列。我在这里提出一个问题，希望每个队列的并发设置都有解决方案。一些第三方服务就是不接受高并发性，并且仅仅为了这些限制整个侧边站是痛苦的。
我在sidekiq 3.3上
浏览 0提问于2015-03-01得票数 15
我在Heroku上，我收到了一个错误，因为我的redis数据库太满了。my sidekiq进程停止工作。就这样过了一天，直到我意识到。现在，我有一些试图处理的600+作业，但它们现在只是破坏了一切。当sidekiq无法处理作业或Enqueue开始填满时，我如何发出警报？
浏览 0提问于2014-04-03得票数 1
我们如何使用rails将作业添加到使用db time的特定日期和时间，我想在约会时间到来时发送电子邮件，那么最好的方法是什么？
浏览 0提问于2015-06-17得票数 3
1回答
我们使用Sidekiq作为我们的队列管理系统和Sidetiq来管理计划中的循环任务，它对我们很好的工作。
Si
浏览 8提问于2015-08-12得票数 1
我使用一个Sidekiq队列来处理与不可靠的第三方API的通信。由于这个API通常一次关闭几分钟，然后再次备份，所以Sidekiq非常方便。当发生连接问题时，会引发一个错误，Sidekiq会将作业抛回队列中，以便在过了一段时间后再重新尝试。
我使用NewRelic不仅帮助调试崩溃，而且还用于监视。我想做的只是在对工作进行了一定数量的重试时，从我的员工那里引发<em
浏览 11提问于2016-02-29得票数 10
回答已采纳
我有一个任务，我需要在请求创建后立即生成，并尽快完成它。为此，我创建了一个/config/sidekiq.yml文件，并在其中定义了以下内容：:queues: - [critical, 10]class GeneratePDFWorker sidekiq_options queue: 'cr
浏览 3提问于2016-05-08得票数 2
我使用的是Sidekiq和我的Rails应用程序，大约有30名工人，他们会根据用户在rails应用程序中点击的任务随机地开始工作。我只是实现了一个中间件，这样我就可以在每次侧翼作业失败时调用一个方法；然而，现在我想知道是否有一种方法可以在一个不同的队列中重新运行该作业(比方说"retry_queue")。这基本上使用了环境中运行的任何队
浏览 0提问于2021-01-22得票数 0
回答已采纳
我正在探索sidekiq API，我试图找到一种方法来检查给定队列，在给定时刻有多少线程在运行(我正在使用sidekiq limit fetch gem ，我希望确保我在配置文件中设置的限制得到遵守)。我看过workers = Sidekiq::Workers.new，它应该包含有关线程的信息，但它实际上并没有显示任何关于线程数量的信息。在sidekiq中，有没有办法找出在给定时刻有多少线程在为特定
浏览 0提问于2019-04-29得票数 1
4回答
我有一个简单的侧边站工作，我已经设置为每5分钟运行一次，使用发条。我担心的是，如果作业耗时超过5分钟，它将再次运行，这可能会导致一些问题，如果它与原始作业同时运行。是否有一种方法可以锁定时钟，使其仅在前一次运行完成时才运行？
浏览 23提问于2017-03-10得票数 5
因为Sidekiq的死作业队列的容量为10,000。我有时运行批量作业，它一次运行乔布斯一百万条记录，失败出现在10k到20k之间。由于并不是所有的作业都出现在dead job queue中，所以我无法重新尝试所有这些任务，而不得不再次运行维护任务。
是否有一种方法可以使用Sidekiq或Rails控制台重新运行所有的故障？
浏览 3提问于2017-04-26得票数 0
回答已采纳
11回答
可以阻止在队列中处理作业的可能原因是什么？排队排满了。日志文件sidekiq.log表示根本没有任何活动。因此，队列已满，但日志为空，Sidekiq似乎不处理项。似乎没有工人处理工作。Sidekiq并生成以下日志文件：
2013-05-30..Booting Sidekiq 2.12.0 using redis有没有隐藏的日志文
浏览 6提问于2013-05-30得票数 73
回答已采纳
1回答
我使用sidekiq并定义了一个worker类，如下所示： include Sidekiq::Worker
sleep在我的情况下，我需要退出队列，或者只在我决定时启动下一个排队的项目。它将由外部事件触发。post '/response/?'doend
浏览 0提问于2016-12-02得票数 1
2回答
在sidekiq中执行的第一个作业完成后，我如何管理执行作业。例如:我触发了今天早上的第一个任务当它还在运行时，我已经在同一个worker中动态地再次执行了一个作业
GoodWorker.perform_ascyn现在Sidekiq一直在处理作业，有没有一种方法一次处理一个<
浏览 2提问于2016-09-08得票数 1
我有一个相当简单的Rails 5应用程序来监控站点的速度。它将作业发送到外部页面速度测试服务，并定期检查作业是否完成，如果完成，则调用和存储有关页面的数据。有一个活动作业，它有一个边框后端，它应该每分钟运行一次，检查应该运行的页面，如果发现任何页面，就启动一个作业来对其进行排队。to pick out all unqueued jobs and send them to webpagespeedtest
Queu
浏览 5提问于2016-10-11得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
