Spec-Zone.ru › Ruby on Rails 7.2

модуль ActiveJob::QueueAdapters

Адаптеры Active Job

Active Job имеет адаптеры для следующих бэкэндов очередей:

  • Backburner

  • Delayed Job

  • Que

  • queue_classic

  • Resque

  • Sidekiq

  • Sneakers

  • Sucker Punch

  • Примечание: мы не принимаем запросы на создание новых адаптеров. Подробнее см. в README.

Для тестирования и разработки Active Job имеет три встроенных адаптера:

  • Асинхронный адаптер Active Job

  • Встроенный адаптер Active Job

  • Тестовый адаптер Active Job

Функции бэкэндов

|                   | Async | Queues | Delayed    | Priorities | Timeout | Retries |
|-------------------|-------|--------|------------|------------|---------|---------|
| Backburner        | Yes   | Yes    | Yes        | Yes        | Job     | Global  |
| Delayed Job       | Yes   | Yes    | Yes        | Job        | Global  | Global  |
| Que               | Yes   | Yes    | Yes        | Job        | No      | Job     |
| queue_classic     | Yes   | Yes    | Yes*       | No         | No      | No      |
| Resque            | Yes   | Yes    | Yes (Gem)  | Queue      | Global  | Yes     |
| Sidekiq           | Yes   | Yes    | Yes        | Queue      | No      | Job     |
| Sneakers          | Yes   | Yes    | No         | Queue      | Queue   | No      |
| Sucker Punch      | Yes   | Yes    | Yes        | No         | No      | No      |
| Active Job Async  | Yes   | Yes    | Yes        | No         | No      | No      |
| Active Job Inline | No    | Yes    | N/A        | N/A        | N/A     | N/A     |
| Active Job Test   | No    | Yes    | N/A        | N/A        | N/A     | N/A     |

Асинхронность

Да: Адаптер очереди может выполнять задачу в неблокирующем режиме. Он выполняется либо в отдельном или форкированном процессе, либо в другом потоке.

Нет: Задача выполняется в том же процессе.

Очереди

Да: Задачи могут указывать очередь, в которой они выполняются, с помощью метода queue_as или set.

Задержка

Да: Адаптер выполнит задачу в будущем через perform_later.

(Gem): Для использования perform_later с этим адаптером требуется дополнительный gem.

Нет: Адаптер выполнит задачи при первой возможности и не может использовать perform_later.

Нет данных: Адаптер не поддерживает очереди.

ПРИМЕЧАНИЕ: queue_classic поддерживает планирование задач с версии 3.1. Для более старых версий можно использовать gem queue_classic-later.

Приоритеты

Порядок обработки задач может быть настроен по-разному в зависимости от адаптера.

Задача: Любой класс, унаследованный от адаптера, может установить приоритет объекта задачи по отношению к другим задачам.

Очередь: Адаптер может установить приоритет для очередей задач; при настройке очереди с помощью Active Job этот приоритет будет учтён.

Да: Позволяет задавать приоритет объекта задачи, на уровне очереди или в качестве параметра конфигурации по умолчанию.

Нет: Адаптер не позволяет настраивать приоритет задач.

Нет данных: Адаптер не поддерживает очереди и, следовательно, сортировку задач.

Таймаут

Время, через которое задача будет остановлена после выделенного времени.

Задача: Таймаут может быть установлен для каждого экземпляра класса задачи.

Очередь: Таймаут устанавливается для всех задач в очереди.

Глобально: Адаптер настроен так, что все задачи имеют максимальное время выполнения.

Нет: Адаптер не позволяет настраивать таймаут задач.

Нет данных: Этот адаптер не работает в отдельном процессе и поэтому не поддерживает таймаут.

Повторные попытки

Задача: Количество повторных попыток может быть установлено для каждого экземпляра класса задачи.

Да: Количество повторных попыток может быть настроено глобально, для каждого экземпляра или в очереди. Этот адаптер также может представлять собой не удавшиеся экземпляры класса задачи, которые можно перезапустить.

Глобально: Адаптер имеет глобальное количество повторных попыток.

Нет: Адаптер не позволяет настраивать количество повторных попыток.

Нет данных: Адаптер не работает в отдельном процессе и поэтому не поддерживает повторные попытки.

Публичные методы класса

lookup(name) Показать исходный код
# File activejob/lib/active_job/queue_adapters.rb, line 138
def lookup(name)
  const_get(name.to_s.camelize << ADAPTER)
end

Возвращает адаптер для заданного имени.

ActiveJob::QueueAdapters.lookup(:sidekiq)
# => ActiveJob::QueueAdapters::SidekiqAdapter

© 2004–2021 David Heinemeier Hansson
Licensed under the MIT License.

Spec-Zone.ru

Настройки Оффлайн Что нового Помощь О нас
Spec-Zone .ru
спецификации, руководства, описания, API