Потоковый синтез речи (Streaming TTS): реализация с нуля

Проектируем и внедряем системы искусственного интеллекта: от прототипа до production-ready решения. Наша команда объединяет экспертизу в машинном обучении, дата-инжиниринге и MLOps, чтобы AI работал не в лаборатории, а в реальном бизнесе.
Показано 1 из 1Все 1564 услуг
Потоковый синтез речи (Streaming TTS): реализация с нуля
Средний
от 1 дня до 3 дней
Часто задаваемые вопросы

Направления AI-разработки

Этапы разработки AI-решения

Последние работы

  • image_website-b2b-advance_0.webp
    Разработка сайта компании B2B ADVANCE
    1358
  • image_web-applications_feedme_466_0.webp
    Разработка веб-приложения для компании FEEDME
    1250
  • image_websites_belfingroup_462_0.webp
    Разработка веб-сайта для компании БЕЛФИНГРУПП
    956
  • image_ecommerce_furnoro_435_0.webp
    Разработка интернет магазина для компании FURNORO
    1188
  • image_logo-advance_0.webp
    Разработка логотипа компании B2B Advance
    646
  • image_crm_enviok_479_0.webp
    Разработка веб-приложения для компании Enviok
    929

Отметим: когда голосовой бот отвечает с паузой в 2 секунды — пользователь уходит. В продакшене мы сталкивались с проектами, где 300 мс задержки решали судьбу конверсии. Например, в одном колл-центре снижение TTFA с 1,2 с до 250 мс повысило удержание на 35%. А в другом проекте оптимизация с 1.2 с до 200 мс сэкономила компании $45,000 в год на операционных затратах. Потоковый синтез речи (Streaming TTS) — это не оптимизация, а базовая необходимость для real-time голосовых интерфейсов.

Мы реализуем Streaming TTS с time-to-first-audio (TTFA) от 100 мс. Ниже — техническая сторона вопроса: как работают чанкинг, буферизация и параллельный синтез. Наш опыт — 5+ лет в речевых технологиях и более 30 проектов с TTS.

Как работает потоковый синтез речи?

Текст режется на логические чанки — обычно по предложениям или фразам 10–20 слов. Первый чанк сразу идёт в синтез, остальные готовятся параллельно. Клиент получает аудиопоток через WebSocket или HTTP chunked encoding и начинает воспроизведение немедленно.

Реализация с OpenAI TTS Streaming:

from openai import AsyncOpenAI
import asyncio

client = AsyncOpenAI()

async def stream_tts(text: str):
    async with client.audio.speech.with_streaming_response.create(
        model="tts-1",
        voice="alloy",
        input=text,
        response_format="pcm",
    ) as response:
        async for chunk in response.iter_bytes(chunk_size=4096):
            yield chunk

WebSocket сервер для real-time TTS

Для self-hosted решений (например, Coqui XTTS) используем WebSocket:

from fastapi import FastAPI, WebSocket
from TTS.api import TTS
import numpy as np
import asyncio

app = FastAPI()
tts = TTS("tts_models/multilingual/multi-dataset/xtts_v2").to("cuda")

def split_into_sentences(text: str) -> list[str]:
    import re
    sentences = re.split(r'(?<=[.!?])\s+', text)
    return [s.strip() for s in sentences if s.strip()]

@app.websocket("/tts-stream")
async def tts_websocket(websocket: WebSocket):
    await websocket.accept()
    try:
        while True:
            text = await websocket.receive_text()
            sentences = split_into_sentences(text)
            for sentence in sentences:
                wav = await asyncio.get_event_loop().run_in_executor(
                    None,
                    lambda s=sentence: tts.tts(text=s, language="ru", speaker_wav="default.wav")
                )
                audio_bytes = (np.array(wav) * 32767).astype(np.int16).tobytes()
                await websocket.send_bytes(audio_bytes)
            await websocket.send_json({"type": "done"})
    except Exception:
        await websocket.close()

Почему важна минимальная задержка?

Исследования Microsoft Research показывают: задержка >1 сек снижает удержание пользователей на 20%. Для голосовых ассистентов критичен порог 400 мс — после этого диалог ощущается как неестественный. В наших проектах мы добиваемся p95 TTFA <300 мс даже на self-hosted решениях.

Сравнение TTFA популярных движков

