2

我正在考虑使用 IronWorker 一个项目，以便我可以轻松扩展它（预计流量很大，有很多后台作业）。

为了保持干燥，我正在尝试使用继承定义工作人员，但我不断收到以下错误：

/usr/local/lib/site_ruby/1.9.1/rubygems/custom_require.rb:36:in `require': cannot load such file -- base_worker.rb (LoadError)
    from /usr/local/lib/site_ruby/1.9.1/rubygems/custom_require.rb:36:in `require'
    from /task/child_worker.rb:3:in `<top (required)>'
    from /task/runner.rb:344:in `require_relative'
    from /task/runner.rb:344:in `<main>'

这是基本工人类：

#  app/workers/base_worker.rb
require 'net/http'
require 'uri'
require 'json'

class BaseWorker < IronWorker::Base
  attr_accessor :params

  # The run method is what IronWorker calls to run your worker
  def run
    data = custom_run(params)
    common_post_process(data)
  end

   def custom_run(params)
     #to be overwritten in the child class 
   end    

   def common_post_process(data)
      # some common post processing => DRY
      ....
   end       
end

这是一个子类：

# app/workers/child_worker.rb 
require 'net/http'
require 'uri'
require 'base_worker.rb'

class ChildWorker  <  BaseWorker
  merge "base_worker.rb"

  def custom_run(params)
     #custom work
  end

end

关于如何解决这个问题的任何想法？

4

2 回答 2

4

我建议使用我们的下一代 gem，iron_worker_ng：https ://github.com/iron-io/iron_worker_ruby_ng 。不推荐使用 iron_worker gem。如果你想保持与你所拥有的风格相似，你的 child_worker.rb 可能看起来像这样：

require 'net/http'
require 'uri'
require_relative 'base_worker.rb'

class ChildWorker  <  BaseWorker

  def custom_run(params)
     #custom work
  end

end

# NG gem doesn't run anything in particular, so to run your method:
cw = ChildWorker.new
cw.custom_run(params)

在一个child_worker.worker文件中：

runtime 'ruby'

file 'base_worker.rb'
exec 'child_worker.rb'

然后将其上传到 IronWorker：

iron_worker upload child_worker

然后你可以开始为它排队工作：

worker = IronWorkerNG::Client.new
worker.tasks.create("child_worker", params)
于 2012-11-09T19:58:24.307 回答
1

如果使用iron_worker_ng，也可以定义一个run方法。IronWorker 运行时将调用此方法。您必须在.worker文件中指定类。

# child_worker.rb
class ChildWorker
  def run
    puts "doing the hard work"
  end
end

和child_worker.worker文件：

# child_worker.worker
runtime 'ruby'
name 'ChildWorker'
exec 'child_worker.rb', 'ChildWorker'
于 2013-08-27T11:47:13.120 回答