使用Sidekiq进行活动作业并获取ActiveJob :: DeserializationError

我正在尝试使用Sidekiq来运行以下作业。使用Sidekiq进行活动作业并获取ActiveJob :: DeserializationError

作业在未排队（perform_now）时表现良好，但在调用为（perform_later）时使用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 < ApplicationJob queue_as：默认

def perform(room) 
    employees = Employee.all 
    if employees.length > 0 
     employees.each do |employee| 
     UserRoom.create(user: employee, room: room) 
     end 
    end 
    end 
end

我思考 我不明白为什么它找不到我进入执行方法的房间。就好像它在排队/ JSON化工作中失去了那个变量？

的Sidekiq文档说

“不幸的是，这意味着如果作业排队后[房间]记录被删除，但执行方法被调用之前，异常处理是不同的。”

他们建议的方法，但我看不出这将帮助我：

rescue_from ActiveJob::DeserializationError do |exception| 
    # handle a deleted user record 
end

在此先感谢您的帮助！

来源

2016-08-20 Tamlyn R

https://github.com/mperham/sidekiq/wiki/Problems-and-Troubleshooting＃can not-find-modelname-with-id12345 –

我不认为将Room对象传递给Sidekiq worker是个好主意。我总是传递一个数据库对象的主键，然后重新查询。尝试这个。

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

来源

2016-08-20 15:36:03 kcdragon

谢谢！这完美的作品... –

@TamlynR如果这个答案解决了你的问题，你会介意把它作为答案。如果没有，请让我知道还需要什么。 – kcdragon

将Ruby对象作为参数发送给sidekick worker是不可取的。您可以发送Id作为参数，并在执行方法内初始化对象。如果想发送对象，那么你可以将Ruby对象转储为任何其他格式，如Json/Binary/yml，如下所示。

object.to_json

或者

Marshal.dump(object)

并采用内部对象之前执行方法，你可以反序列化对象的Ruby对象，如下所示。

JSON.parse(serialized_object)

或者

Marshal.load(serialized_object)

这些是你的问题的解决方案，而不是理想的解决方案。

来源

2016-08-20 16:17:17 rakeshp

谢谢，这真的很有趣 –

如果可以确保此模型已提交，则可以将模型传递给作业。在提交当前事务之前排队作业是一个经典错误。

在我们的项目中，我们编写了一个模型，关注能够添加动态后提交的代码块。

module AfterCommitOnce 
    extend ActiveSupport::Concern 

    included do 
    after_commit :execute_after_commit_handlers 
    end 

    def after_commit_once(&block) 
    @after_commits = @after_commits || [] 
    @after_commits << block 
    end 

    private 

    def execute_after_commit_handlers 
    @after_commits = @after_commits || [] 
    @after_commits.each do |ac| 
     ac.call 
    end 
    @after_commits = [] 
    end 
end

添加这种关注你Employee模式，您可以指定要执行后提交所有更改到你的数据库与工作：

... 
employee.after_commit_once do 
    AddEmployeesToRoomJob.perform_later 
end 
employee.save!

来源

2017-12-14 10:39:05

使用Sidekiq进行活动作业并获取ActiveJob :: DeserializationError

回答

相关问题