Nic Lin's Blog

喜歡在地上打滾的 Rails Developer

Rails 非同步工作請用 Global ID

非同步的工作是在另一個 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 物件,就要自己注意了。

comments powered by Disqus