Active Job 기본 사항

$ bin/rails generate job guests_cleanup
invoke  test_unit
create    test/jobs/guests_cleanup_job_test.rb
create  app/jobs/guests_cleanup_job.rb

$ bin/rails generate job guests_cleanup --queue urgent

class GuestsCleanupJob < ApplicationJob
  queue_as :default

  def perform(*guests)
    # 나중에 무언가를 수행합니다
  end
end

$ bin/rails generate job process_payment --parent=payment_job

class ProcessPaymentJob < PaymentJob
  queue_as :default

  def perform(*args)
    # 나중에 무언가를 수행합니다
  end
end

# 큐 시스템이 비어있을 때 즉시 실행될 작업을 큐에 넣습니다.
GuestsCleanupJob.perform_later guest

# 내일 정오에 실행될 작업을 큐에 넣습니다.
GuestsCleanupJob.set(wait_until: Date.tomorrow.noon).perform_later(guest)

# 1주일 후에 실행될 작업을 큐에 넣습니다.
GuestsCleanupJob.set(wait: 1.week).perform_later(guest)

# `perform_now` 및 `perform_later`는 내부적으로 `perform`를 호출하므로
# 후자에서 정의된대로 많은 인수를 전달할 수 있습니다.
GuestsCleanupJob.perform_later(guest1, guest2, filter: 'some_filter')

# config/application.rb
module YourApp
  class Application < Rails::Application
    # 어댑터의 gem이 Gemfile에 있고
    # 어댑터의 특정 설치 및 배포 지침을 따르십시오.
    config.active_job.queue_adapter = :sidekiq
  end
end

class GuestsCleanupJob < ApplicationJob
  self.queue_adapter = :resque
  # ...
end

# 이제 작업은 `resque`를 백엔드 큐 어댑터로 사용하며,
# `config.active_job.queue_adapter`에 구성된 것을 무시합니다.

class GuestsCleanupJob < ApplicationJob
  queue_as :low_priority
  # ...
end

# config/application.rb
module YourApp
  class Application < Rails::Application
    config.active_job.queue_name_prefix = Rails.env
  end
end

# app/jobs/guests_cleanup_job.rb
class GuestsCleanupJob < ApplicationJob
  queue_as :low_priority
  # ...
end

# 이제 작업은 프로덕션 환경에서 production_low_priority 큐에서 실행되며,
# 스테이징 환경에서는 staging_low_priority 큐에서 실행됩니다.

class GuestsCleanupJob < ApplicationJob
  queue_as :low_priority
  self.queue_name_prefix = nil
  # ...
end

# 이제 작업의 큐 이름에는 접두사가 없으며, `config.active_job.queue_name_prefix`에서 구성한 것을 무시합니다.

# config/application.rb
module YourApp
  class Application < Rails::Application
    config.active_job.queue_name_prefix = Rails.env
    config.active_job.queue_name_delimiter = '.'
  end
end

# app/jobs/guests_cleanup_job.rb
class GuestsCleanupJob < ApplicationJob
  queue_as :low_priority
  # ...
end

# 이제 작업은 프로덕션 환경에서 production.low_priority 큐에서 실행되며,
# 스테이징 환경에서는 staging.low_priority 큐에서 실행됩니다.

MyJob.set(queue: :another_queue).perform_later(record)

class ProcessVideoJob < ApplicationJob
  queue_as do
    video = self.arguments.first
    if video.owner.premium?
      :premium_videojobs
    else
      :videojobs
    end
  end

  def perform(video)
    # 비디오 처리 수행
  end
end

ProcessVideoJob.perform_later(Video.last)

class GuestsCleanupJob < ApplicationJob
  queue_as :default

  around_perform :around_cleanup

  def perform
    # 나중에 무언가 수행
  end

  private
    def around_cleanup
      # 수행 전에 무언가 수행
      yield
      # 수행 후에 무언가 수행
    end
end

class ApplicationJob < ActiveJob::Base
  before_enqueue { |job| $statsd.increment "#{job.class.name.underscore}.enqueue" }
end

# 지금 이메일을 보내려면 #deliver_now를 사용합니다.
UserMailer.welcome(@user).deliver_now

# Active Job을 통해 이메일을 보내려면 #deliver_later를 사용합니다.
UserMailer.welcome(@user).deliver_later

I18n.locale = :eo

UserMailer.welcome(@user).deliver_later # 이메일은 에스페란토로 지역화됩니다.

class TrashableCleanupJob < ApplicationJob
  def perform(trashable_class, trashable_id, depth)
    trashable = trashable_class.constantize.find(trashable_id)
    trashable.cleanup(depth)
  end
end

class TrashableCleanupJob < ApplicationJob
  def perform(trashable, depth)
    trashable.cleanup(depth)
  end
end

# app/serializers/money_serializer.rb
class MoneySerializer < ActiveJob::Serializers::ObjectSerializer
  # 이 직렬화기가 인수를 직렬화해야 하는지 확인합니다.
  def serialize?(argument)
    argument.is_a? Money
  end

  # 지원되는 객체 유형을 사용하여 객체를 더 간단한 대표값으로 변환합니다.
  # 권장되는 대표값은 특정 키를 가진 해시입니다. 키는 기본 유형만 사용할 수 있습니다.
  # 사용자 정의 직렬화기 유형을 해시에 추가하려면 `super`를 호출해야 합니다.
  def serialize(money)
    super(
      "amount" => money.amount,
      "currency" => money.currency
    )
  end

  # 직렬화된 값을 적절한 객체로 변환합니다.
  def deserialize(hash)
    Money.new(hash["amount"], hash["currency"])
  end
end

# config/initializers/custom_serializers.rb
Rails.application.config.active_job.custom_serializers << MoneySerializer

# config/application.rb
module YourApp
  class Application < Rails::Application
    config.autoload_once_paths << Rails.root.join('app', 'serializers')
  end
end

class GuestsCleanupJob < ApplicationJob
  queue_as :default

  rescue_from(ActiveRecord::RecordNotFound) do |exception|
    # 예외 처리
  end

  def perform
    # 나중에 수행할 작업
  end
end

class RemoteServiceJob < ApplicationJob
  retry_on CustomAppException # 기본값은 3초 대기, 5번 시도

  discard_on ActiveJob::DeserializationError

  def perform(*args)
    # CustomAppException 또는 ActiveJob::DeserializationError가 발생할 수 있음
  end
end