Редактирование и рестрим rtmp стрима на python

Есть nginx rtmp lan сервер на который ведётся поток из OBS. Есть скрипт на python, который на основании скриншота экрана определяет есть ли nsfw контент на экране. Результат просчитывается в реальном времени и отправляется по tcp. Задача другого скрипта: Получать результат по tcp - это он умеет Получать поток с rtmp lan сервера и за секунду до появления nsfw контента накладывать на видео-поток оверлей. По идее мне нужно получать стрим и отправлять его с задержкой в эту самую секунду и если приходит сигнал по tcp, то накладывать на видео оверлей.

Я не понимаю как мне реализовать этот буфер, записывать в него стрим обрабатывать его и публиковать его. Оверлей можно накладывать через opencv, но вопрос реализации буфера и постинга его остаётся открытым. Я смотрел в сторону ffmpeg, но как организовать стриминг не понимаю.

Какие библиотеки могут помочь мне в решении этой задачи? Есть ли какая-то связанная литература?