asdas1241 commited on
Commit
1059915
verified
1 Parent(s): a362ed2

Upload 3 files

Browse files
Files changed (4) hide show
  1. .gitattributes +1 -0
  2. app.py +75 -0
  3. iarec.mp4 +3 -0
  4. requirements.txt +6 -0
.gitattributes CHANGED
@@ -33,3 +33,4 @@ saved_model/**/* filter=lfs diff=lfs merge=lfs -text
33
  *.zip filter=lfs diff=lfs merge=lfs -text
34
  *.zst filter=lfs diff=lfs merge=lfs -text
35
  *tfevents* filter=lfs diff=lfs merge=lfs -text
 
 
33
  *.zip filter=lfs diff=lfs merge=lfs -text
34
  *.zst filter=lfs diff=lfs merge=lfs -text
35
  *tfevents* filter=lfs diff=lfs merge=lfs -text
36
+ iarec.mp4 filter=lfs diff=lfs merge=lfs -text
app.py ADDED
@@ -0,0 +1,75 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ import os
2
+ import time
3
+ import subprocess
4
+ from multiprocessing import Process
5
+ import uvicorn
6
+ from fastapi import FastAPI, Response
7
+
8
+ app = FastAPI()
9
+
10
+ # Archivo de video y rutas de salida
11
+ video_file = "iarec.mp4"
12
+ hls_output = "stream.m3u8"
13
+ hls_segment_prefix = "stream"
14
+
15
+ # Comando FFmpeg para transmitir video en HLS (en loop continuo)
16
+ ffmpeg_command = [
17
+ 'ffmpeg',
18
+ '-re',
19
+ '-stream_loop', '-1', # Repetir el video en loop
20
+ '-i', video_file,
21
+ '-c:v', 'libx264',
22
+ '-c:a', 'aac',
23
+ '-crf', 23,
24
+ '-b:a', '128.00k',
25
+ '-preset', 'slow',
26
+ '-f', 'hls',
27
+ '-hls_time', '10', # Duraci贸n de cada segmento en segundos
28
+ '-hls_list_size', '10', # N煤mero de segmentos en la lista de reproducci贸n
29
+ '-hls_flags', 'append_list+omit_endlist', # A帽adir a la lista sin eliminar los antiguos
30
+ '-hls_segment_filename', f'{hls_segment_prefix}%03d.ts', # Nombre de archivo de los segmentos
31
+ hls_output
32
+ ]
33
+
34
+ def stream_video():
35
+ # Ejecuta el comando FFmpeg para iniciar la transmisi贸n
36
+ process = subprocess.Popen(ffmpeg_command)
37
+ process.wait()
38
+
39
+ def start_video_streaming():
40
+ video_process = Process(target=stream_video)
41
+ video_process.start()
42
+
43
+ @app.on_event("startup")
44
+ async def startup_event():
45
+ # Espera activa para verificar que el archivo M3U8 est茅 generado
46
+ while not os.path.exists(hls_output):
47
+ print("Esperando a que se genere el archivo M3U8...")
48
+ time.sleep(1)
49
+ print("Archivo M3U8 generado. Servidor listo para recibir solicitudes.")
50
+
51
+ @app.get("/")
52
+ async def read_root():
53
+ return {"message": "Training IA"}
54
+
55
+ @app.get("/stream.m3u8")
56
+ def get_m3u8():
57
+ # Devuelve el archivo M3U8 generado
58
+ with open(hls_output, "rb") as f:
59
+ m3u8_content = f.read()
60
+ return Response(content=m3u8_content, media_type="application/vnd.apple.mpegurl")
61
+
62
+ @app.get("/stream{segment}.ts")
63
+ def get_segment(segment: int):
64
+ # Devuelve los segmentos TS generados
65
+ segment_file = f"{hls_segment_prefix}{segment:03d}.ts"
66
+ if os.path.exists(segment_file):
67
+ with open(segment_file, "rb") as f:
68
+ segment_content = f.read()
69
+ return Response(content=segment_content, media_type="video/mp2t")
70
+ else:
71
+ return Response(status_code=404, content="Segment not found")
72
+
73
+ if __name__ == "__main__":
74
+ start_video_streaming()
75
+ uvicorn.run(app, host="0.0.0.0", port=7860)
iarec.mp4 ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:63649c7f763c1c0a265cfb92f707d4a0018a0c4e199db2e821bfad07ec64e75f
3
+ size 4444071249
requirements.txt ADDED
@@ -0,0 +1,6 @@
 
 
 
 
 
 
 
1
+ fastapi==0.79.0
2
+ uvicorn==0.18.3
3
+ requests==2.28.1
4
+ ffmpeg-python==0.2.0
5
+ py7zr
6
+ jdk4py