非同步的工作是在另一個 process 運作,所以從 Rails 這端指派工作時,需要避免參數被 serialize 的動作,以避免在 background job 中的 process 無法順利 deserialize 回來。
因為途中如果 code 有變動,或是有可能資料被改變了,這其中到 enqueue 的時間差可能造成 background job 執行時有問題。
所以會建議的作法是, call background job 時,傳入 id,然後在 job 被執行時才去找物件。
TrashableCleanupJobJob.perform_later(trashable.id)
class TrashableCleanupJob
def perform(trashable_id)
trashable = Trashable.find(trashable_id)
trashable.cleanup(depth)
end
end
但由於這是非常常見的設計,所以 Rails 會自動用 GlobalID 幫你處理來自 ActiveRecord 物件的轉換 (Active Model 的類別預設皆有混入 GlobalID::Identification)
所以只要確定物件是 ActiveRecord 類別就可以直接用
TrashableCleanupJobJob.perform_later(trashable)
在 Rails 內部會自動幫你把 trashable 物件轉成一個 GlobalID 字串放進 queue 裡,讓以下的job可以直接運作:
class TrashableCleanupJob
def perform(trashable)
# trashable 就是 activerecord 物件了,Rails 自動幫你 query 資料庫轉換回來
end
end
這邊記得,如果不是丟 ActiveRecord 物件,就要自己注意了。