有什么办法可以从ActiveJob排队中获取Delayed::Job的ID吗？当我排队一个任务时，我会得到一个ActiveJob::Base实例和一个@job_id，但这个作业ID似乎是内部使用的。到目前为止，我最好的猜测就是遍历最近创建的作业：
active_job_id = GenerateReportJob.perform_later(self.id).job_id
delayed_job = Delayed::Job.order(id: :desc).limit(5).detect do |job|
YAML.load(job.handler).job_data['job_id'] == active_job_id
end
但那看起来很不专业。有些惊讶 ActiveJob 没有从 Delayed::Job 返回 ID，尤其是当作业被排队时明确返回该ID。
== 编辑
看起来我不是唯一一个遇到这个问题的人 (https://github.com/rails/rails/issues/18821)
如果以后有人发现这个问题：Rails刚才接受了一个补丁，允许你从Rails 5的provider_job_id中获取这个id。你可以像这样使用补丁使其正常工作
ActiveJob::QueueAdapters::DelayedJobAdapter.singleton_class.prepend(Module.new do
def enqueue(job)
provider_job = super
job.provider_job_id = provider_job.id
provider_job
end
def enqueue_at(job, timestamp)
provider_job = super
job.provider_job_id = provider_job.id
provider_job
end
end)
attr_accessor：provider_job_id添加到ApplicationJob（如果您尚未这样做），或者添加到每个作业类中。 将@kddeisz的代码添加到初始化程序中非常有效。 - Brendon Muir受Beguene回答的启发，并对Rails 5 ActiveJob代码进行了一些反向工程，我已经使其适用于Rails 4.2，具体步骤如下:
1) 在lib/active_job/queue_adapters/delayed_job_adapter.rb 或 config/initializers/delayed_job.rb（两个位置都可行）中添加以下代码：
# file: lib/active_job/queue_adapters/delayed_job_adapter.rb
module ActiveJob
module Core
# ID optionally provided by adapter
attr_accessor :provider_job_id
end
module QueueAdapters
class DelayedJobAdapter
class << self
def enqueue(job) #:nodoc:
delayed_job = Delayed::Job.enqueue(JobWrapper.new(job.serialize), queue: job.queue_name)
job.provider_job_id = delayed_job.id
delayed_job
end
def enqueue_at(job, timestamp) #:nodoc:
delayed_job = Delayed::Job.enqueue(JobWrapper.new(job.serialize), queue: job.queue_name, run_at: Time.at(timestamp))
job.provider_job_id = delayed_job.id
delayed_job
end
end
class JobWrapper #:nodoc:
attr_accessor :job_data
def initialize(job_data)
@job_data = job_data
end
def perform
Base.execute(job_data)
end
end
end
end
end
attr_accessor :provider_job_id语句在Rails 4.2中是必需的，因为它在enqueue方法中使用，而在4.2中尚未定义。
然后我们可以按照以下方式使用它：
2）定义我们自己的ActiveJob类：
# file: app/jobs/my_job.rb
class MyJob < ActiveJob::Base
queue_as :default
def perform(object, performmethod = method(:method))
# Do something later
returnvalue = object.send(performmethod)
returnvalue
end
end
end
3) 现在我们可以在代码的任何地方创建一个新的任务：
job = MyJob.perform_later(Myobject, "mymethod")
Myobject.mymethod放入队列中。delayed_job = Delayed::Job.find(job.provider_job_id)
5) 最后，我们可以对 delayed_job 进行任何需要的操作，例如删除它：
delayed_job.delete
attr_accessor :provider_job_id语句。更好的选择是向Beguene的答案添加注释，但由于我是stackoverflow的新手，并且没有声望，我无权添加评论。因此，我想，回答这个问题并提供所有我需要使其工作的成分是有意义的。 - Ollilib/active_job/queue_adapters/delayed_job_adapter.rb。module ActiveJob
module QueueAdapters
class DelayedJobAdapter
class << self
def enqueue(job) #:nodoc:
delayed_job = Delayed::Job.enqueue(JobWrapper.new(job.serialize), queue: job.queue_name)
job.provider_job_id = delayed_job.id
delayed_job
end
def enqueue_at(job, timestamp) #:nodoc:
delayed_job = Delayed::Job.enqueue(JobWrapper.new(job.serialize), queue: job.queue_name, run_at: Time.at(timestamp))
job.provider_job_id = delayed_job.id
delayed_job
end
end
class JobWrapper #:nodoc:
attr_accessor :job_data
def initialize(job_data)
@job_data = job_data
end
def perform
Base.execute(job_data)
end
end
end
end
end
如果取消工作，您可以将其建模为工作本身的取消，而不是从队列中删除该工作。
然后，在运行GenerateReportJob之前，您可以首先检查报告是否已取消。如果有一个取消记录，则可以销毁该取消记录并退出报告生成。如果没有取消，则可以像往常一样继续进行。