ruby – 同时运行延迟作业和Sidekiq

发布时间：2020-12-16 21:59:50 所属栏目：百科来源：网络整理

导读：我目前使用延迟作业异步处理作业.而不是创建工作人员,我使用了.delay方法很多. 我想转移到Sidekiq,但是我有太多的工作类型,不能确保所有这些都是线程安全的.所以我想并行运行Delayed Job和Sidekiq,并一次迁移一种类型的作业. 由于Delayed Job和Sidekiq都提供

我目前使用延迟作业异步处理作业.而不是创建工作人员,我使用了.delay方法很多.

我想转移到Sidekiq,但是我有太多的工作类型,不能确保所有这些都是线程安全的.所以我想并行运行Delayed Job和Sidekiq,并一次迁移一种类型的作业.

由于Delayed Job和Sidekiq都提供了.delay方法,我如何区分两者？还有其他潜在的问题吗？

解决方法

对于Sidekiq 2.17.1及更高版本,Rails初始化器中的某个地方,请调用以下命令：

Sidekiq.hook_rails!
Sidekiq.remove_delay!

并且您将只有前缀sidekiq_delay方法等等.

(official document)

对于旧版的Sidekiq：

将以下内容放在config / initializers / sidekiq.rb中

module Sidekiq::Extensions::Klass
  alias :sidekiq_delay :delay
  remove_method :delay
  alias :sidekiq_delay_for :delay_for
  remove_method :delay_for
  alias :sidekiq_delay_until :delay_until
  remove_method :delay_until
end

module Sidekiq::Extensions::ActiveRecord
  alias :sidekiq_delay :delay
  remove_method :delay
  alias :sidekiq_delay_for :delay_for
  remove_method :delay_for
  alias :sidekiq_delay_until :delay_until
  remove_method :delay_until
end

module Sidekiq::Extensions::ActionMailer
  alias :sidekiq_delay :delay
  remove_method :delay
  alias :sidekiq_delay_for :delay_for
  remove_method :delay_for
  alias :sidekiq_delay_until :delay_until
  remove_method :delay_until
end

然后,您可以使用sidekiq_delay在Sidekiq中排队,并在延迟作业中调用延迟队列.

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!