如何管理与 Sidekiq 的连接?
How to manage connections with Sidekiq?
每个工作人员都应该有自己的资源连接。我阅读了文档,但不清楚每个线程是否运行一个单独的 worker 实例。
如果是这样,这是否会为每个工作人员创建一个唯一的连接?
class HardWorker
include Sidekiq::Worker
def perform
connection.send 'message'
end
def connection
@connection ||= Connection.new
end
end
Sidekiq 在执行每个作业时基本上都是这样做的:HardWorker.new.perform
。所以,是的。
每个工作人员都应该有自己的资源连接。我阅读了文档,但不清楚每个线程是否运行一个单独的 worker 实例。
如果是这样,这是否会为每个工作人员创建一个唯一的连接?
class HardWorker
include Sidekiq::Worker
def perform
connection.send 'message'
end
def connection
@connection ||= Connection.new
end
end
Sidekiq 在执行每个作业时基本上都是这样做的:HardWorker.new.perform
。所以,是的。