作业完成后 Sidekiq 如何在网页上通知用户？答案

【问题标题】：How should Sidekiq notify user on the web page when job is finished?作业完成后 Sidekiq 如何在网页上通知用户？
【发布时间】：2017-06-22 02:13:45
【问题描述】：

用户可以通过控制器操作处理的 Web 界面在我的系统中上传多个文件。

  def import
    paths = params[:files].map(&:path) if params[:files].present?
    if paths
      @results = MyRecord.create_from paths
    end 
    redirect_to confirmation_my_records_path
  end

class MyRecord < ActiveRecord::Base
  def self.create_from(paths)
    paths.each do |path|
      MyRecordWorker.perform path 
    end    
  end
end


works/my_record_worker.rb
class MyRecordWorker
  include Sidekiq::Worker
  def perform(path)
      # each time this is run, it is no I/O, just expensive math calculations that take minutes
      collection = ExpensiveOperation.new(path).run 
      if collection && collection.any?
        save_records(collection)
      else
        []
      end
  end
end

由于sidekiq作业将在后台运行，我如何通过确认页面通知用户作业已完成？我们不知道作业何时完成，因此当确认页面加载时，Rails 请求和响应周期无法确定任何内容。确认页面是否应该只显示“处理中...”，然后在作业完成时让 Faye 更新页面？

【问题讨论】：

这是使用网络套接字 (ActionCable) 的最佳时机。我从来没有使用过 Faye，但是是的，这也应该可以。

标签： ruby-on-rails ruby sidekiq

【解决方案1】：

在您的应用程序中添加一个RecordJobs 模型，用于存储上传记录的人员、记录数量、上传时间等。

每次有人上传新记录时创建一个新的record_job 并将其id 传递给工作人员。工作人员可以更新该实例以指示其进度。

同时，应用程序可以查询现有的record_job 并显示其进度。这可以在用户重新加载页面时通过主动轮询或使用网络套接字（取决于您的需要）来完成。

【讨论】：

网络插座，可以是 faye 或 activecable。在我写这篇文章之前，我什至从未听说过 activecable。我认为它是 Rails 5 中的新功能。

【解决方案2】：

使用 ActionCable，这里是带有报告通道的示例

在 routes.rb 中添加以下行

mount ActionCable.server => '/cable'

使用以下代码在 app/channels 中创建一个 ReportChannel.rb

class ReportChannel < ApplicationCable::Channel
  def subscribed 
    stream_from "report_#{current_user.id}"
  end
end

使用以下代码在 app/assets/javascripts/channels 中创建 reports.coffee

  window.App.Channels ||= {}
  window.App.Channels.Report ||= {}
  window.App.Channels.Report.subscribe = ->
      App.report = App.cable.subscriptions.create "ReportChannel",
        connected: ->
          console.log('connected ')

        disconnected: ->
          console.log('diconnected ')

        received: (data) ->
          console.log('returned ')
          data = $.parseJSON(data)
          #write your code here to update or notify user#

并在工作结束时添加以下行

ActionCable.server.broadcast("*report_*#{current_user_id}", data_in_json_format)

用您的特定模型替换报告

看起来很简单吧:)

【讨论】：