mirror of
https://github.com/MichaByte/OnBoard-Live.git
synced 2026-01-29 13:32:12 -05:00
17 lines
713 B
Python
17 lines
713 B
Python
import subprocess
|
|
import time
|
|
import requests
|
|
|
|
active_stream = requests.get("http://backend:8000/api/v1/active_stream").text
|
|
old_active_stream = active_stream
|
|
|
|
proc = None
|
|
|
|
while True:
|
|
proc = subprocess.Popen([f"ffmpeg -re -i rtmp://mediamtx:1935/{active_stream} -c:a copy rtmp://host.containers.internal:1936/active-input"], shell=True)
|
|
time.sleep(3)
|
|
active_stream = requests.get("http://backend:8000/api/v1/active_stream").text
|
|
if old_active_stream is not active_stream:
|
|
proc.terminate()
|
|
proc = subprocess.Popen([f"ffmpeg -re -i rtmp://mediamtx:1935/{active_stream} -c:a copy rtmp://host.containers.internal:1936/active-input"], shell=True)
|
|
old_active_stream = active_stream
|