AL
при успешной передаче обработчику ack-аешь и всё, не?
Size: a a a
2021 April 23
AL
или nack'аешь
AB
то есть, отдельное сообщение акнуть именно по итогу обработки нельзя?
AL
ну, по итогу обработки - это как раз получится число консьюмеров=число обработчиков. тоже есть смысл.
но я так понимаю, тут важно именно как можно больше сообщений взять в работу. если важно ещё и по факту обработки только ack проставлять, тогда надо количество воркеров-консьюмеров просто выкручивать в максимум, оно же и как rps будет работать, ограничивая число одновременно обрабатываемых
но я так понимаю, тут важно именно как можно больше сообщений взять в работу. если важно ещё и по факту обработки только ack проставлять, тогда надо количество воркеров-консьюмеров просто выкручивать в максимум, оно же и как rps будет работать, ограничивая число одновременно обрабатываемых
AM
Вот только Бродвей можно за десять минут поднять, а остальное время ручки крутить и тестировать, а собственное решение это собственное решение
AD
Что значит собственное решение? Бродвей использует эту же блиюлиотеку, ее подымать те же 10 минут
AD
Но да бродвей модно, бродвей молодежно))
AM
То есть по вашему Бродвей использует "ту же библиотеку" и от себя не добавляет ничего полезного? Просто слипы в коде расставляет?
AD
Он добавляет, но это для батч процессинга. Я не вижу где тут есть батч в вопросе, это просто 1000 джоб и все. Наверняка ack/nack тоже хочется желать по каждой отдельно
AD
Это как юзать какой-то мега фреймворк, он ведь не зря добавляет миллион фич
AD
:)
AM
И про какую библиотеку вы говорите? Флоу, генстейдж, адаптер amqp?
AD
amqp
AM
Ну да, а потом захочется навернуть back pressure, метрик, батчить аки и вот у нас уже плохая копия Бродвея
ŹR
Бери broadway никого не слушай
AN
ну бродвей добавляет батчинг, мультистэйдж, тот же супервизор над воркерами, это в любом случае делать нужно будет, хотя и работы на полчаса если не нужно ничего из вышеперечисленного, кроме супервизора
AD
А давайте сразу кафку, овериженерить так оверэнджинерить
AD
А потом обсудим почему нас на хорошую работу не берут)
AN
я в принципе тоже думал, что Task.async + ampq решает задачу
AN
но если захочется стадию добавить или в батч сложить один фиг на бродвей переезжать