知道如何从ActiveJob入队获取Delayed :: Job id吗?当我排队一个工作时,我用@job_id返回一个ActiveJob :: Base实例,但该工作ID似乎是ActiveJob内部的.到目前为止,我最好的猜测就是走下最近创建的工作:
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
但这似乎是各种各样的hacky.有点惊讶的ActiveJob没有从Delayed :: Job返回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)