Upload 3 files

.gitattributes

@@ -33,3 +33,4 @@ saved_model/**/* filter=lfs diff=lfs merge=lfs -text
 *.zip filter=lfs diff=lfs merge=lfs -text
 *.zst filter=lfs diff=lfs merge=lfs -text
 *tfevents* filter=lfs diff=lfs merge=lfs -text
+iarec.mp4 filter=lfs diff=lfs merge=lfs -text

app.py

@@ -0,0 +1,73 @@
+import os
+import time
+import subprocess
+from multiprocessing import Process
+import uvicorn
+from fastapi import FastAPI, Response
+
+app = FastAPI()
+
+# Archivo de video y rutas de salida
+video_file = "iarec.mp4"
+hls_output = "stream.m3u8"
+hls_segment_prefix = "stream"
+
+# Comando FFmpeg para transmitir video en HLS (en loop continuo)
+ffmpeg_command = [
+    'ffmpeg',
+    '-re',
+    '-stream_loop', '-1',  # Repetir el video en loop
+    '-i', video_file,
+    '-c:v', 'copy',
+    '-c:a', 'aac',
+    '-preset', 'ultrafast',
+    '-f', 'hls',
+    '-hls_time', '10',  # Duración de cada segmento en segundos
+    '-hls_list_size', '10',  # Número de segmentos en la lista de reproducción
+    '-hls_flags', 'append_list+omit_endlist',  # Añadir a la lista sin eliminar los antiguos
+    '-hls_segment_filename', f'{hls_segment_prefix}%03d.ts',  # Nombre de archivo de los segmentos
+    hls_output
+]
+
+def stream_video():
+    # Ejecuta el comando FFmpeg para iniciar la transmisión
+    process = subprocess.Popen(ffmpeg_command)
+    process.wait()
+
+def start_video_streaming():
+    video_process = Process(target=stream_video)
+    video_process.start()
+
+@app.on_event("startup")
+async def startup_event():
+    # Espera activa para verificar que el archivo M3U8 esté generado
+    while not os.path.exists(hls_output):
+        print("Esperando a que se genere el archivo M3U8...")
+        time.sleep(1)
+    print("Archivo M3U8 generado. Servidor listo para recibir solicitudes.")
+
+@app.get("/")
+async def read_root():
+    return {"message": "Training IA"}
+
+@app.get("/stream.m3u8")
+def get_m3u8():
+    # Devuelve el archivo M3U8 generado
+    with open(hls_output, "rb") as f:
+        m3u8_content = f.read()
+    return Response(content=m3u8_content, media_type="application/vnd.apple.mpegurl")
+
+@app.get("/stream{segment}.ts")
+def get_segment(segment: int):
+    # Devuelve los segmentos TS generados
+    segment_file = f"{hls_segment_prefix}{segment:03d}.ts"
+    if os.path.exists(segment_file):
+        with open(segment_file, "rb") as f:
+            segment_content = f.read()
+        return Response(content=segment_content, media_type="video/mp2t")
+    else:
+        return Response(status_code=404, content="Segment not found")
+
+if __name__ == "__main__":
+    start_video_streaming()
+    uvicorn.run(app, host="0.0.0.0", port=7860)

iarec.mp4

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:3a13c17cb44a8c2e9bd4f408e51664657a6e0195399fafed68c547a2fa06801a
+size 7226487214

requirements.txt

@@ -0,0 +1,6 @@
+fastapi==0.79.0
+uvicorn==0.18.3
+requests==2.28.1
+ffmpeg-python==0.2.0
+py7zr
+jdk4py