2

メール通知とスクレーパーのバックグラウンド ジョブを作成しようとしています。resque-scheduler (4.0.0)、resque (1.25.2)、rails 4.2.1 を使用しています。

私の config.ru ファイル:

# This file is used by Rack-based servers to start the application.
require ::File.expand_path('../config/environment', __FILE__)
run Rails.application

require 'resque/server'  
run Rack::URLMap.new "/" => AppName::Application,  "/resque" => Resque::Server.new

私の /lib/tasks/resque.rake:

require 'resque/tasks'
require 'resque/scheduler/tasks'

namespace :resque do
  task :setup do
    require 'resque'
    require 'resque-scheduler'

    Resque.schedule = YAML.load_file("#{Rails.root}/config/resque_schedule.yml")
    Dir["#{Rails.root}/app/jobs/*.rb"].each { |file| require file }
  end
end

私の /config/resque_scheduler.yml:

CheckFsUpdatesJob:
  queue: fs_updates
  every:
    - '1h'
    - :first_in: '10s'  
  class: CheckFsUpdatesJob
  args:
  description: scrape page

私の /config/initializer/active_job.rb

ActiveJob::Base.queue_adapter = :resque

私の /config/initializer/resque.rb:

#config/initializers/resque.rb
require 'resque-scheduler'
require 'resque/scheduler/server'

uri = URI.parse("redis://localhost:6379/")  
Resque.redis = Redis.new(:host => uri.host, :port => uri.port, :password => uri.password)

Resque.after_fork = Proc.new { ActiveRecord::Base.establish_connection }

Dir["#{Rails.root}/app/jobs/*.rb"].each { |file| require file }
Resque.schedule = YAML.load_file(Rails.root.join('config', 'resque_schedule.yml'))

Resque::Server.use(Rack::Auth::Basic) do |user, password|
  user = 'admin'
  password = 'admin'
end

メール通知の最初の仕事:

class EmailNotificationJob < ActiveJob::Base
  queue_as :email_notifications

  def perform(episode_id, email)
    NotificationMailer.new_record_appears(record_id, email).deliver_now
  end
end

スケジュールされた実行のための私の 2 番目の仕事:

class CheckFsUpdatesJob < ActiveJob::Base
  queue_as :fs_updates

  def perform()
    FsStrategy.new.check_for_updates
  end
end

だから私は仕事をしなければなりません: 1. 電子メール通知 - DB に新しいレコードが表示されたときに電子メールを送信する必要があります 2. ページをスクレイピング - 1 時間ごとに実行する必要があります

実行方法：

redis-server
rake environment resque:work QUEUE=fs_updates
rake environment resque:work QUEUE=email_notifications
rake environment resque:scheduler
rails s

これらのコマンドを実行した後、Resque ダッシュボードに、予想どおり 2 つのワーカーと 2 つのキューが表示されます。

しかし！

resque Schedule タブで 'queue now' ボタンをクリックすると、タスクが作成され、"fs_updates" キューに書き込まれたことがわかります。しかし、それは実行されておらず、数秒で消えます。

Rails コンソールから送信する電子メールのジョブを実行すると、まったく機能しません。

構成を修正するのを手伝ってください。よろしくお願いします！

4

2 に答える 2