我有一个漫长的任务,需要在Rails 4.2.6应用程序的后台运行。不幸的是,该作业没有使用事件作业发送到后台。我已经找到工作了:
class PhotoProcessorJob < ActiveJob::Base
queue_as :default
def perform(*args)
::Photo.process_photos
end
end
它在我的Photo类上调用了一个方法(存储在config/initializers中):
class Photo
require 'zxing'
require 'csv'
@tablePath = Dir.glob("#{Rails.root.to_s}/tmp/photo_processing/*.csv")[0]
@output = "#{Rails.root.to_s}/tmp/photo_data.csv"
def self.getStudentInfo(id)
CSV.foreach(@tablePath, headers: true) do |row|
if row["Student ID"] == id
return row
else
next
end
end
end
def self.writeInfoToFile(data, file)
first_name = data["First Name"]
last_name = data["Last Name"]
student_id = data["Student ID"]
grade = data["Grade"]
email = data["Email"]
photo = file.to_s
CSV.open(@output, "a+") do |csv|
csv << [first_name, last_name, student_id, grade, email, photo]
end
end
def self.process_photos
extensions = %w(.jpg .jpeg .png .gif .tif)
studentInfo = nil
newfile = false
if File.exist?(@output)
outfile = CSV.new(File.read(@output))
if outfile.count == 0
newfile = true
end
else
newfile = true
end
if newfile
CSV.open(@output, "wb") do |csv|
csv << ["First Name", "Last Name", "Student ID", "Grade", "Email", "Photo"]
end
end
Dir.glob("#{Rails.root.to_s}/tmp/photo_processing/*").each do |file|
if file.match(/#{extensions.join("|")}/)
id = ZXing.decode File.new(file)
unless id.nil?
studentInfo = getStudentInfo(id)
else
writeInfoToFile(studentInfo, file) unless studentInfo.nil?
end
end
end
end
end
并从 Controller 调用:
class ProcessingController < ApplicationController
def finish
PhotoProcessorJob.perform_later
end
end
我正在尝试使用事件作业内联后端,因此没有安装任何队列库。问题是在运行
process_photos
方法时,“完成” View 被延迟了,而不是将其发送到后台并立即显示了该 View 。这可能是由upstream prematurely closed connection
引起的Nginx中的502错误,可能是因为process_photos
任务花费的时间太长了。我的“主 Action 业”设置是否做错了什么?
最佳答案
引用文档:
这意味着默认情况下,事件作业将在主线程中运行,而不是在“后台”中运行。这是一个常见的陷阱。基本上事件的工作只是跨多个排队后端的通用API。
TL; DR您必须设置一个像Sidekiq这样的排队后端。
否则,您的设置看起来很棒,甚至是教科书。
关于ruby-on-rails - Rails事件作业: perform_later not executing in background,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/37399057/