我正在使用带有 sidekiq 适配器的活动作业,并且我只想在满足某些条件时才执行作业,例如。我追加到队列,但我不想执行队列中的任何项目,除非设置了特定的 redis 标志。我怎样才能做到这一点?如果在触发器之前,我会检查是否设置了标志并抛出异常,我想它会起作用,但它看起来并不优雅。
1 回答
0
class SendNotificationsJob
include Sidekiq::Worker
queue_as :default
def perform(order)
order_status = $redis_server.get("#{order.id}:status")
unless 'done' == order_status
SendNotificationsJob.set(wait: 10.minutes).perform_later(order)
return # end this job. new job will check in 10min later
end
# fill here
end
end
于 2019-02-25T13:40:31.987 回答