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

example 01

Browse Source
This commit is contained in:
Kwindla Hultman Kramer
2024-03-03 16:38:03 -08:00
parent 2d8d9146f8
commit 0512765aeb
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/examples/foundational/01-say-one-thing.py
View File

@@ -29,7 +29,6 @@ async def main(room_url):
mic_enabled=True mic_enabled=True
) )
"""
tts = ElevenLabsTTSService( tts = ElevenLabsTTSService(
aiohttp_session=session, aiohttp_session=session,
api_key=os.getenv("ELEVENLABS_API_KEY"), api_key=os.getenv("ELEVENLABS_API_KEY"),
@@ -41,6 +40,9 @@ async def main(room_url):
user_id=os.getenv("PLAY_HT_USER_ID"), user_id=os.getenv("PLAY_HT_USER_ID"),
voice_url=os.getenv("PLAY_HT_VOICE_URL"), voice_url=os.getenv("PLAY_HT_VOICE_URL"),
) )
"""
tts.sink = transport.send_queue
# Register an event handler so we can play the audio when the participant joins. # Register an event handler so we can play the audio when the participant joins.
@transport.event_handler("on_first_other_participant_joined") @transport.event_handler("on_first_other_participant_joined")
@@ -50,14 +52,12 @@ async def main(room_url):
await tts.say( await tts.say(
"Hello there, " + participant["info"]["userName"] + "!" "Hello there, " + participant["info"]["userName"] + "!"
) )
await tts.sink.put(EndStreamQueueFrame())
# wait for the output queue to be empty, then leave the meeting # wait for the output queue to be empty, then leave the meeting
await transport.stop_when_done() await transport.stop_when_done()
# question: how do we exit the script?
await transport.run() await transport.run()
del(tts)
if __name__ == "__main__": if __name__ == "__main__":
(url, token) = configure() (url, token) = configure()