СВ
тогда просто 2 очереди
Size: a a a
2021 January 14
SB
тогда просто 2 очереди
и толку?
воркер то один (он же консюмер)
просто запущенный в нескольких копиях
воркер то один (он же консюмер)
просто запущенный в нескольких копиях
СВ
я написал два воркера)
AD
Вот ибо он один это воркер
https://symfony.com/doc/current/messenger.html#consuming-messages-running-the-worker
https://symfony.com/doc/current/messenger.html#consuming-messages-running-the-worker
Понятненько.
С ним сложно это сделать получается - в его понятиях это считается разными шинами и не выйдет удобно разбить очереди (или мне это не очевидно)
С ним сложно это сделать получается - в его понятиях это считается разными шинами и не выйдет удобно разбить очереди (или мне это не очевидно)
СВ
1 на каждую очередь
D
вы использовали symfony messenger?
ага
D
и толку?
воркер то один (он же консюмер)
просто запущенный в нескольких копиях
воркер то один (он же консюмер)
просто запущенный в нескольких копиях
ну так блин запустите 2 воркера то
SB
1 на каждую очередь
ну вот вы костылей навтыкали
с костылями да
но я забелася писать костыли для месендера когда с 4,2 игрался
с костылями да
но я забелася писать костыли для месендера когда с 4,2 игрался
AD
Понятненько.
С ним сложно это сделать получается - в его понятиях это считается разными шинами и не выйдет удобно разбить очереди (или мне это не очевидно)
С ним сложно это сделать получается - в его понятиях это считается разными шинами и не выйдет удобно разбить очереди (или мне это не очевидно)
Но в защиту мессенджера (простите) он умеет накладывать клеймы на сообщение - мол эти обраточики уже обработали и при ретрае не булут
SB
ну так блин запустите 2 воркера то
вы оиличаете инстансы одного воркера от нескольких разных воркеров?
у симфони месендера только один воркер прост оможно несколько инстансов оного поднять
у симфони месендера только один воркер прост оможно несколько инстансов оного поднять
СВ
мм, независимо обрабатывать ивент ( или что там у вас в басе) это костыль)
AD
мм, независимо обрабатывать ивент ( или что там у вас в басе) это костыль)
Не)
SB
Но в защиту мессенджера (простите) он умеет накладывать клеймы на сообщение - мол эти обраточики уже обработали и при ретрае не булут
Тогда ему придется после каждого обрабочика сообщение из осереди удалять и создавать новое
D
вы оиличаете инстансы одного воркера от нескольких разных воркеров?
у симфони месендера только один воркер прост оможно несколько инстансов оного поднять
у симфони месендера только один воркер прост оможно несколько инстансов оного поднять
вы сейчас издеваетесь ? почитайте документацию пожалуйста
SB
вы сейчас издеваетесь ? почитайте документацию пожалуйста
Дока
https://symfony.com/doc/current/messenger.html#consuming-messages-running-the-worker
один воркер он же консюмер
https://symfony.com/doc/current/messenger.html#consuming-messages-running-the-worker
один воркер он же консюмер
SB
ага, из этой же доки
php bin/console messenger:consume async_priority_high async_priority_low
php bin/console messenger:consume async_priority_high async_priority_low
это тот же консюмер просто которые обрабатывает 2 очереди
СВ
а в чем проблема иметь два пода
php bin/console messenger:consume queue1
php bin/console messenger:consume queue2
?
php bin/console messenger:consume queue1
php bin/console messenger:consume queue2
?
SB
что мешает раскинуть это на 2 процесса ?
та хоть 10
это все инстансы одного воркера
для аналогии есть класс воркера
ваши косюимеры это объектв этого воркера
это все инстансы одного воркера
для аналогии есть класс воркера
ваши косюимеры это объектв этого воркера