DB драйвер ¶

DB дравер для хранения очереди заданий использует базу данных.

Пример настройки:

return [
    'bootstrap' => [
        'queue', // Компонент регистрирует свои консольные команды 
    ],
    'components' => [
        'queue' => [
            'class' => \zhuravljov\yii\queue\db\Queue::class,
            'db' => 'db', // ID подключения
            'tableName' => '{{%queue}}', // таблица
            'channel' => 'default', // выбранный для очереди канал
            'mutex' => \yii\mutex\MysqlMutex::class, // мьютекс для синхронизации запросов
        ],
    ],
];

В базу данных нужно добавить таблицу. Схема, на примере MySQL:

CREATE TABLE `queue` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `channel` varchar(255) NOT NULL,
  `job` blob NOT NULL,
  `pushed_at` int(11) NOT NULL,
  `ttr` int(11) NOT NULL,
  `delay` int(11) NOT NULL DEFAULT 0,
  `reserved_at` int(11) DEFAULT NULL,
  `attempt` int(11) DEFAULT NULL,
  `done_at` int(11) DEFAULT NULL,
  PRIMARY KEY (`id`),
  KEY `channel` (`channel`),
  KEY `reserved_at` (`reserved_at`)
) ENGINE=InnoDB

Миграции смотрите в src/drivers/db/migrations.

Консоль ¶

Для обработки очереди используются консольные команды.

yii queue/listen [delay]

Команда listen запускает обработку очереди в режиме демона. Очередь опрашивается непрерывно. Если добавляются новые задания, то они сразу же извлекаются и выполняются. delay - время ожидания в секундах перед следующим опросом очереди. Способ наиболее эфективен если запускать команду через супервайзер.

yii queue/run

Команда run в цикле извлекает задания из очереди и выполняет их, пока очередь не опустеет, и завершает свою работу. Это способ подойдет для обработки очереди заданий через cron.

Для команд run и listen доступны следующие опции:

• --verbose, -v: состояние обработки заданий выводится в консоль.
• --isolate: каждое задание выполняется в отдельном дочернем процессе.
• --color: подсветка вывода в режиме --verbose.

yii queue/info

Команда info выводит инофрмацию о состоянии очереди.