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
Передаваемые записи сериализуются/десериализуются с использованием Global ID. Более подробную информацию можно найти в 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–2020 David Heinemeier Hansson
Licensed under the MIT License.