手动执行sidekiq worker
是指通过手动触发来执行sidekiq worker任务，而不是依赖于自动调度或队列中的任务。sidekiq是一个用于处理后台任务的Ruby库，它基于Redis实现了一个简单而高效的消息队列系统。
sidekiq worker是一个处理后台任务的工作单元，它可以执行各种异步任务，如发送电子邮件、处理图像、生成报告等。通过手动执行sidekiq worker，我们可以在需要的时候立即执行任务，而不必等待自动调度或队列中的任务。
手动执行sidekiq worker的步骤如下：
- 确保已经安装并配置好了sidekiq和Redis。
- 在应用程序的代码中定义并注册需要执行的sidekiq worker任务。
- 使用sidekiq提供的命令行工具手动触发执行worker任务。
具体步骤如下：
- 安装并配置sidekiq和Redis：根据sidekiq的官方文档，安装并配置sidekiq和Redis，确保它们能够正常工作。
- 定义并注册sidekiq worker任务：在应用程序的代码中，定义需要执行的sidekiq worker任务。例如，我们可以创建一个名为
MyWorker的worker类，其中包含perform方法来执行具体的任务逻辑。 - 定义并注册sidekiq worker任务：在应用程序的代码中，定义需要执行的sidekiq worker任务。例如，我们可以创建一个名为
MyWorker的worker类，其中包含perform方法来执行具体的任务逻辑。 - 然后，在应用程序的初始化代码中，注册这个worker任务。
- 然后，在应用程序的初始化代码中，注册这个worker任务。
- 手动执行sidekiq worker任务：使用sidekiq提供的命令行工具手动触发执行worker任务。在终端中，使用以下命令执行worker任务：
- 手动执行sidekiq worker任务：使用sidekiq提供的命令行工具手动触发执行worker任务。在终端中，使用以下命令执行worker任务：
- 其中，
-q default指定了使用默认队列，-r ./path/to/your/code.rb指定了加载应用程序代码的路径。 - 执行以上命令后，sidekiq将会启动，并开始执行队列中的任务。
手动执行sidekiq worker的优势是可以灵活地控制任务的执行时机，特别适用于需要立即执行的任务或调试任务。它可以帮助开发人员快速验证任务逻辑，定位问题，并进行调试。
应用场景：
- 需要立即执行的任务：手动执行sidekiq worker可以立即触发任务执行，适用于需要立即处理的任务，如发送紧急邮件、生成实时报告等。
- 调试任务：手动执行sidekiq worker可以帮助开发人员在开发和测试阶段调试任务逻辑，定位问题，并进行单步调试。
腾讯云相关产品推荐：
- 云服务器（CVM）：提供高性能、可扩展的云服务器实例，用于部署和运行sidekiq和应用程序。
- 产品介绍链接：https://cloud.tencent.com/product/cvm
- 云数据库Redis版：提供高性能、可靠的Redis数据库服务，用于存储sidekiq的任务队列。
- 产品介绍链接：https://cloud.tencent.com/product/redis
- 云函数（SCF）：提供事件驱动的无服务器计算服务，可用于自动触发执行sidekiq worker任务。
- 产品介绍链接：https://cloud.tencent.com/product/scf
请注意，以上推荐的腾讯云产品仅供参考，具体选择应根据实际需求和项目要求进行评估和决策。
相关·内容
我有一个sidekiq worker，它执行一些JRuby代码来连接并从远程服务器拉取数据。它在终端上运行得很好：
bundle exec sidekiq
但在生产环境中，我想通过传递-d选项在后台运行worker：
bundle exec sidekiq -d -L log/sidekiq.log
它无法工作，并返回以下内容：
ObjectSpace is disabled; each_object will only work with Class, pass -X+O to enable
我需要传递任何其他选项才能在后台运行sidekiq吗？
浏览 0提问于2016-06-06得票数 0
1回答
只在开发中慢慢来
、、
在Sidekiq 6.1.0上运行Rails 5.0.7.2，并将Sidekiq并发设置为12、Redis server 4.0.14和Redis gem 4.2.1。
在排队/执行作业之间似乎有一些延迟(秒)，这是我们在Rails 4.2.9中没有看到的。注意，这种行为只发生在开发中，生产似乎做得很好。
示例工人：
class SidekiqTestWorker
include Sidekiq::Worker
sidekiq_options(
queue: "default",
)
def perform
puts "Hello f
浏览 1提问于2020-07-08得票数 2
回答已采纳
我的Sidekiq工人如下所示：
Class BooksWorker
include Sidekiq::Worker
def perform
books = Book.where(collected: true)
books.each do |book|
book.update_attribute(:status, "read")
book.toggle!(:collected)
end
end
end
我想使用禁用模式下的Sidekiq测试来检查：
作业是排队的
Sidekiq与Redis
浏览 1提问于2016-12-10得票数 0
所以在用户注册后，我要做两件事
( 1)发送一封欢迎电子邮件2)将他们的facebook配置文件图片更新到我的s3
if user.save
UpdateAvatarWorker.perform_async(user.id)
UserMailer.welcome_email(user).deliver_later unless user.email.nil?
render json: {
status: 200
}
else
render json: { errors: user.errors.messages, statu
浏览 1提问于2018-03-31得票数 3
回答已采纳
3回答
我已经为这个问题挣扎了一段时间了，我就是想不出来。我正试图让Redis和Sidekiq来处理Rails项目的后台工作，这些工作托管在Cloud66 w/ Digital上。所有需要的宝石似乎都存在，并且设置在本地完全工作。
我的第一次尝试是使用以下设置：
这是我的config/file kiq.yaml文件：
---
:concurrency: 25
:pidfile: ./tmp/pids/sidekiq.pid
:logfile: ./log/sidekiq.log
:queues:
- default
- [high_priority, 2]
:daemon: true
根据本教
浏览 3提问于2015-05-16得票数 0
回答已采纳
我有以下员工
class JobBlastingWorker
include Sidekiq::Worker
sidekiq_options queue: 'job_blasting_worker'
def perform(job_id, action=nil)
job = Job.find(job_id)
JobBlastingService.new(job).call
sidekiq_id = JobBlastingWorker.perform_in(2.minutes, job.id, 're-blast', tru
浏览 21提问于2021-09-22得票数 0
1回答
在一个单独的选项卡中，我运行
bundle exec sidekiq
在另一个选项卡中，我正在运行：
SendWithUsInviteeMailerJob.perform_async(invitee.id)
这就开始了这里的工作：
class SendWithUsInviteeMailerJob
include Sidekiq::Worker
sidekiq_options queue: :mailer, retry: 2
def perform(invitee_id)
SendWithUsInviteeMailer.welcome(invitee_id).deliver
浏览 18提问于2017-02-02得票数 0
2回答
我有一个使用Sidekiq的应用程序。web服务器进程有时会将作业放在Sidekiq上，但我不一定会让worker运行。有没有我可以从Rails控制台调用的实用程序，它可以从Redis队列中拉出一个作业并运行适当的Sidekiq worker？
浏览 2提问于2015-02-26得票数 28
我想从后台作业中sign_out一个给定的用户？例如，从Sidekiq后台工作人员中注销给定用户。您知道如何从worker访问sign_out方法吗？
class SessionWorker
include Sidekiq::Worker
sidekiq_options retry: false
def perform(user_id)
# user = User.find(user_id)
# sign_out(user) if user
end
end
end
浏览 1提问于2014-05-15得票数 1
sidekiq.yml
:verbose: false
:pidfile: ./tmp/pids/sidekiq.pid
:logfile: ./log/sidekiq.log
:concurrency: 5
:queues:
- ["queue1", 1]
- ["queue2", 1]
- ["queue3", 1]
- ["queue4", 1]
- ["queue5", 1]
- critical
- default
- low
max_retries: 1
我想在每个队列
浏览 0提问于2019-03-21得票数 2
更新:现在意识到这是Sidekiq Pro唯一的功能。难怪它不起作用了。 我正在创建一个父批次，然后在其中创建子批次，但父作业在子批次完成之前“完成”。 我按照文档所说的做，唯一的区别是我不是直接在Sidekiq worker中创建子批处理，而是在worker调用的类中创建。 但是我正在传递批处理，并且已经确认子批处理具有与初始整体批处理相匹配的batch.parent_bid。 当我观看Sidekiq web时，我看到家长工人比所有的孩子先完成了很多，但我需要等待。想法？ 代码看起来像这样： overall = Sidekiq::Batch.new
overall.jobs do
浏览 8提问于2019-03-15得票数 0
2回答
我不能理解。如何获得sidekiq或resque worker任务的结果？例如：
class HardWorker
include Sidekiq::Worker
def perform(a, b)
a+b
end
end
HardWorker.perform_async(10,10)
如何获得结果？
浏览 2提问于2012-12-29得票数 0
我有这个配置文件给我现有的项目，我需要设置。
web: bundle exec unicorn -p $PORT -c ./config/unicorn.rb
worker: bundle exec rake jobs:work
sidekiq_worker: env DB_POOL=${SIDEKIQ_DB_POOL:-10} bundle exec sidekiq -c ${SIDEKIQ_CONCURRENCY:-4} -q $RAILS_ENV"_magplus_background_job" -i ${DYNO#worker.}
app_build_sidekiq_w
浏览 3提问于2016-11-17得票数 0
2回答
对象属性不在后台更新
、、、
我试图在后台通过一个受保护的方法来更新我的object body字段，使用sidekiq：
class BodyWorker
include Sidekiq::Worker
sidekiq_options retry: false
def perform(offer_id)
offer = Offer.find(offer_id)
remove_html(offer)
offer.publish!
end
protected
def remove_html(offer)
offer.body = '&#
浏览 0提问于2015-09-16得票数 1
3回答
我有一个sidekiq worker，它应该不会超过30秒，但几天后，我会发现整个worker队列停止执行，因为所有worker都被锁定。
这是我的工人：
class MyWorker
include Sidekiq::Worker
include Sidekiq::Status::Worker
sidekiq_options queue: :my_queue, retry: 5, timeout: 4.minutes
sidekiq_retry_in do |count|
5
end
sidekiq_retries_exhausted do |msg|
浏览 1提问于2014-04-04得票数 5
1回答
我在配置文件夹中创建了sidekiq.yml文件：
---
:concurrency: 25
:pidfile: ./tmp/pids/sidekiq.pid
:logfile: ./log/sidekiq.log
:queues:
-default
我在Rails项目中添加了foreman gem，并在根文件夹中创建了Procfile：
web: bundle exec rails s
worker: sidekiq -C config/sidekiq.yml
当我在命令行中运行foreman时，它只是不想启动。信息是：
C:\Users\lenovo\RubymineProjects\
浏览 1提问于2015-06-09得票数 0
回答已采纳
1回答
是否有可能将sidekiq作业直接从SidekiqWorker实例级移动到死队列(即在执行时)？
class MyWorker
include Sidekiq::Worker
sidekiq_options retry: 9
def perform(name)
if name == 'StackOverflow'
# ----> skip_retry_queue_and_go_to_dead_queue
else
# do_stuff!
end
end
end
浏览 0提问于2015-11-27得票数 12
我刚开始使用sidekiq & redis，并试图让sidekiq在Heroku上运行，但每次我部署Rails 4应用程序时，它似乎都会崩溃。我在文献记录中发现了这个错误：
May 03 11:16:37 myapp app/worker.1: No such file or directory @ rb_sysopen - ./log/sidekiq.log
May 03 11:16:37 myapp app/worker.1: /app/vendor/ruby-2.2.0/lib/ruby/2.2.0/logger.rb:636:in `initialize'
Ma
浏览 2提问于2015-05-03得票数 2
回答已采纳
1回答
因此，我使用的是Rails5和Ruby2.5版本(Mssql数据库)，我创建了两个sidekiq worker，并通过"perform_async“方法调用控制器中的sidekiq worker。我需要的是让这两个工人并行工作。但目前有一名工人正在工作。如何使这两个工人并行工作？
浏览 0提问于2020-08-26得票数 0
我有一个能捕获自定义异常的sidekiq中间件
require 'celluloid'
require 'sidekiq/middleware/server/retry_jobs'
module Sidekiq
class RetryMiddleware < Sidekiq::Middleware::Server::RetryJobs
def call(worker, msg, queue)
yield
rescue Sidekiq::Shutdown
# ignore, will be pushed bac
浏览 0提问于2015-11-07得票数 1
我有一个rails web应用程序，我正在与sidekiq集成一个后台进程。基本集成运行良好。 重点是我需要在循环中连续运行后台进程。根据另一篇文章，我创建了一个循环，该循环在初始化器中触发了worker。代码： sidekiq.rb Thread.new do
loop do
puts "Sidekiq.Initializer-->before perform worker"
MyWorker.perform_async()
puts "Sidekiq.Initializer-->after perform w
浏览 14提问于2020-04-23得票数 0
比方说，我有一位员工，他有几个对讲机：
class Foo
include Sidekiq::Worker
sidekiq_options queue: :critical
def perform(param1, param2, param3)
...
end
end
它工作了一段时间，然后我减少了工人的args数量：
class Foo
include Sidekiq::Worker
sidekiq_options queue: :critical
def perform(param1, param2)
...
end
end
但是，队列中
浏览 1提问于2016-08-04得票数 1
回答已采纳
4回答
我有一个永远在运行的工人。
class Worker
include Sidekiq::Worker
sidekiq_options queue: "infinity", retry: true
def perform(params)
# ...
self.class.perform_in(30.seconds, params)
end
end
问题是我在启动时加载工人，就像这样。config/initializers/load_workers.rb
Rails.application.config.after_initialize do
浏览 1提问于2014-04-18得票数 112
我有一个rails应用程序，它使用了sidekiq、sidekiq-status和sidekiq批处理：
gem "sidekiq"
gem "sidekiq-status"
# freemium version vs sidekiq pro https://github.com/breamware/sidekiq-batch
gem "sidekiq-batch"
# slim & sinatra for sidekiq monitoring
gem "sinatra", "2.0.0.beta2", r
浏览 6提问于2022-01-31得票数 0
回答已采纳
我有一个名为Connection的模型的before_destroy回调。
它看起来是这样的：
def run_my_worker
SomeWorker.perform_async(self.id)
end
该方法调用要执行的Sidekiq Worker。到Sidekiq worker运行时，模型已经被销毁，当我根据传递给Worker的id查询它时，它无法“找到”它。
我如何解决这个问题/这种情况的替代方案是什么？
浏览 3提问于2016-04-07得票数 0
我已经为在heroku生产环境上获得sidekiq工作而苦苦挣扎了两天。我已经阅读了所有关于类似问题的可用文档，但仍然无法产生一个有效的解决方案，我真的需要一些帮助！
在heroku上部署后，我的应用程序崩溃，并得到以下错误堆栈跟踪：
2014-09-23T23:38:40.905093+00:00 app[worker.1]: No such file or directory @ rb_sysopen - /app/tmp/pids/sidekiq.pid
2014-09-23T23:38:40.905122+00:00 app[worker.1]: /app/vendor/bundle/
浏览 49提问于2014-09-24得票数 19
回答已采纳
1回答
我在Sidekiq与多个工人和多个Sidekiq进程进行了一些斗争。
我想为一个环境运行三个侧翼进程。
我有三个工人类(比如"worker1“、"worker2”和"worker3")和三个侧翼进程(比如"process1“、"process2”和"process3")。
在我当前的结构中，工作人员正在任何可用的进程上运行。但是我想要的是worker1应该在process1上运行，worker2应该运行在process2上等等。
我对如何实现它感到有点困惑，如果我知道如何将一个工作人员设置为一个特定的侧翼进程，我会很高兴的
浏览 2提问于2015-09-11得票数 4
从Rails API中，我发现了ActiveJob can retry_job interval：
my_job_instance.enqueue
my_job_instance.enqueue wait: 5.minutes
my_job_instance.enqueue queue: :important
my_job_instance.enqueue wait_until: Date.tomorrow.midnight
但是，如果我想设置重试计数，例如Sidekiq的：
include Sidekiq::Worker
sidekiq_options :retry => 5
浏览 12提问于2015-10-15得票数 22
我有一个使用引擎的rails应用程序，其中定义了Sidekiq工人。worker的perform_async在引擎内的控制器中调用。worker的perform对通过该控制器传递的参数进行处理。worker类中也定义了特定于worker的队列。然而，当一个请求进入控制器时，它会被从“perform_async”推送到redis服务器的正确队列中。一个bundle exec sidekiq启动了Sidekiq。但是，工作者的perform永远不会被执行。检查sidekiq UI，我可以看到作业在正确的队列中。这是我的工人的样子
require 'pando'
class Pan
浏览 1提问于2014-11-07得票数 2
我计划从Heroku Scheduler转移到使用clockwork gem的自定义时钟过程。Heroku Scheduler将杀死一个任务，如果它没有在下一个预定的相同类型的任务之前完成。如何在Sidekiq中实现这一点？
鉴于超时不是线程安全的。在Sidekiq worker中这样做是个坏主意吗？
class RunsTooLongWorker
include Sidekiq::Worker
sidekiq_options :retry => false
def perform(*args)
Timeout::timeout(2.hours) do
浏览 1提问于2015-08-06得票数 1
1回答
为什么用户类的日志消息没有显示在Sidekiq日志窗口中？
expenses_worker.rb
class ExpensesWorker
include Sidekiq::Worker
def perform
logger.info "I am called from worker" #<-- it is visible in Sidekiq!
User.do_stuff
end
end
user.rb
class User < ActiveRecord::Base
self.do_stuff
logg
浏览 3提问于2015-11-22得票数 0
我目前正在从DJ迁移到sidekiq，并且有很多普通的旧ruby对象，我会这样使用它们： Delayed::Job.enqueue(SomeService.new(id)) 我想我可以将SomeService移到app/workers文件夹中并添加include Sidekiq::Worker，但是它永远不会进入sidekiq队列，而只是调用在现场执行 class SomeService
include Sidekiq::Worker
def initialize(id)
@some_instance = SomeClass.find_by(id: id)
end
浏览 11提问于2019-04-25得票数 2
我有一个Rails应用程序，它使用Procfile在heroku上自动启动sidekiq。我想让它在本地主机上自动启动sidekiq (我目前只是在一个单独的窗口中'bundle exec sidekiq‘)。下面是我的procfile：
web: bundle exec unicorn -p $PORT -c ./config/unicorn.rb
worker: bundle exec sidekiq
我该怎么做呢？我在本地安装了foreman
浏览 2提问于2014-06-03得票数 1
1回答
我已经设置了sidekiq来运行after_commit，但是它在使用ActiveRecord::RecordNotFound: Couldn't find User with id=42635时失败了(接近) 100%。
有很长一段时间，我以为它连接到了错误的redis数据库，但是在打开retry: true之后，我发现它最终在大约10分钟后成功了。
这是非常奇怪的，因为我可以看到我们的用户在管理面板中的id失败，但在一段时间内仍然会失败，然后重试将工作。我不知道是什么原因造成的，我想让它在第一次尝试成功。
编辑:使用AWS的，下面是sidekiq调用和worker：
In User
浏览 0提问于2014-03-21得票数 7
我有一个Rails 5应用程序，我开始使用Sidekiq，Heroku和Redis将各种工作转移到后台。 到目前为止，我有一个ResetFinanceDataWorker，它有一个同名的类。 //reset_finance_data_worker.rb
class ResetFinanceDataWorker
include Sidekiq::Worker
sidekiq_options retry: false
def perform()
end
end 我可以通过调用ResetFinanceDataWorker.perform_in(10.seconds)来调用它。理
浏览 16提问于2019-01-09得票数 0
回答已采纳
1回答
我的应用程序可以在DelayedJob上运行，但速度很慢，所以我决定切换到Sidekiq。
到目前为止，它还没有与Sidekiq一起进行测试或开发。(当然，我也没有尝试过使用Sidekiq来推动生产。)
从DelayedJob迁移到Sidekiq时，我首先更新了我的Profile
web: bundle exec unicorn -p $PORT -c ./config/unicorn.rb
# worker: bundle exec rake jobs:work
before_fork do |server, worker|
@sidekiq_pid ||= spawn("b
浏览 1提问于2014-01-20得票数 1
我的Rails应用程序中有一个控制器操作，可以通过文本消息和电子邮件与用户联系。由于我不会详细介绍的原因，在成功发送电子邮件之前，需要完成文本消息。我最初有这样的东西：
控制器：
class MyController < ApplicationController
def contact_user
ContactUserWorker.perform_async(@user.id)
end
end
员工：
class ContactUserWorker
include Sidekiq::Worker
def perform(user_id)
SendUse
浏览 0提问于2014-06-11得票数 2
回答已采纳
1回答
我有多个工作人员，每个工作人员基于WorkerClass指定的队列、并发性等进行分离。它们是通过cron作业触发的。
nohup bundle exec sidekiq -q worker1 -c 5 -e production
nohup bundle exec sidekiq -q worker2 -c 5 -e production
nohup bundle exec sidekiq -q worker3 -c 5 -e production
nohup bundle exec sidekiq -q worker4 -c 5 -e production
nohup bundle exec
浏览 6提问于2013-09-15得票数 1
回答已采纳
我试着用铁轨跑边工。当我尝试docker-compose up worker时，我得到以下错误：
worker_1 | Error connecting to Redis on 127.0.0.1:6379 (Errno::ECONNREFUSED)
worker_1 | /home/app/Nyvur/vendor/bundle/ruby/2.2.0/gems/redis-3.2.2/lib/redis/client.rb:332:in `rescue in establish_connection'
worker_1 | /home/app/Nyvur/vendor/bundle/
浏览 17提问于2016-01-11得票数 50
回答已采纳
是否可以从Sidekiq通过Mongoid编写MongoDB文档？
# lib/worker.rb
require 'sidekiq'
require 'model' # lib/model.rb
class AwesomeWorker
include Sidekiq::Worker
def perform
RandomNumberModel.create! { random_number: Random.new.rand(1..100) }
end
end
运行Sidekiq时，它返回uninitialized constant Aweso
浏览 3提问于2015-04-06得票数 0
回答已采纳
我正试着在我的应用中使用Sidekiq，但由于某种原因我得到了一个undefined local variable or method "worker" for #<SolutionController:0xb55bc358>
我已经为Sidekiq web UI安装了sidekiq，sinatra和slim，它没有注册任何东西。现在我确实让sidekiq在另一个终端窗口中运行。
Worker调用：
worker.perform_async(@user)
我的员工：
# app/workers/worker.rb
class worker
incl
浏览 0提问于2014-04-20得票数 1
假设我有一个这样的Sidekiq工人：
class MyWorker
include Sidekiq::Worker
def perform
message = SomeImportantClass.new.get_message
flash.now[:notice] = message
end
end
因此，当用户访问页面时，worker将启动。在不离开页面的情况下，用户可以从Sidekiq worker获得通知。我在这个领域没有太多的经验，所以我不知道从哪里开始。
浏览 1提问于2016-03-02得票数 0
我最近开始使用Sidekiq，并注意到它有一个我已经搜索了很久的特性：
UserMailer.delay_until(5.days.from_now).find_more_friends_email
基本上，我可以安排一份工作在未来，所以我不需要我的应用程序不断轮询新事件的开始时间。
现在这就像一种魅力，但是我如何改变工作的开始时间呢？通常，一些排定的活动会改变其开始时间。我该如何在侧翼复制这个呢？
我知道我可以删除这个作业并创建一个新的作业，但是是否可以仅仅修改开始时间？
编辑
我以Oto Brglez的想法为基础，下面是有文档记录的代码：
module TaskStuff
class
浏览 6提问于2013-04-16得票数 14
回答已采纳
您可以设置在过程文件中使用的环境变量的。我正在尝试设置一个SIDEKIQ_CONCURRENCY变量，以便我的登台环境为Sidekiq分配的工作者比我的生产环境少。
我将新变量设置如下：
heroku config:set SIDEKIQ_CONCURRENCY=3 --app mystaging
heroku config:set SIDEKIQ_CONCURRENCY=15 --app myproduction
然后，我将以下行添加到我的procfile中：
worker: bundle exec sidekiq -c ENV[SIDEKIQ_CONCURRENCY]
我还尝试了这个：
浏览 1提问于2014-02-08得票数 1
我试图在Crystal中运行一个Sidekiq示例，但是在Sidekiq日志中有一个错误：
2016-11-03T13:18:22.430Z 19329 TID-uvtuk WARN: {"queue"=>"default", "jid"=>"84853f6ac0bf8d434ec0beee", "class"=>"Sample::MyWorker", "args"=>["world", 3], "created_at"=>
浏览 0提问于2016-11-03得票数 0
回答已采纳
sidekiq_retries_exhausted不被调用的原因可能是什么？我是不是遗漏了什么设置？
可能有什么东西覆盖了sidekiq_options retry: 1，并且worker一直在重试，但是是什么呢？
class SomeWorker
include Sidekiq::Worker
sidekiq_options retry: 1
sidekiq_retries_exhausted do |msg|
# => never hit this point
Rails.logger.info "tried two times, failed
浏览 0提问于2019-02-06得票数 0
它显示了错误的参数数，但我要传递3个参数。
ScannerWorker.perform_async('bob1','bob2',5)
这里是侧翼工人代码
class ScannerWorker
include Sidekiq::Worker
def perform(bob1, bob2, bob3)
puts bob1
end
end
侧翼版本：- 4.2.7
rails 4.2.6
Redis服务器v=3.0.7
Sidekiq错误：
2017-01-03T06:29:43.007Z 9547 TID-itjjk WARN: Ar
浏览 2提问于2017-01-03得票数 6
回答已采纳
我正在尝试在Heroku worker中初始化Sidekiq，使用：
if Rails.env.production?
Sidekiq.configure_client do |config|
config.redis = { url: ENV['REDISCLOUD_URL'], size: 2 }
end
Sidekiq.configure_server do |config|
config.redis = { url: ENV['REDISCLOUD_URL'], size: 10 }
Rails.applicat
浏览 0提问于2017-04-13得票数 0
2回答
我在mac上使用的是Rails 5.0.1，我刚刚通过homebrew安装了redis，并在我的Gemfile中安装了这个
gem 'sidekiq'
我有这个文件，app/worker/run_crawlers_worker.rb，...
class MyWorker
include Sidekiq::Worker
def perform()
puts "about to fire up service ..."
svc = MyService.new
svc.do_tasks
puts "done invo
浏览 0提问于2017-05-24得票数 2
所以我的模型中有一个Sidekiq worker，看起来像这样：
class Perk < ActiveRecord::Base
include Sidekiq::Worker
include Sidekiq::Status::Worker
after_save :update_release_time
def update_release_time
if self.release_time_changed?
#if scheduled job already exists then cancel and reschedule
# Sidekiq::Statu
浏览 5提问于2014-06-12得票数 7
云服务器
ICP备案
对象存储
腾讯会议
实时音视频
腾讯云开发者
