Size: a a a

2021 January 14

СВ

Сергей Вершинин... in symfony
тогда просто 2 очереди
источник

SB

Sergei Baikin in symfony
Сергей Вершинин
тогда просто 2 очереди
и толку?
воркер то один (он же консюмер)
просто запущенный в нескольких копиях
источник

СВ

Сергей Вершинин... in symfony
я написал два воркера)
источник

AD

Andrey Dembitskyi in symfony
Понятненько.
С ним сложно это сделать получается - в его понятиях это считается разными шинами и не выйдет удобно разбить очереди (или мне это не очевидно)
источник

СВ

Сергей Вершинин... in symfony
1 на каждую очередь
источник

D

Dmitry in symfony
Sergei Baikin
вы использовали symfony messenger?
ага
источник

D

Dmitry in symfony
Sergei Baikin
и толку?
воркер то один (он же консюмер)
просто запущенный в нескольких копиях
ну так блин запустите 2 воркера то
источник

SB

Sergei Baikin in symfony
Сергей Вершинин
1 на каждую очередь
ну вот вы костылей навтыкали
с костылями да
но я забелася писать костыли для месендера когда с 4,2 игрался
источник

AD

Andrey Dembitskyi in symfony
Andrey Dembitskyi
Понятненько.
С ним сложно это сделать получается - в его понятиях это считается разными шинами и не выйдет удобно разбить очереди (или мне это не очевидно)
Но в защиту мессенджера (простите) он умеет накладывать клеймы на сообщение - мол эти обраточики уже обработали и при ретрае не булут
источник

SB

Sergei Baikin in symfony
Dmitry
ну так блин запустите 2 воркера то
вы оиличаете инстансы одного воркера от нескольких разных воркеров?
у симфони месендера только один воркер прост оможно несколько инстансов оного поднять
источник

СВ

Сергей Вершинин... in symfony
мм, независимо обрабатывать ивент ( или что там у вас в басе) это костыль)
источник

AD

Andrey Dembitskyi in symfony
Сергей Вершинин
мм, независимо обрабатывать ивент ( или что там у вас в басе) это костыль)
Не)
источник

SB

Sergei Baikin in symfony
Andrey Dembitskyi
Но в защиту мессенджера (простите) он умеет накладывать клеймы на сообщение - мол эти обраточики уже обработали и при ретрае не булут
Тогда ему придется после каждого обрабочика сообщение из осереди удалять и создавать новое
источник

D

Dmitry in symfony
Sergei Baikin
вы оиличаете инстансы одного воркера от нескольких разных воркеров?
у симфони месендера только один воркер прост оможно несколько инстансов оного поднять
вы сейчас издеваетесь ? почитайте документацию пожалуйста
источник

SB

Sergei Baikin in symfony
Dmitry
вы сейчас издеваетесь ? почитайте документацию пожалуйста
Дока
https://symfony.com/doc/current/messenger.html#consuming-messages-running-the-worker

один воркер он же консюмер
источник

D

Dmitry in symfony
ага, из этой же доки
php bin/console messenger:consume async_priority_high async_priority_low
источник

D

Dmitry in symfony
что мешает раскинуть это на 2 процесса ?
источник

SB

Sergei Baikin in symfony
Dmitry
ага, из этой же доки
php bin/console messenger:consume async_priority_high async_priority_low
это тот же консюмер просто которые обрабатывает 2 очереди
источник

СВ

Сергей Вершинин... in symfony
а в чем проблема иметь два пода

php bin/console messenger:consume queue1
php bin/console messenger:consume queue2

?
источник

SB

Sergei Baikin in symfony
Dmitry
что мешает раскинуть это на 2 процесса ?
та хоть 10
это все инстансы одного воркера
для аналогии есть класс воркера
ваши косюимеры это объектв этого воркера
источник