ruby-on-rails - 使用 sidekiq 为 activerecord 类编写 worker

Question

我有两个模型类如下:

class FileInfo < ActiveRecord::Base
  STATUS = {:UNAPPROVED => 1, :APPROVED => 2, :PROCESSED => 3 }
  attr_accessible :id, :status
  validates :status, :inclusion => {:in => STATUS.values}    
end

FileInfo 有 id 和 status 字段。每个文件可以有多个 FileEntry 类型的文件条目(行)。 FileEntry 有 id、file_info_id(FileInfo 的外键)和状态字段。

class FileEntry < ActiveRecord::Base
  STATUS = {:UNAPPROVED => 1, :READY => 2 , :SENT => 3 }
  attr_accessible :id, :file_info_id, :status, :reason
  validates :status, :inclusion => {:in => STATUS.values}
end

我想编写一个 worker 来异步处理状态字段为 APPROVED 的所有文件(FileInfo 模型)。每个线程都应处理状态为 READY 的特定文件的所有文件条目。一旦为该文件处理了所有条目，该线程就应该完成。假设状态为 UNAPPROVED 的文件条目也将变为 READY。

处理完每个条目后，其状态应更新为SENT。一旦所有文件条目都具有特定文件的 SENT 状态，请将该文件的状态更新为 PROCESSED。

到目前为止，我有这么多代码。无法弄清楚如何对 worker 进行编码:

class FileInfoObserver < ActiveRecord::Observer
  def after_save(file_info)        
    if file_info.status.eql? 2
       FileProcessingJob.perform_async(file_info.id)    
    end
  end
end

worker 如下:

class FileProcessingJob
  include Sidekiq::Worker
  def perform(file_id)
    puts "job"
    flag =1    
    while flag==1
      count = 0
      FileEntry.where("file_info_id = #{file_id}").find_each do |file_entry|
        if(file_entry.status == 2)
          puts "update" //Some PUT request, instead wrote a puts statement
          FileEntry.update(file_entry.id, :status => 3)
        elsif(file_entry.status == 0 || file_entry.status ==1)
          count = count + 1
        end
      end
      if(count == 0)
        flag = 0
      end
    end
  end 
end

这是正确的做法吗？如何启用重试机制？这段代码是线程安全的吗？

Answer 1

对于重试机制，

只需在“include Sidekiq::Worker”之后添加这一行

sidekiq_options queue: :default, retry: 1

它似乎不是多线程网络服务器环境。所以这里不用担心线程安全。

多线程网络服务器环境示例:
How get best performance rails requests parallel sidekiq worker