实时模式不执行工具调用

async def websocket_task(call_id): try: async with websockets.connect( f"wss://{AZURE_RESOURCE_NAME}.OpenAI.Azure.com/OpenAI/v1/realtime?call_id=" + call_id, additional_headers=AUTH_HEADER, ): await websocket.send(json.dumps(response_create)) while True: response = await websocket.recv() print(f"Received from WebSocket: {response}") except Exception as e: print(f"WebSocket error: {e}")

@app.route("/", methods=["POST"]) def webhook(): try: event = client.webhooks.unwrap(request.data, request.headers) if event.type == "realtime.call.incoming": requests.post( f"https://{AZURE_RESOURCE_NAME}.OpenAI.Azure.com/OpenAI/v1/realtime/calls/"

• event.data.call_id
• "/accept", headers={**AUTH_HEADER, "Content-Type": "application/json"}, json=call_accept, ) threading.Thread( target=lambda: asyncio.run( websocket_task(event.data.call_id) ), daemon=True, ).start() return Response(status=200) except InvalidWebhookSignatureError as e: print("Invalid signature", e) return Response("Invalid signature", status=400)

if name == "main": app.run(host="0.0.0.0",