Как задать уникальное поле для очереди в laravel?

Question

[Леонид Горшков]

Добрый день. Необходимо задать уникальное поле в jobs (например user_id), что бы при необходимости можно было удалить из очереди именно эту задачу. (Использовать промежуточное redis, mysql не вариант).
Как этого добиться?
И как при dispatch() добавить в это поле информацию?

Answer 1

[vism]

Зачем удалять?
Пропишите в самом Job условие, чтоб сперва происходила проверка, выполнять этот Job или нет

Comments

[Леонид Горшков]

Как мне узнать, существует этот job в очереди?

[vism]

Леонид Горшков, Вы пытаетесь функционал job притянуть к неверным алгоритмам.
При правильном использовании job нет необходимости узнавать существует ли он в очереди.

Меняйте алгоритмы.

[Леонид Горшков]

vism, мне надо отправить http запрос. Если сервер не отвечает, то мне надо попытаться снова через 10 мин. Так до тех пор пока запрос не будет отправлен. Так же мне нельзя делать этот запрос более 1 раза. Какой ещё может быть алгоритм?

[vism]

Ну так пусть job и выполняет свою работу. Не надо пытаться накинуть логику на саму очередь.
А для проверки условия добавления и контроля выполнения используйте базу данных, например.

[RacceGatel]

Леонид Горшков, сделай циклично создающий самого себя job с delay(600), пока не выполнится твоя задача.

Answer 2

[RacceGatel]

Тоже была примерно такая же нужда. Однако, как я понял, из jobs вытащить конкретный ворк и удалить "по-человечески" нельзя. Я решил эту проблему путем добавления Lock'ов с динамичным ключом, а уже в самом теле job'а проверял состояние lock'a.
Иными словами, при добавлении job'а в очередь, добавляется lock привязанный конкретно к этому job'у, в случае если очередь до нашего job'а не дошла, можно просто убрать lock и тогда этот job явно не сработает.
Такой расклад позволил мне, грубо говоря, контролировать состояние job'a пока до него не дошла очередь в воркере.

Но видимо вам такой вариант не подходит, так что буду ждать, кто предложит что-нибудь получше.

Вопрос с уникальным полем - как задать

class Job implements ShouldQueue, ShouldBeUnique
{
protected $user_id;

public function __construct($user_id)
    {
        $this->user_id = $user_id;
    }

public function handle()
    {
        //
    }

public function uniqueId()
    {
        return $this->user_id;
    }
}