Ruby on Rails Sidekiq：能否传递Lambda方法至Worker并执行？

首先明确：Sidekiq无法直接接收并执行Lambda、Proc这类可调用对象。原因很简单——Sidekiq的任务参数必须能被JSON序列化，而Ruby的Lambda/Proc是无法被JSON正常序列化和跨进程反序列化的，客户端进程里定义的block根本传不到Worker进程中。

你之前尝试的写法之所以失败，就是因为block并没有被作为参数传递给perform_async，而是在客户端执行时就被丢弃了，Sidekiq不会处理这种隐式的block参数。

下面给你两个实用的替代方案，既能避免编写大量一次性Worker，又能利用Sidekiq的多线程能力：

方案一：通用Worker+类方法 #

定义一个通用的Worker，专门用来执行指定类的指定方法，把逻辑封装到类方法中，再传递类名、方法名和参数即可。

通用Worker代码 #

class GenericWorker
  include Sidekiq::Worker

  def perform(class_name, method_name, *args)
    # 解析类和方法，执行逻辑
    klass = class_name.constantize
    klass.send(method_name, *args)
  end
end

调用方式 #

先把你的计算逻辑封装到一个类的静态方法里：

class TaskExecutor
  def self.run_calculation(args)
    # 这里写你的大量计算逻辑，比如 args.lets_go
    args.lets_go
  end
end

然后批量提交任务：

lot_of_work.each do |args|
  GenericWorker.perform_async('TaskExecutor', 'run_calculation', args)
end

方案二：利用Ruby的方法标识（进阶） #

如果你不想单独定义类，也可以传递对象的方法标识，但要确保对象在Worker进程中能被正确重建（比如传递ActiveRecord对象的ID，而非对象本身）：

调用示例 #

# 假设你的args是一个有lets_go方法的对象，先传ID
lot_of_work.each do |item|
  GenericWorker.perform_async('Item', 'find', item.id, 'lets_go')
end

对应的通用Worker调整 #

class GenericWorker
  include Sidekiq::Worker

  def perform(class_name, finder_method, finder_arg, method_name)
    obj = class_name.constantize.send(finder_method, finder_arg)
    obj.send(method_name)
  end
end

注意事项 #

• 所有传递的参数必须是可JSON序列化的类型（字符串、数字、数组、哈希等），不要直接传递ActiveRecord对象、文件句柄这类无法序列化的对象，建议传ID后在Worker中重新查询。
• 确保你传递的类名和方法名在Sidekiq Worker的运行环境中存在，不然constantize会抛出NameError。
• 注意安全风险，不要允许外部输入类名/方法名，避免恶意代码执行。

内容的提问来源于stack exchange，提问作者Casper Akuma H. Iversen