job的使用--执行

首先，命名和文件位置：app/jobs/xx_job.rb,

内容上：一种是继承application

cat app/jobs/application_job.rb
class ApplicationJob < ActiveJob::Base
  # Automatically retry jobs that encountered a deadlock
  # retry_on ActiveRecord::Deadlocked

  # Most jobs are safe to ignore if the underlying records are no longer available
  # discard_on ActiveJob::DeserializationError
end

cat app/jobs/say_hi_job.rb
class SayHiJob < ApplicationJob
  queue_as :default

&nbsp; def perform(args)<br />
&nbsp;&nbsp;&nbsp; # 演示如何获得参数<br />
&nbsp;&nbsp;&nbsp; name = args[:name]<br />
&nbsp;&nbsp;&nbsp; content = args[:content]<br />
&nbsp;&nbsp;&nbsp; puts &quot;in SayHiJob, name: #{name}, content: #{content}&quot;

    # 如何执行代码
    avatar = Avatar.new
    avatar.account_id = 1
    avatar.nft_asset_id = 1
    avatar.is_primary = false
    avatar.save!
  end
end

一种是自己：

cat app/jobs/guests_cleanup_job.rb<br />
class GuestsCleanupJob &lt; ActiveJob::Base<br />
&nbsp; queue_as :default

&nbsp; def perform(*args)<br />
&nbsp;&nbsp;&nbsp; # Do something later<br />
&nbsp; end<br />
end

执行： 进入console

bundle exec rails c

reload!<br />
Reloading...<br />
=&gt; true<br />
irb(main):002:0&gt; YunPianJob.perform_later<br />
Enqueued YunPianJob (Job ID: d5de572f-4f20-4db6-9263-2166b854ca07) to Async(default)<br />
=&gt;<br />
#&lt;YunPianJob:0x0000564abab51700<br />
&nbsp;@arguments=[],<br />
&nbsp;@exception_executions={},<br />
&nbsp;@executions=0,<br />
&nbsp;@job_id=&quot;d5de572f-4f20-4db6-9263-2166b854ca07&quot;,<br />
&nbsp;@priority=nil,<br />
&nbsp;@provider_job_id=&quot;456f4b94-a56e-47ed-97a4-884aa9c9a007&quot;,<br />
&nbsp;@queue_name=&quot;default&quot;,<br />
&nbsp;@timezone=&quot;UTC&quot;&gt;<br />
Performing YunPianJob (Job ID: d5de572f-4f20-4db6-9263-2166b854ca07) from Async(default) enqueued at 2022-06-13T01:21:30Z