wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

examples: simplify 09-mirror.py

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2024-05-14 19:06:02 -07:00
parent 754c1c6775
commit bd04ea8aca
1 changed files with 4 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
examples/foundational/09-mirror.py
View File

@@ -7,12 +7,9 @@
import asyncio import asyncio
import sys import sys
from pipecat.frames.frames import AudioRawFrame, ImageRawFrame
from pipecat.processors.filter import Filter
from pipecat.pipeline.pipeline import Pipeline from pipecat.pipeline.pipeline import Pipeline
from pipecat.pipeline.runner import PipelineRunner from pipecat.pipeline.runner import PipelineRunner
from pipecat.pipeline.task import PipelineTask from pipecat.pipeline.task import PipelineTask
from pipecat.pipeline.parallel_pipeline import ParallelPipeline
from pipecat.transports.services.daily import DailyTransport, DailyParams from pipecat.transports.services.daily import DailyTransport, DailyParams
from runner import configure from runner import configure
@@ -23,15 +20,15 @@ from dotenv import load_dotenv
load_dotenv(override=True) load_dotenv(override=True)
logger.remove(0) logger.remove(0)
logger.add(sys.stderr, level="DEBUG") logger.add(sys.stderr, level="TRACE")
async def main(room_url, token): async def main(room_url, token):
transport = DailyTransport( transport = DailyTransport(
room_url, token, "Test", room_url, token, "Test",
DailyParams( DailyParams(
audio_in_enabled=True, # audio_in_enabled=True,
audio_out_enabled=True, # audio_out_enabled=True,
camera_out_enabled=True, camera_out_enabled=True,
camera_out_width=1280, camera_out_width=1280,
camera_out_height=720 camera_out_height=720
@@ -42,13 +39,7 @@ async def main(room_url, token):
async def on_first_participant_joined(transport, participant): async def on_first_participant_joined(transport, participant):
transport.capture_participant_video(participant["id"]) transport.capture_participant_video(participant["id"])
# The ParallelPipeline is not really necessary here but it shows how you pipeline = Pipeline([transport.input(), transport.output()])
# would process audio and video concurrently in parallel pipelines.
pipeline = Pipeline([transport.input(),
ParallelPipeline(
[Filter([AudioRawFrame])],
[Filter([ImageRawFrame])]),
transport.output()])
runner = PipelineRunner() runner = PipelineRunner()