3

我有一个使用 Sinatra 构建的基于 Web 的应用程序。从最近开始，我需要定期收集数据并将它们存储在数据库中。为此，有人告诉我我可以在组合中使用Resque和Clockwork宝石。

每隔一小时左右，我需要根据数据库进行近 15 次计算，并将结果存储在数据库中。

所以这就是我采取的方法。我决定制作 15 个具有该perform方法的类（我用于测试的确切文件如下）。Resque.enqueue( GraphData )然后为所有 15 个班级做一些类似的事情。

class GraphData

  @queue = :graph_data

  def self.init()

  end

  def self.perform()
    File.open( '/home/ziyan/Desktop/resque.txt', 'a' ) { | file | file.write( "Resqueu - performed - #{Time.now}\n" ) }
  end

end

为了触发测试目的的操作，我创建了一个 rake 任务。

desc "Start Resque Workers for Queue" # {{{
task :graph_data do |t|

  ENV["QUEUE"]      = "*"
  ENV["VVERBOSE"]   = "1"
  ENV["INTERVAL"]   = "5"

  Resque.enqueue( GraphData )
  #resque = Resque.new
  #resque << AdminWorker.new
end # }}}

如您所见，在GraphData课堂上，self.perform我正在写入文件的方法。

我的问题是没有！我做错了什么吗？

rake graph_data将不显示任何输出。Web 界面将显示Queue.

附加信息

我添加了另一个Rake任务来运行 Web 界面。

desc "Start Resque Web Frontend" # {{{
task :resque_web_frontend do |t|
  sh "resque-web -p 8282"
  puts "Resque Web Frontend is running on http://localhost:8282"
end # }}

在他们身上，看到了一些有趣的东西。当我运行 rake 任务时，stats值pending会增加但不会被处理。

在 queues -> graph_data 我看到类似这样的东西。

Class   Args
GraphData   []
GraphData   []
GraphData   []

我最终得到了什么：

desc "Start Resque Workers for Queue" # {{{
task :graph_data do |t|

  ENV["QUEUE"]      = "*"
  ENV["VVERBOSE"]   = "1"
  ENV["INTERVAL"]   = "5"

  Rake::Task[ "resque:work" ].invoke
  Resque.enqueue( GraphData )
  #resque = Resque.new
  #resque << AdminWorker.new
end # }}}
4

1 回答 1

7

这是在开发还是生产中？根据您的描述，您似乎没有启动 Resque 流程。你是如何运行你的应用程序的？我更熟悉将 Resque 与 Rails 一起使用，但您应该运行以下命令：

rake resque:work QUEUE='*'

让 resque worker 启动。

于 2013-08-23T16:58:09.083 回答