我有一些更新触发器将作业推送到Sidekiq队列.所以在某些情况下,可以有多个作业来处理同一个对象.
有几个独特的插件(“Middleware”,Unique Jobs),它们没有多少记录,但它们似乎更像是调节器来防止重复处理;我想要的是阻止重复创建相同作业的扼流器.这样,一个对象将始终处于最新鲜的状态.是否有插件或技术？
更新：我没有时间做一个中间件,但我最终得到一个相关的清理功能,以确保队列是唯一的：https://gist.github.com/mahemoff/bf419c568c525f0af903
解决方法
我的建议是根据一些选择条件搜索以前的计划作业,然后再安排一个新的作业.当我想要一个特定的对象的一个预定的作业,和/或其中一个方法,这对我来说是有用的.
在这种情况下的一些示例方法：
find_jobs_for_object_by_method(klass,method)
jobs = Sidekiq::ScheduledSet.new
jobs.select { |job|
job.klass == 'Sidekiq::Extensions::DelayedClass' &&
((job_klass,job_method,args) = YAML.load(job.args[0])) &&
job_klass == klass &&
job_method == method
}
end
##
# delete job(s) specific to a particular class,method,particular record
# will only remove djs on an object for that method
#
def self.delete_jobs_for_object_by_method(klass,id)
jobs = Sidekiq::ScheduledSet.new
jobs.select do |job|
job.klass == 'Sidekiq::Extensions::DelayedClass' &&
((job_klass,args) = YAML.load(job.args[0])) &&
job_klass == klass &&
job_method == method &&
args[0] == id
end.map(&:delete)
end
##
# delete job(s) specific to a particular class and particular record
# will remove any djs on that Object
#
def self.delete_jobs_for_object(klass,args) = YAML.load(job.args[0])) &&
job_klass == klass &&
args[0] == id
end.map(&:delete)
end