class ActiveJob::Base
Базовый класс Active Job
Объекты Active Job могут быть настроены для работы с различными фреймворками очереди заднего плана. Для указания используемого адаптера очереди:
ActiveJob::Base.queue_adapter = :inline
Список поддерживаемых адаптеров можно найти в QueueAdapters.
Объекты Active Job могут быть определены путём создания класса, который наследуется от класса ActiveJob::Base. Единственным необходимым методом для реализации является метод «perform».
Для определения объекта Active Job:
class ProcessPhotoJob < ActiveJob::Base
def perform(photo)
photo.watermark!('Rails')
photo.rotate!(90.degrees)
photo.resize_to_fit!(300, 300)
photo.upload!
end
end
Записи, которые передаются, сериализуются/десериализуются с использованием глобального идентификатора. Дополнительную информацию можно найти в Arguments.
Для добавления задачи в очередь для выполнения, как только система очереди освободится:
ProcessPhotoJob.perform_later(photo)
Для добавления задачи в очередь для обработки в какой-то момент в будущем:
ProcessPhotoJob.set(wait_until: Date.tomorrow.noon).perform_later(photo)
Дополнительную информацию можно найти в ActiveJob::Core::ClassMethods#set
Задача также может быть обработана немедленно без отправки в очередь:
ProcessPhotoJob.perform_now(photo)
Exceptions
-
DeserializationError- Класс ошибок десериализации. -
SerializationError- Класс ошибок сериализации.
© 2004–2021 David Heinemeier Hansson
Licensed under the MIT License.