Я создаю конвейер данных, который читает двоичные журналы MySQL в реальном времени, используя Maxwell Daemon, а Maxwell Daemon отправляет данные в Redis потоки. Я создал клиент, который потребляет данные из потоков Redis и обрабатывает их. В настоящее время я опрашиваю XREAD, используя бесконечный цикл со временем ожидания в несколько миллисекунд, чтобы потреблять данные из потока, но я считаю это неэффективным решением.
Я искал способ каким-то образом подписаться на поток Redis и получать уведомления всякий раз, когда в поток добавляются новые записи, и наткнулся на этот выпуск GitHub, в котором говорится об использовании Redis pub / sub вместе с потоками для достижения этой функциональности.
Есть ли более эффективный способ построения этой системы?
