如何在Rails中使用delay_job将文件读取（导入）到数据库

debugcn 发表于 Dev

bav ko十

我有一个要导入import_jobs.rb的类

require 'roo'
class ImportJob < Struct.new(:path, :name)
  def perform
    import(path, name)
  end
  #
  def import(path, name)
    spreadsheet = open_spreadsheet(path, name)
    header = spreadsheet.row(1).map!(&:downcase)

    (2..spreadsheet.last_row).each do |i|
      row = Hash[[header, spreadsheet.row(i)].transpose].to_hash     
      potential_user = PotentialUser.find_by_id(row[:id]) || PotentialUser.new
      potential_user.attributes = row
      potential_user.save!
    end
  end
  #
  def open_spreadsheet(path,extname)
    case extname
    when ".csv" then Roo::CSV.new(path)
    when ".xls" then Roo::Excel.new(path)
    when ".xlsx" then Roo::Excelx.new(path,file_warning: :ignore)
    else raise "Unknown file type: extname"
    end
  end
end

在我看来

<%= form_tag import_potential_users_path, multipart: true do %>
  <%= file_field_tag :file %>
  <%= submit_tag "Import" %>
<% end %>

在控制器中

def import
  if params[:file].present?
    Delayed::Job.enqueue ImportJob.new(params[:file].path, File.extname(params[:file].original_filename))
  redirect_to potential_users_path, notice: "Protential Users imported."
  else
    redirect_to potential_users_path
  end
end

在运行作业时，显示错误不会退出file。虽然我运行时不使用delay_job，但代码有效

[Worker(host:ubuntu pid:14362)] Job ImportJob (id=860) RUNNING
[Worker(host:ubuntu pid:14362)] Job ImportJob (id=860) COMPLETED after 2.0222
[Worker(host:ubuntu pid:14362)] Job ImportJob (id=858) RUNNING
[Worker(host:ubuntu pid:14362)] Job ImportJob (id=858) FAILED (3 prior attempts) with IOError: file /tmp/RackMultipart20151211-14238-13b7xb does not exist
[Worker(host:ubuntu pid:14362)] 2 jobs processed at 0.7092 j/s, 1 failed

快速向导

看起来临时文件是在工作者开始处理作业之前被删除的。建议您将文件复制到另一个位置，然后重试。以下代码可能会有所帮助：

if params[:file].present?
  original_filename = params[:file].original_filename
  new_filename = "#{File.basename(original_filename)}_new"
  new_filepath = File.join(Dir.tmpdir, new_filename)
  FileUtils.cp(params[:file].path, new_filepath)
  import_job = ImportJob.new(new_filepath, File.extname(original_filename))
  DelayedJob.enqueue(import_job)
...

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。