Ahora en el aire sonando tú Radio

import os import random import subprocess import time from watchdog.observers import Observer from watchdog.events import FileSystemEventHandler # --- CONFIGURACIÓN --- # Define la clave o URL RTMP de tu destino (YouTube, Twitch, Nginx, etc.) STREAM_URL = "rtmp://a.rtmp.youtube.com/live2/TU_CLAVE_DE_TRANSMISION" # Carpetas de contenido FOLDER_MUSICA = "./contenido/musica" FOLDER_PUBLICIDAD = "./contenido/publicidad" # Tipos de archivo válidos VALID_EXTENSIONS = ('.mp4', '.mkv', '.mov', '.avi', '.mp3') class MediaFolderHandler(FileSystemEventHandler): """Detecta cuando se añaden o eliminan archivos de las carpetas""" def on_created(self, event): if not event.is_directory and event.src_path.endswith(VALID_EXTENSIONS): print(f"Nuevo contenido detectado: {event.src_path}") def get_media_files(folder): """Obtiene todos los archivos multimedia válidos de una carpeta""" files = [] if os.path.exists(folder): for f in os.listdir(folder): if f.lower().endswith(VALID_EXTENSIONS): files.append(os.path.join(folder, f)) return files def play_file_ffmpeg(file_path): """Envía el archivo actual al servidor RTMP usando FFmpeg""" print(f"\n[ON AIR] Transmitiendo: {os.path.basename(file_path)}") # Comando de FFmpeg configurado para re-codificar manteniendo sincronía cmd = [ 'ffmpeg', '-re', # Lee el archivo en tiempo real (1x) '-i', file_path, # Archivo de entrada '-c:v', 'libx264', # Códec de video H.264 '-preset', 'veryfast', # Rendimiento '-maxrate', '3000k', # Bitrate máx. '-bufsize', '6000k', '-pix_fmt', 'yuv420p', '-g', '50', # Keyframe cada 2 segundos (a 25fps) '-c:a', 'aac', # Códec de audio AAC '-b:a', '128k', '-ar', '44100', '-f', 'flv', # Formato contenedor para RTMP STREAM_URL ] # Ejecutar transmisión process = subprocess.Popen(cmd, stdout=subprocess.DEVNULL, stderr=subprocess.STDOUT) process.wait() # Esperar a que el video termine para pasar al siguiente def main(): # Asegurar que existan las carpetas os.makedirs(FOLDER_MUSICA, exist_ok=True) os.makedirs(FOLDER_PUBLICIDAD, exist_ok=True) # Iniciar el observador de carpetas en segundo plano event_handler = MediaFolderHandler() observer = Observer() observer.schedule(event_handler, FOLDER_MUSICA, recursive=False) observer.schedule(event_handler, FOLDER_PUBLICIDAD, recursive=False) observer.start() print("=== MediaCast Automatizado Iniciado ===") print("Agrega o elimina videos en las carpetas sin detener el programa.\n") counter = 0 try: while True: # Lógica de emisión / Escaleta automática: # Cada 3 canciones de la carpeta "musica", pasa 1 "publicidad" if counter % 3 == 0 and counter != 0: ads = get_media_files(FOLDER_PUBLICIDAD) if ads: selected = random.choice(ads) print("--> [PAUTA] Reproduciendo Publicidad") play_file_ffmpeg(selected) # Reproducir elemento de la carpeta principal music_files = get_media_files(FOLDER_MUSICA) if music_files: selected_music = random.choice(music_files) play_file_ffmpeg(selected_music) counter += 1 else: print("No hay archivos en la carpeta de música. Esperando 10s...") time.sleep(10) except KeyboardInterrupt: observer.stop() print("\nTransmisión detenida por el usuario.") observer.join() if __name__ == "__main__": main()

Digital 88.7 FM