将 Sidekiq 用于 Active Job 并获取 ActiveJob::DeserializationError [英] Using Sidekiq for Active Job and getting ActiveJob::DeserializationError
问题描述
我正在尝试使用 Sidekiq 来运行以下作业.
I'm trying to use Sidekiq to run the below job.
作业在未排队时 (perform_now) 执行良好,但在调用时失败 (perform_later),使用 Sidekiq.
The job performs fine when not queued (perform_now) but fails when called as (perform_later), which uses Sidekiq.
AddEmployeesToRoomJob.perform_now room ## works fine
AddEmployeesToRoomJob.perform_later room ## breaks in Sidekiq
错误:
AddEmployeesToRoomJob JID-da24b13f405b1ece1212bbd5 INFO: fail: 0.003 sec
2016-08-20T14:57:16.645Z 19456 TID-owmym5fbk WARN: {"class":"ActiveJob::QueueAdapters::SidekiqAdapter::JobWrapper","wrapped" :"AddEmployeesToRoomJob","queue":"default","args": [{"job_class":"AddEmployeesToRoomJob","job_id":"0ba5bd30-e281-49a7-a93f- 6e50445183ac","queue_name":"default","priority":null,"arguments": [{"_aj_globalid":"gid://dragonfly/Room/1"}],"locale":"en"}],"retry":true, "jid":"da24b13f405b1ece1212bbd5","created_at":1471704675.739077,"enqueued _at":1471705036.6406531,"error_message":"Error while trying to deserialize arguments: Couldn't find Room with 'id'=1","error_class":"ActiveJob::DeserializationError","failed_at":14717 04675.946183,"retry_count":4,"retried_at":1471705036.644416}
2016-08-20T14:57:16.645Z 19456 TID-owmym5fbk WARN: ActiveJob::DeserializationError: Error while trying to deserialize arguments: Couldn't find Room with 'id'=1
2016-08-20T14:57:16.645Z 19456 TID-owmym5fbk WARN: /Users/tamlyn/.rvm/gems/ruby-2.2.3/gems/activerecord- 5.0.0.1/lib/active_record/relation/finder_methods.rb:357:in `raise_record_not_found_exception!'
我的工作类 AddEmployeesToRoomJob <申请工作queue_as :默认
My Job class AddEmployeesToRoomJob < ApplicationJob queue_as :default
def perform(room)
employees = Employee.all
if employees.length > 0
employees.each do |employee|
UserRoom.create(user: employee, room: room)
end
end
end
end
我的想法我不明白为什么它找不到我传递给 perform 方法的房间.就好像它以某种方式在作业的排队/JSONifying 中丢失了该变量?
My Thoughts I don't understand why it can't find the room which I'm passing into the perform method. It's as though it somehow loses that variable in the queueifying / JSONifying of the job?
Sidekiq 文档说
The Sidekiq docs say
不幸的是,这意味着如果在作业入队之后但在调用 perform 方法之前删除 [Room] 记录,则异常处理是不同的."
"Unfortunately this means that if the [Room] record is deleted after the job is enqueued but before the perform method is called, exception handling is different."
他们提出了一种解决方法,但我看不出这对我有什么帮助:
They suggest a workaround but I don't see how that would help me:
rescue_from ActiveJob::DeserializationError do |exception|
# handle a deleted user record
end
在此先感谢您的帮助!
推荐答案
我认为将 Room 对象传递给 Sidekiq 工作线程并不是一个好主意.我总是传递数据库对象的主键,然后重新查询.试试这个.
I don't think it is a good idea to pass the Room object into a Sidekiq worker. I've always passed the primary key for a database object and then re-queried. Try this.
AddEmployeesToRoomJob.perform_later room.id
def perform(room_id)
room = Room.find(room_id)
employees = Employee.all
if employees.length > 0
employees.each do |employee|
UserRoom.create(user: employee, room: room)
end
end
end
end
这篇关于将 Sidekiq 用于 Active Job 并获取 ActiveJob::DeserializationError的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!