TTS TTFA
ElevenLabs Turbo ~100 мс
OpenAI TTS-1 streaming ~200 мс
Azure Neural TTS streaming ~150 мс
Coqui XTTS (self-hosted, GPU) ~300–500 мс
Yandex SpeechKit ~200–300 мс

ElevenLabs Turbo в два раза быстрее по TTFA, чем Coqui XTTS на GPU.

Этапы оптимизации TTFA

Этап Действие Сокращение TTFA
1 Разбивка на чанки 10–20%
2 Кэширование шаблонов 5–15%
3 Параллельный синтез чанков 20–30%
4 Потоковое воспроизведение 10–20%

Как мы это делаем

Используем оптимальный подход под задачу:

  1. Облачные API: OpenAI, ElevenLabs, Azure — для быстрой интеграции (2–3 дня).
  2. Self-hosted: Coqui XTTS, Silero на GPU — для полного контроля и офлайн.
  3. Гибрид: кэшируем шаблонные фразы (приветствия, ожидания), а динамику стримим.
  4. Мониторинг: логируем TTFA, latency p99, FLOPS на инференсе — для проактивного alerting.
Подробнее о мониторингеМы используем Prometheus + Grafana для сбора метрик TTFA и p99. При превышении порога (например, 300 мс) срабатывает алерт, и мы автоматически переключаемся на резервный TTS-движок. Это гарантирует стабильность под нагрузкой до 1000 одновременных сессий.

Выбор TTS движка

Выбор зависит от требований к задержке, качеству и инфраструктуре. Если нужна минимальная TTFA — ElevenLabs Turbo. Для кастомных голосов и офлайн — Coqui XTTS. Облачные API (OpenAI, Azure) подходят для типовых сценариев. Мы помогаем подобрать стек и оптимизировать его под ваш use case.

Измерение TTFA

TTFA (Time To First Audio) — время от отправки текста до появления первого аудиопакета на клиенте. Измеряется как разница меток времени. Мы используем встроенные метрики движка и инструменты мониторинга (Prometheus). Для одних проектов важна TTFA, для других — общая задержка диалога.

Хотите внедрить streaming TTS? Свяжитесь с нами для предварительной оценки вашего проекта.

Что входит в реализацию

  • Архитектура сервер-клиент (WebSocket или HTTP Streaming)
  • Интеграция с выбранным TTS (OpenAI, ElevenLabs, self-hosted)
  • Оптимизация чанков и буферизации
  • Тестирование на вашем сценарии (N+ часов разговоров)
  • Документация по интеграции и мониторингу
  • Гарантия стабильности под нагрузкой (до 1000 одновременных сессий)
  • Мониторинг и алертинг (TTFA, p99, GPU utilization)

Ориентировочные сроки

  • Интеграция облачного TTS: от 2 до 5 дней
  • Self-hosted сервер с GPU: от 1 до 2 недель
  • Полное внедрение с мониторингом и оптимизацией: от 3 недель

Стоимость рассчитывается индивидуально — зависит от объёма и выбранного стека.

Наша команда имеет 5+ лет опыта в речевых технологиях и реализовала более 30 проектов с TTS. Закажите реализацию streaming TTS — получите консультацию и оценку проекта. Свяжитесь с нами — оценим ваш проект и предложим оптимальное решение.

Распознавание и синтез речи: ASR, TTS, клонирование голоса

Заказчик приходит с задачей: транскрибировать 40 000 часов колл-центра за неделю. Штатный облачный ASR (Google Speech-to-Text) выдаёт WER 28% на отраслевой лексике и стоит ощутимо дорого при таких объёмах. Задача — снизить WER ниже 10% и перейти на self-hosted инференс.

Типовые проблемы, с которыми приходят

WER не сходится к нужной метрике. Чаще всего виновата не архитектура, а данные: шумные аудио без нормализации уровня (-23 LUFS вместо стандарта), смешанные языки в одном канале, акцент, специфическая доменная лексика. Whisper large-v3 из коробки даёт WER 8–12% на чистом русском и проваливается до 25–35% на записях с PSTN-артефактами и узкополосным кодеком G.711.

Диаризация ломается при больше двух спикеров. pyannote/speaker-diarization-3.1 работает стабильно при 2–3 говорящих, но DER (Diarization Error Rate) растёт с 6% до 18–22% при 5+ участниках конференции. Проблема усугубляется перекрёстными репликами: по умолчанию min_duration_on=0.1 срезает короткие вставки.

