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

Configuring the ice servers.

Browse Source
This commit is contained in:
Filipi Fuchter
2025-11-28 15:40:59 -03:00
parent 9fcc7a25fd
commit a3d3e3136c
1 changed files with 15 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
examples/aws-agentcore/agents/pipecat/pipecat-agent.py
View File

@@ -25,7 +25,7 @@ from pipecat.services.deepgram.stt import DeepgramSTTService
from pipecat.services.openai.llm import OpenAILLMService from pipecat.services.openai.llm import OpenAILLMService
from pipecat.transports.base_transport import BaseTransport, TransportParams from pipecat.transports.base_transport import BaseTransport, TransportParams
from pipecat.transports.daily.transport import DailyParams from pipecat.transports.daily.transport import DailyParams
from pipecat.transports.smallwebrtc.connection import SmallWebRTCConnection from pipecat.transports.smallwebrtc.connection import IceServer, SmallWebRTCConnection
from pipecat.transports.smallwebrtc.request_handler import ( from pipecat.transports.smallwebrtc.request_handler import (
SmallWebRTCRequest, SmallWebRTCRequest,
) )
@@ -130,9 +130,20 @@ async def agentcore_bot(payload, context):
"""Bot entry point for running on Amazon Bedrock AgentCore Runtime.""" """Bot entry point for running on Amazon Bedrock AgentCore Runtime."""
request = SmallWebRTCRequest.from_dict(payload) request = SmallWebRTCRequest.from_dict(payload)
# TODO: need to implement this ice_servers = [
# ice_servers=self._ice_servers IceServer(
pipecat_connection = SmallWebRTCConnection() urls=[
"turn:turn.cloudflare.com:3478?transport=tcp",
"turn:turn.cloudflare.com:80?transport=tcp",
"turns:turn.cloudflare.com:5349?transport=tcp",
"turns:turn.cloudflare.com:443?transport=tcp",
],
username=os.getenv("TURN_USERNAME"),
credential=os.getenv("TURN_CREDENTIAL"),
)
]
pipecat_connection = SmallWebRTCConnection(ice_servers=ice_servers)
await pipecat_connection.initialize(sdp=request.sdp, type=request.type) await pipecat_connection.initialize(sdp=request.sdp, type=request.type)
# Prepare runner arguments with the callback to run your bot # Prepare runner arguments with the callback to run your bot