Rails延迟工作不起作用 [英] Rails delayed job not working

查看:79
本文介绍了Rails延迟工作不起作用的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

我的延迟工作不起作用。我正在尝试使用应该每15分钟运行一次的延迟作业为rake文件创建后台任务。我已将rake任务复制到rake文件中,并将其在控制器中设置为方法。我需要一份延迟的工作,因为heroku每1小时只会做一次cron。

My delayed job is not working. I am trying to create an background task for a rake file using a delayed job that should run every 15 minute. I have copied my rake tasks in my rake file and set them in my controller as methods. I need an delayed job because heroku only makes a cron every 1 hour.

这是我的应用程序控制器:

Here is my Application controller:

class ApplicationController < ActionController::Base

require 'delayed_job'
require 'Mechanize'
require 'pp'


protect_from_forgery

def iqmedier
          agent = WWW::Mechanize.new
          agent.get("http://www.iqmedier.dk")
          form = agent.page.forms.first
          form.submit

          agent.page.link_with(:href => "/Publisher/Stats").click

          form = agent.page.forms.first
          form.submit

          @stats = agent.page.search('//tr')[-2]

          @existing = Reklamer.find(:first, :conditions => {:dato => @stats[0]})
          if @existing.nil?
              Reklamer.create!(:virksomhed => 'Iqmedier', :dato => @stats[0], :unik_klik => @stats[1], :klik => @stats[2], :unik_vis => @stats[3], :vis => @stats[4], :leads => @stats[5], :ordre => @stats[6], :cpc => @stats[7], :earn => @stats[8])
          elsif @existing.dato != Date.today
          Reklamer.create!(:virksomhed => 'Iqmedier', :dato => Date.today, :unik_klik => 0, :klik => 0, :unik_vis => 0, :vis => 0, :leads => 0, :ordre => 0, :cpc => 0, :earn => 0)
          else
            @existing.update_attributes!(:unik_klik => @stats[1], :klik => @stats[2].to_i, :unik_vis => @stats[3], :vis => @stats[4], :leads => @stats[5], :ordre => @stats[6], :cpc => @stats[7], :earn => @stats[8])
          end
  end
 def euroads
        agent = Mechanize.new { |agent|
        agent.user_agent_alias = 'Mac Safari'}
        agent.get("http://www.euroads.dk")
        form = agent.page.forms.first
        form.submit
        @month = Date.today.strftime("%m").to_s
        agent.get("http://www.euroads.dk/system/index.php?showpage=showstat&show=overview&month=#{@month}&year0=2011&day=1&month=#{@month}&year=2011&day1=31&month1=#{@month}&year1=2011&fk_campaign=&fk_survey=&fk_track=&fk_pool=&columns1=1&columns2=2&columns4=4&columns14=14&columns5=5&columns6=6&columns7=7&columns8=8&columns9=9")

        @stats =  agent.page.search('table.ea').search('tr')

        @existing = Reklamer.find(:first, :conditions => {:dato => @stats[0]})
        if @existing.nil?
            Reklamer.create!(:virksomhed => 'Euroads', :dato => @stats[0], :unik_klik => @stats[1], :klik => @stats[2].to_i, :unik_vis => @stats[3], :vis => @stats[4], :leads => @stats[5], :ordre => @stats[6], :cpc => @stats[7], :earn => @stats[8])
        elsif @existing.dato != Date.today
          Reklamer.create!(:virksomhed => 'Euroads', :dato => Date.today, :unik_klik => 0, :klik => 0, :unik_vis => 0, :vis => 0, :leads => 0, :ordre => 0, :cpc => 0, :earn => 0)
        else
          @existing.update_attributes(:unik_klik => @stats[1], :klik => @stats[2].to_i, :unik_vis => @stats[3], :vis => @stats[4], :leads => @stats[5], :ordre => @stats[6], :cpc => @stats[7], :earn => @stats[8])
        end
  end

def mikkelsen
        agent = Mechanize.new
        agent.get("http://affilate.mikkelsenmedia.dk/partnersystem/mylogins.php")

        form = agent.page.forms.first
        @stats = agent.page.search('//tr')

        @existing = Reklamer.find(:first, :conditions => {:dato => @stats[0] })
        if @existing.nil?
            Reklamer.create!(:virksomhed => 'Mikkelsen', :dato => @stats[0], :unik_klik => @stats[3], :klik => @stats[3].to_i, :unik_vis => @stats[1], :vis => @stats[1], :leads => @stats[4], :ordre => @stats[9], :cpc => @stats[3], :earn => @stats[5])
        else
            @existing.update_attributes(:virksomhed => 'Mikkelsen', :dato => @stats[0], :unik_klik => @stats[3], :klik => @stats[3].to_i, :unik_vis => @stats[1], :vis => @stats[1], :leads => @stats[4], :ordre => @stats[9], :cpc => @stats[3], :earn => @stats[5])
        end
   end
def orville
        agent = WWW::Mechanize.new
        agent.get("https://dk.orvillemedia.com")

        form = agent.page.forms.first
        form.submit
        @dato = Date.today.strftime("%Y-%m-%d").to_s
        @month = Date.today.strftime("%m").to_s
        @day = Date.today.strftime("%d").to_s
        @stats = agent.page.search('//tr')

        @existing = Reklamer.find(:first, :conditions => {:dato => @dato})
        if @existing.nil?
            Reklamer.create!(:virksomhed => 'Orville', :dato => @dato, :unik_klik => @stats[2], :klik => @stats[2].to_i, :unik_vis => @stats[1], :vis => @stats[1], :leads => @stats[3], :ordre => '0', :cpc => (@stats[5] == '-' ? 0 : @stats[3]), :earn => @stats[6])
        else
          @existing.update_attributes(:virksomhed => 'Orville', :dato => Date.today, :unik_klik => @stats[2], :klik => @stats[2].to_i, :unik_vis => @stats[1], :vis => @stats[1], :leads => @stats[3], :ordre => '0', :cpc => (@stats[5] == '-' ? 0 : @stats[3]), :earn => @stats[6])
        end
   end

def runall
  [:iqmedier, :euroads, :mikkelsen, :orville].each{|a| send(a)}    
end
handle_asynchronously :runall, :run_at => Proc.new { 5.minutes.from_now }

当我执行rake作业时,工作开始但无法正常运行

When I run rake jobs:work it starts but is not working the runall job of

推荐答案

如果我正确理解了您要执行的操作,那么您应该具备以下条件:

If I understand correctly what you're trying to do, then you should have the following:

scraper.rb


require 'mechanize'

class Scraper
  def perform
    [:iqmedier, :euroads, :mikkelsen, :orville].each{|a| send(a)}
  end

  def iqmedier
    # some code
  end

  def mikkelsen
    # some code
  end

  def orville
    # some code
  end

end

在您的控制器中:


require 'delayed_job'
class MyController < ApplicationController
  def runall
    Delayed::Job.enqueue(Scraper.new, :run_at => 5.minutes.from_now)
  end
end

要从Rails外部添加作业,您可以编写类似的内容,然后使用railsRunner运行它:

For adding jobs from outside of rails, you can write something similar and then run it with rails runner:


require 'scraper'
Delayed::Job.enqueue Scraper.new
Delayed::Job.enqueue Scraper.new, :run_at => 15.minutes.from_now
Delayed::Job.enqueue Scraper.new, :run_at => 30.minutes.from_now
Delayed::Job.enqueue Scraper.new, :run_at => 45.minutes.from_now

这篇关于Rails延迟工作不起作用的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!

查看全文
登录 关闭
扫码关注1秒登录
发送“验证码”获取 | 15天全站免登陆