Bedrud Dokumentation

Bedrud enthält Python-basierte Bot-Agenten, die Meeting-Räumen beitreten und Medieninhalte streamen können. Diese sind nützlich für Hintergrundmusik, Radiostreams oder die Freigabe von Videoinhalten.

Verfügbare Agenten

AgentBeschreibungMedientyp
music_agentSpielt Audiodateien in einem Raum abAudio (PCM)
radio_agentStreamt Internet-RadiosenderAudio (PCM über FFmpeg)
video_stream_agentTeilt Videoinhalte (HLS, MP4)Video + Audio

Wie Agenten funktionieren

Alle Agenten folgen demselben Verbindungsmuster:

flowchart TD
    A[1. Parse meeting URL] --> B[2. Guest login<br/>POST /api/auth/guest-login]
    B --> C[3. Join room<br/>POST /api/room/join]
    C --> D[4. Connect to LiveKit<br/>WebSocket + Token]
    D --> E[5. Publish tracks<br/>Stream audio/video frames]
flowchart LR
    subgraph Media["Media Source"]
        MS["File / URL<br/>(MP3, radio, HLS, MP4)"]
    end
    subgraph Agent["Python Agent"]
        FF[FFmpeg Decoder]
        PA[Agent Logic]
    end
    subgraph Server["Bedrud Server"]
        GL[Guest Login<br/>/api/auth/guest-login]
        JR[Join Room<br/>/api/room/join]
    end
    subgraph LK["LiveKit SFU<br/>(WebRTC)"]
        WS[WebSocket Connect]
        PT[Publish Tracks]
    end
    MS --> FF --> PA
    PA --> GL
    GL --> JR
    JR --> WS
    WS --> PT

Music Agent

Spielt Audiodateien (MP3, WAV usw.) in einem Meeting-Raum ab.

Einrichtung

cd agents/music_agent
pip install -r requirements.txt

Abhängigkeiten: httpx, livekit, pydub

Verwendung

python agent.py "https://meet.example.com/m/room-name"

Funktionsweise

  1. Dekodiert Audiodateien mit pydub
  2. Konvertiert zu PCM-Frames
  3. Veröffentlicht Audio-Frames als Mikrofon-Track in LiveKit

Siehe Music Agent README für Einrichtungs- und Verwendungsanweisungen.

Radio Agent

Streamt Internet-Radiosender in einen Meeting-Raum unter Verwendung von FFmpeg zur Audiodekodierung.

Einrichtung

cd agents/radio_agent
pip install -r requirements.txt

Abhängigkeiten: httpx, livekit

Systemanforderung: FFmpeg muss installiert sein (brew install ffmpeg oder apt install ffmpeg)

Verwendung

python agent.py "https://meet.example.com/m/room-name"

Funktionsweise

  1. Verbindet sich mit einer Radio-Stream-URL
  2. Leitet den Stream durch FFmpeg zur Dekodierung in rohes PCM
  3. Veröffentlicht PCM-Audio-Frames in LiveKit

Siehe Radio Agent README für Einrichtungs- und Verwendungsanweisungen.

Video Stream Agent

Teilt Video und Audio von einer URL (HLS/m3u8, MP4) in einem Meeting-Raum.

Einrichtung

cd agents/video_stream_agent
pip install -r requirements.txt

Abhängigkeiten: httpx, livekit

Systemanforderung: FFmpeg muss installiert sein

Verwendung

python agent.py "https://meet.example.com/m/room-name"

Funktionsweise

  1. Führt zwei FFmpeg-Prozesse parallel aus:
    • Video: Dekodiert zu YUV420p-Rohframes (1280x720 @ 30fps)
    • Audio: Dekodiert zu PCM-Samples
  2. Veröffentlicht Video als Bildschirmfreigabe-Track
  3. Veröffentlicht Audio als Mikrofon-Track

Siehe Video Stream Agent README für Einrichtungs- und Verwendungsanweisungen.

Videospezifikationen

EinstellungWert
Breite1280
Höhe720
FPS30
PixelformatYUV420p

Einen eigenen Agenten schreiben

Um einen neuen Agenten zu erstellen, folgen Sie diesem Muster:

import httpx
from livekit import rtc
 
# 1. Parse the meeting URL to extract room name
room_name = parse_url(meeting_url)
 
# 2. Guest login
client = httpx.Client(base_url=server_url)
resp = client.post("/api/auth/guest-login", json={"name": "Bot Name"})
token = resp.json()["token"]
 
# 3. Join room
client.headers["Authorization"] = f"Bearer {token}"
resp = client.post("/api/room/join", json={"roomName": room_name})
lk_token = resp.json()["token"]
 
# 4. Connect to LiveKit
room = rtc.Room()
await room.connect(livekit_url, lk_token)
 
# 5. Publish tracks
source = rtc.AudioSource(sample_rate=48000, num_channels=1)
track = rtc.LocalAudioTrack.create_audio_track("audio", source)
await room.local_participant.publish_track(track)
 
# 6. Stream frames
while has_data:
    frame = get_next_frame()
    await source.capture_frame(frame)

Siehe auch