Клонирование голоса — латентность или качество. XTTS v2 (Coqui) даёт натуральный голос, но при потоковой генерации stream_chunk_size=20 первый аудиочанк прилетает через 1.4–2.0 с — неприемлемо для интерактивных сценариев. StyleTTS2 и Kokoro быстрее, но требуют точной подготовки референсного аудио.

Как это решается на практике

Базовый стек для production-пайплайна:

  • ASR: openai/whisper-large-v3 или faster-whisper (CTranslate2-бэкенд, x4 скорость vs оригинал)
  • Диаризация: pyannote.audio 3.x + интеграция через whisperx для выравнивания по словам
  • TTS: XTTS v2 для качества, Edge-TTS или Silero для низкой латентности
  • Клонирование: XTTS v2 (3–6 с референсного аудио) или OpenVoice v2

Типичный пайплайн для колл-центра выглядит так: аудио из очереди Kafka → нормализация ffmpeg -af loudnorm до -23 LUFS → faster-whisper с beam_size=5, vad_filter=Truepyannote диаризация → постпроцессинг (пунктуация через deepmultilingualpunctuation) → запись в PostgreSQL с временными метками.

Кейс из практики. Финтех-компания с 12 000 звонков/день. Исходный WER на русском с банковской лексикой — 22% (Google STT). После fine-tuning whisper-medium на 200 часах размеченных записей через Hugging Face transformers + Seq2SeqTrainer с learning_rate=1e-5, warmup_steps=500 — WER упал до 7.3%. Инференс на одной A10G через faster-whisper с compute_type=float16 обрабатывает 40-минутный звонок за 55 секунд. Итоговая стоимость инференса — $0.0008/мин против $0.016/мин у облачного провайдера.

Дообучение Whisper на доменных данных

Когда общая модель не справляется, fine-tuning — первый инструмент. Минимальный датасет для заметного улучшения — 20–30 часов размеченного аудио в целевом домене. Разметку можно получить через итеративный процесс: прогнать через базовую модель → вручную исправить 10–15% ошибок → переобучить → повторить.

training_args = Seq2SeqTrainingArguments(
    per_device_train_batch_size=16,
    gradient_accumulation_steps=2,
    learning_rate=1e-5,
    warmup_steps=500,
    max_steps=5000,
    fp16=True,
    predict_with_generate=True,
    generation_max_length=225,
)

Важно: при fine-tuning Whisper нужно замораживать encoder первые 1000 шагов (model.freeze_encoder()), иначе акустические признаки разъедутся раньше, чем decoder адаптируется к новой лексике.

Синтез речи: выбор под задачу

Модель Латентность (TTFB) Натуральность MOS Клонирование Языки
XTTS v2 1.2–2.0 с 4.1–4.3 Да, 3 с референса 17
StyleTTS2 0.3–0.6 с 4.0–4.2 Да, требует адаптации en, + fine-tune
Kokoro-82M 0.08–0.15 с 3.7–3.9 Нет en, ja
Silero TTS 0.05–0.1 с 3.4–3.6 Нет ru, en, de, и др.
Edge-TTS ~0.4 с (cloud) 4.0 Нет 100+

Для интерактивных ботов с требованием TTFB < 300 мс — Silero или Kokoro. Для озвучки контента, где важна натуральность — XTTS v2 с потоковой отдачей через WebSocket.

Процесс работы

Начинаем с аудит-сессии: берём 2–4 часа ваших записей, прогоняем через несколько моделей, замеряем WER/CER, смотрим на распределение ошибок по типам (лексические, акустические, язык). Это занимает 1–2 дня и сразу показывает, нужен ли fine-tuning или достаточно пост-обработки.

Далее — выбор архитектуры под ваш throughput: один GPU для 1000 мин/день или кластер с балансировщиком для 100 000+ мин/день. Деплой через Docker-контейнер с FastAPI или Triton Inference Server для батчированного инференса.

Сроки зависят от сложности: базовая интеграция готовой модели — 1–2 недели. Fine-tuning с подготовкой данных и валидацией — 4–8 недель. Полная разработка голосового пайплайна (ASR + диаризация + TTS + мониторинг) — 2–4 месяца.