草庐IT

sidekiq-superworker

全部标签

ruby - 如何检测我的代码运行的是 "inside"Sidekiq 服务器还是 Puma?

我使用Puma作为网络服务器,使用Sidekiq作为我的队列运行器。对于多种事物(数据库连接、Redis连接、其他外部服务),我使用ConnectionPoolgem来管理对连接的安全访问。现在,根据我是在Sidekiq还是Puma的上下文中运行,我需要这些池的大小不同(分别与Sidekiq线程或Puma线程的数量一样大,而且它们是不同的)在您的初始化程序中,根据执行上下文了解连接池大小的最佳方法是什么?谢谢! 最佳答案 您使用Sidekiq.server?当不在Sidekiq进程本身内运行时返回nil。

ruby - sidekiq 取消计划作业列表

我有几个这样运行的预定作业:MyWorker.perform_at(3.hours.from_now,'mike',1)我在想,如果稍后,比如说一个小时后,我想取消这份工作,我会怎么做呢? 最佳答案 我最近写了一些代码来处理这个问题,它可以在我的sidekiq-statusgem分支中找到。您可以在此处查看或使用它:https://github.com/Robinson7D/sidekiq-status(目前,您必须将它用作gemfile中的git:信息,直到项目的主分支实现它)要使用它,首先要存储job_identifier:jo

ruby - Sidekiq 如何将参数传递给 perform 方法?

我有这个Sidekiqworker:classDealNoteWorkerincludeSidekiq::Workersidekiq_optionsqueue::emaildefperform(options={})ifoptions[:type]=="deal_watch_mailer"deal_watchers=DealWatcher.where("deal_id=?",options[:deal_id])deal_note=DealNote.find(options[:deal_note_id])current_user=User.find(options[:current_us

ruby - 同时运行延迟作业和 Sidekiq

我目前使用延迟作业来异步处理作业。我没有创建worker,而是经常使用.delay方法。我想转到Sidekiq,但是我的工作类型太多,无法确保所有工作都是线程安全的。所以我想并行运行DelayedJob和Sidekiq,并一次迁移一种类型的作业。既然DelayedJob和Sidekiq都提供了.delay方法,那么如何区分两者呢?还有其他潜在问题吗? 最佳答案 对于Sidekiq2.17.1及更高版本,在Rails初始化程序的某处,调用以下命令:Sidekiq.hook_rails!Sidekiq.remove_delay!并且您将

ruby - Rails 4.2 - Sidekiq 在开发中不发送电子邮件

我有一个Rails应用程序,我可以在其中发送大量电子邮件。我想执行此操作异步。为此,我尝试使用Sidekiq,但我无法让它正常工作——它不发送任何电子邮件。发送电子邮件之前有效,所以我确定我的电子邮件设置正确。在我的gemfile中我有这个:gem'sidekiq'我已经运行了bundleinstall。我还安装了redis,按照RailsCasts#366上的说明进行操作.我已经使用以下命令启动了sidekiq:bundleexecsidekiq,结果如下图所示:在application.rb我有以下内容:config.active_job.queue_adapter=:sideki

ruby-on-rails - 登录 Sidekiq worker

我正在尝试在开发中使用tail-flog/development.log并在生产中使用herokulogs来记录我的sideqikworker的进度。但是,worker内部的所有内容以及worker调用的所有内容都不会被记录。在下面的代码中,仅记录TEST1。如何记录工作人员内部的所有内容以及工作人员调用的类?#app/controllers/TasksController.rbdefimport_dataRails.logger.info"TEST1"#showsupindevelopment.logDataImportWorker.perform_asyncrender"done"

ruby-on-rails - 多种环境的 Sidekiq 配置

我查看了多个来源并尝试了各种方案,但无法解决这个问题。请指出正确的方向。和每个人一样,我有3个环境(开发、暂存和生产)。我的sidekiq.yml文件中有以下内容#Optionsherecanstillbeoverriddenbycmdlineargs.#sidekiq-Cconfig.yml---:verbose:false:namespace:xyz:logfile:log/sidekiq.log:concurrency:25:strict:false:pidfile:tmp/pids/sidekiq.pid:queues:-[stg_xyz_tests_queue,10]-[st

ruby-on-rails - Sidekiq 工作人员没有被触发

我正在使用Sidekiq对于我的后台工作:我有一个workerapp/workers/data_import_worker.rbclassDataImportWorkerincludeSidekiq::Workersidekiq_optionsretry:falsedefperform(job_id,file_name)begin#Somelogicinit.....endend从文件lib/parse_excel.rb调用defparse_raw_data#job_idand#filenamearedefinedbfrDataImportWorker.perform_async(jo

ruby - 重启 Sidekiq

重启sidekiq的正确方法是什么。它似乎在我启动它时缓存了我的worker代码,所以每次我对我的worker进行更改时我都需要重新启动它。我正在使用Ctrl/C执行此操作,但该过程需要很长时间才能结束并返回到提示符。有没有办法立即强制重启?我使用的是通过POW运行的Sinatra的最新版本。 最佳答案 Sidekiq自带命令sidekiqctl,可以停止与你的Sidekiq进程关联的PID。您传入PID文件和等待所有线程完成的秒数。示例用法:sidekiqctlstop#{rails_root}/tmp/pids/sidekiq_

ruby-on-rails - 监控 Sidekiq 作业完成情况的最佳方式?

我正在使用Sidekiqworker在用户首次登录后完成对Facebook的一些请求。通常该任务大约需要20秒左右。我想在同步完成后立即使用ajax请求将一些信息加载到页面上,但不确定使用Javascript检查作业完成情况的最佳方式。一种可能性是配置Sidekiqworker在完成其余工作后设置cookie。然后我可以使用setTimeout函数在调用加载函数之前继续检查cookie。但我不确定这是否是最好的方法。我可以改用Redis吗? 最佳答案 Paul,最初你必须看一下这个PubSubonRailstutorial!当异步事