草庐IT

sidekiq-superworker

全部标签

ruby-on-rails - Ruby on Rails + Sidekiq : How do I change a scheduled job start time?

我最近开始使用Sidekiq并注意到它有一个我一直在寻找的很棒的功能:UserMailer.delay_until(5.days.from_now).find_more_friends_email基本上我可以在未来安排工作,所以我不需要我的应用程序持续轮询具有开始时间的新事件。现在这很有用,但我如何更改作业的开始时间?通常一些预定的事件会更改其开始时间。我如何在sidekiq中复制它?我知道我可以删除作业并创建一个新作业,但是否可以只修改开始时间?编辑:我建立在OtoBrglez的想法之上,这里是记录的代码:moduleTaskStuffclassTaskSetterincludeSi

ruby-on-rails - 将 sidekiq 作业直接移至死队列

是否可以将sidekiq作业从SidekiqWorker实例级别直接移动到死队列(即在执行时)classMyWorkerincludeSidekiq::Workersidekiq_optionsretry:9defperform(name)ifname=='StackOverflow'#---->skip_retry_queue_and_go_to_dead_queueelse#do_stuff!endendend 最佳答案 在执行作业中不是动态的。静态地,如果您设置sidekiq_optionsretry:0,如果作业引发错误,它

ruby - Sidekiq 现任赛璐珞 Actor

我需要在我的Sidekiqworker中访问当前的赛璐珞Actor,但我看不到这样做的方法。每当我尝试调用:Celluloid::Actor.current我收到一个错误:不在actor范围内我试图通过每次创建一个新Actor来绕过寻找当前Actor:Celluloid::Actor.new(SecureRandom.hex)但出于某种原因,它给我一个错误:attemptedtocalldeadactor。我应该做些什么不同的事情来让当前的actor进入Sidekiqworker?背景信息我正在连接到我的工作人员中的websocket并向它发送消息。Celluloid::WebSock

ruby - 在开发环境中使用 rails server 启动 Sidekiq

我正在使用Sidekiq对于我的一些后台进程。目前我做的是:在一个终端上启动bundleexecrailss,然后在另一个终端上启动bundleexecsidekiq,以便sidekiq自行启动并寻找要处理的作业。我想要的是:一旦我启动bundleexecrailss,它也应该启动sidekiqbundleexecsidekiq。我怎样才能将它集成到开发环境中?? 最佳答案 对于像您这样需要运行大量服务的应用,请考虑使用foreman和一个Procfile来定义这些进程。然后您可以使用foremanstart在一个终端中运行所有这些

ruby - 没有 Rails 的 Sidekiq 不会加载工作类

我正在使用Sidekiq3.1.2没有Rails像这样:$sidekiq-vrsidekiq.rbsidekiq.rb看起来像这样:($LOAD_PATHlib/workers/lookup_worker.rb看起来像这样:require'sidekiq'classLookupWorkerincludeSidekiq::Workerdefperform(*args)puts"LookupWorker#performfiredwitharguments#{args.map(&:inspect).join(',')}"endend但是当我在irb并尝试>LookupWorker.perfo

ruby-on-rails - 在 Sidekiq 的任何地方找到工作的最佳方式

是否有一种简单的方法来搜索特定作业的所有sidekiq(队列、重试、计划等)?目前我正在这样做:if!Sidekiq::Queue.new("feeds").find{|j|j.args[0]==feed.id&&j.args[1]==true}if!Sidekiq::RetrySet.new.find{|j|j.queue=='feeds'&&j.args[0]==feed.id&&j.args[1]==true}if!Sidekiq::ScheduledSet.new.find{|j|j.queue=='feeds'&&j.args[0]==feed.id&&j.args[1]==

ruby - 作业中的 Sidekiq 重试计数

有没有办法获取当前作业的重试次数?我希望作业在x次重试后停止,而不是崩溃。我想在perform方法中询问重试次数,这样我就可以在重试次数等于x时简单地返回。defperform(args)returnifretry_count>5...end使用Sidekiq2.12。编辑我(不是OP)有同样的问题,但出于不同的原因。如果正在重试该作业,我想进行额外的健全性检查以确保需要该作业,并在不再期望它成功时停止重试,因为它在排队后发生了外部变化。那么,有没有办法获取当前作业的重试次数呢?当前的答案仅建议您可以绕过需要它或可以从工作之外获得它的方法。 最佳答案

ruby-on-rails - Sidekiq:确保队列中的所有作业都是唯一的

我有一些更新触发器可以将作业推送到Sidekiq队列中。因此在某些情况下,可以有多个作业来处理同一个对象。有几个唯一性插件("Middleware"、UniqueJobs),它们的文档记录不多,但它们似乎更像是防止重复处理的节流器;我想要的是一个阻止重复创建相同作业的节流器。这样,对象将始终以其最新状态进行处理。有这方面的插件或技术吗?更新:我没有时间制作中间件,但我最终得到了一个相关的清理函数来确保队列是唯一的:https://gist.github.com/mahemoff/bf419c568c525f0af903 最佳答案 简

ruby-on-rails - Sidekiq:失败作业的重试更改率?

我有特定类型的作业,我希望重试的频率高于默认Sidekiq间隔设置的频率。这目前可能吗?理想情况下,作业将每5秒重试一次,最多一分钟。不完全确定这是目前插入Sidekiq作业的微不足道的事情。 最佳答案 根据:https://github.com/mperham/sidekiq/wiki/Error-Handling你可以这样做:classWorkerincludeSidekiq::Workersidekiq_retry_indo|count|5endend 关于ruby-on-rail

ruby-on-rails - Sidekiq 和 rails 4 actionmailer 从不发送电子邮件

我在Rails4应用程序中设置了sidekiq,用于发送电子邮件和处理后台作业。我还设计了我正在使用的devise_async和典型的联系表单电子邮件。我正在使用gmail发送电子邮件。如果我删除sidekiq,它通常会通过gmail(设计和联系表单)发送电子邮件,但是当我启用它时,它不起作用(devise_async和联系表单都没有)。Sidekiq显示后台作业成功启动和完成(我也通过sinatra应用程序看到它们已被处理)但电子邮件从未送达。在开发中,控制台显示已发送电子邮件(使用devise_async和联系表单,因为它们已使用sidekiq成功处理)。我已经尝试过的:我已经为s