草庐IT

ActiveJob

全部标签

ruby-on-rails - rspec rails 测试 : how can I force ActiveJob job's to run inline for certain tests?

我希望我的后台作业能够内联运行某些标记测试。我可以通过用perform_enqueueddo包装测试来做到这一点,但我希望能够用元数据标记它们,如果可能的话,它会自动发生。我试过以下方法:it"doeseverythinginthejobtoo",perform_enqueued:truedoendconfig.around(:each)do|example|ifexample.metadata[:perform_enqueued]perform_enqueued_jobsdoexample.runendendend但它会导致错误:undefinedmethod`perform_enq

ruby-on-rails - 如何将自定义 delayed_job 作业与 ActiveJob 一起使用?

我正在使用DelayedJob,我想更新我的Rails4.2应用程序以使用ActiveJob。问题是我有一堆看起来像这样的自定义作业:AssetDeleteJob=Struct.new(:user_id,:params)dodefperform#codeend#moremethodsn'stuffend然后在某处的Controller中,作业使用以下语法排队:@asset_delete_job=AssetDeleteJob.new(current_admin_user.id,params)Delayed::Job.enqueue@asset_delete_job我想找到ActiveJo

ruby - ActiveJob::SerializationError - 不支持的参数类型:Time/DateTime

我正在使用Rails5和ActiveJob来处理后台任务。我正在尝试将使用as_json序列化的对象传递给我的工作,但我收到以下错误:ActiveJob::SerializationError(Unsupportedargumenttype:Time):ActiveJob::SerializationError(Unsupportedargumenttype:DateTime):我知道ActiveJob不会接受Time/DateTime对象,因为一些排队系统不处理这些类型。所以我要序列化的对象如下:card=Card.first=>#当我运行时:card.as_json=>{"id"=

ruby-on-rails - 如何访问 ActiveJob 救援中的执行参数

我想知道您如何访问救援block中的ActiveJob执行参数,例如defperformobjectendrescue_fromExceptiondo|e|ife.class!=ActiveRecord::RecordNotFound**job.arguments.first**#dosomethingendend谢谢!! 最佳答案 在rescue_fromblock中使用arguments是可能的:rescue_from(StandardError)do|exception|user=arguments[0]post=argume

ruby-on-rails - ActiveJob 是否有具有特定优先级的队列?

查看下面的作业,我假设该作业在low_priority队列上运行。classGuestsCleanupJob我同意这一点,但这只是队列的名称对吗?它实际上与优先级无关。例如,如果我创建了一个队列名为:my_queue的作业,它将被视为具有与:low_priority队列相同的优先级。从文档中我无法找到任何表明我可以对排队的作业进行优先排序的信息。我知道delayed_jobs有这个功能,但我在active_job中没有找到它。 最佳答案 优先级取决于实际的QueueAdapter以及此适配器的配置方式。如果您的适配器不支持优先级或未

ruby-on-rails - 如何在 Rails ActiveJob 中创建日常工作(类似 cron)?

我知道这个线程:Acronjobforrails:bestpractices?,但没有提到ActiveJob。我使用ActiveJob的动机是因为它内置于Rails中,下面是其文档的摘录:“这些工作可以是一切,从定期安排的清理,到计费,再到邮寄。”如何在RailsActiveJob中创建日常工作(类似cron)?因为我没有在itsdocs中看到运行定期计划作业的示例.还是我应该坚持使用whenevergem? 最佳答案 坚持使用whenevergem或类似的gem,例如chrono,clockwork,rufus-scheduler

ruby-on-rails - SerializationError Rails ActiveJob 时间和日期

有人知道在尝试序列化Date或Time对象时避免发生ActiveJob::SerializationError的干净方法吗?到目前为止,我有两个解决方案:在加载参数时调用Marshal/JSON/YAMLdump然后load回到作业中(这很糟糕,因为我需要猴子修补邮件作业)猴子补丁Date和Time像这样:/lib/core_ext/time.rbclassTimeincludeGlobalID::Identificationdefidself.to_ienddefself.find(id)self.at(id.to_i)endend/lib/core_ext/date.rbclass

ruby-on-rails - 如何使用 Rspec 检查 ActiveJob 中排队的内容

我正在RailsAPI应用程序中使用reset_password方法。当这个端点被命中时,一个ActiveJob被排队,它将触发对Mandrill(我们的交易电子邮件客户端)的请求。我目前正在尝试编写测试以确保在命中Controller端点时ActiveJob正确排队。defreset_password@user=User.find_by(email:params[:user][:email])@user.send_reset_password_instructionsendsend_reset_password_instructions在创建代码如下的ActiveJob之前创建一些u

mysql - 当数据库不可用时,延迟的工作人员退出

我在分布式系统上使用mysql将延迟作业与ActiveRecord后端一起使用。每当我重新启动mysql数据库时,工作人员就会停止。根据日志,每个工作人员尝试以5秒的间隔重新连接8次,然后退出并显示FATAL--:MySQLclientisnotconnected消息。这意味着每次我重新启动数据库时,我还必须重新启动所有工作程序。有没有办法增加重连尝试的次数? 最佳答案 在工作中:classMyJob如果您希望此重试行为成为所有作业的默认行为,请考虑将此行放在ApplicationJob中,并让你所有的工作都继承自它。官方文档的默认

ruby-on-rails - 让 ActiveJob 和 Sidekiq 与 ActionCable 一起用于聊天室

所以我一直在关注DHH的教程,以实现一个基本的聊天室。在我尝试集成ActiveJob组件之前,该实现对我来说已经足够好了。我在rails或sidekiq控制台中没有看到任何错误消息。但是_message部分没有被渲染。当我在ActiveJob方法中放置一个binding.pry时,所有元素看起来都很好,所以我猜这与作业执行有关?为了进一步支持这种怀疑,当我调用ActionCable.server.broadcast('room_channel',message:data['message'])在room_channel.rb中它工作得很好!我在这上面花了几个小时,但无法弄清楚如何进一步