ruby-on-rails - delayed_job : 'undefined method' error when using handle_asynchronously

Question

我正在尝试使用 delayed_job 将更大的 csv 导入到我的 rails 数据库中。这是我的 Controller 和模型方法:

Controller 方法

def import
    InventoryItem.import(params[:file], params[:store_id])
    redirect_to vendors_dashboard_path, notice: "Inventory Imported."
end

模型方法

def self.import(file, store_id)
CSV.foreach(file.path, headers: true) do |row|
inventory_item = InventoryItem.find_or_initialize_by_upc_and_store_id(row[0], store_id)
inventory_item.update_attributes(:price => row.to_hash["price"], :updated_at => "#{Time.now}")
    end
end

handle_asynchronously :import

我已将“delayed_job”和“daemons”添加到我的 gemfile，然后进行捆绑。运行生成器，使用 rake jobs:work 启动开发工作进程，然后尝试通过应用运行导入。这是我得到的错误:

Routing Error
undefined method `import' for class `InventoryItem'

我在集成 delayed_job 时是否遗漏了什么？这个导入过程之前运行良好，所以只是想知道我在哪里搞砸了。提前致谢!

Answer 1

您的导入是一个类方法，您应该在模型类名称的单例类上调用 handle_asynchronously:

您可以使用元类技巧来为类方法起别名:

class << self
   def import(file, store_id)
     CSV.foreach(file.path, headers: true) do |row|
      inventory_item = InventoryItem.find_or_initialize_by_upc_and_store_id(row[0], store_id)
      inventory_item.update_attributes(:price => row.to_hash["price"], :updated_at => "#{Time.now}")
     end
   end
  handle_asynchronously :import
end

希望这对您有所帮助!