Twilio `` Вызов отключает через 5 секунд - без ошибок, звук не воспроизводится ⇐ Python

[Anonymous]

Я использую Twilio's тег, чтобы транслировать аудио в WebSocket для голосового вызова. WebSocket успешно создан, и я получаю аудио куски от Twilio. Однако: < /p>

• Вызов разъединения через 5–6 секунд. < /Li>
  Я посылаю звук, кодируемый μ-закодированным (8000 Гц, 160 байтов на чанк) каждые 20 мс. < /Li>

  Код: Выделить всё

  My audio is not being played back to the caller.

• Twilio не возвращает никакой ошибки или журнала, кроме и
  .

вот фрагмент аудионой загрузки, который я отправляю (base64):
PrettyPrint-Override ">
{
"event": "media",
"streamSid": "FAKE_STREAM_SID_FOR_TEST",
"media": {
"payload": "////////fn5+Fo7/////fe5+..."
}
}
< /code>
Вот фрагмент кода для потребления звука и отправки звука, которую я использовал: < /p>
@api.websocket("/twilio/wss/{call_id}")
@tracer.start_as_current_span("twilio_wss_post")
async def twilio_wss_post(call_id: str, websocket: WebSocket):
stream_sid = None
stop_event = asyncio.Event()
call_state = await _db.call_get(call_id=UUID(call_id))

if not hasattr(call_state, "audio_to_bot_queue"):
object.__setattr__(call_state, "audio_to_bot_queue", asyncio.Queue())
if not hasattr(call_state, "audio_from_bot_queue"):
object.__setattr__(call_state, "audio_from_bot_queue", asyncio.Queue())

await websocket.accept()

async def _consume_audio():
nonlocal stream_sid
while True:
msg = json.loads(await websocket.receive_text())
if msg["event"] == "stop":
stop_event.set()
break
if msg["event"] == "start":
stream_sid = msg.get("streamSid")
continue
if msg["event"] != "media":
continue
chunk = msg["media"]["payload"]
decoded = b64decode(chunk)
await call_state.audio_to_bot_queue.put(decoded)

async def _send_audio():
CHUNK_SIZE = 160
CHUNK_DELAY = 0.02
timeout_start = time.time()

while stream_sid is None:
if time.time() - timeout_start > 10:
return
await asyncio.sleep(0.01)

while not stop_event.is_set():
try:
audio = call_state.audio_from_bot_queue.get_nowait()
except:
audio = bytes([0xFF] * CHUNK_SIZE)

for i in range(0, len(audio), CHUNK_SIZE):
if stop_event.is_set():
break
chunk = audio[i:i + CHUNK_SIZE]
if len(chunk) < CHUNK_SIZE:
chunk += bytes([0xFF] * (CHUNK_SIZE - len(chunk)))
await websocket.send_text(json.dumps({
"event": "media",
"streamSid": stream_sid,
"media": {
"payload": b64encode(chunk).decode("utf-8")
}
}))
await asyncio.sleep(CHUNK_DELAY)

await asyncio.gather(
_consume_audio(),
_send_audio()
)
< /code>
Я подтвердил: < /p>
Отправленные звуковые воспроизведения идеально локально. Вскоре после этого. Может ли это быть проблема форматирования, времени или потока?
Любая помощь оценена!>

Подробнее здесь: https://stackoverflow.com/questions/796 ... not-played