qi( d Z ddlZddlmZ ddlmZ ddlmZmZm Z m
Z
ddl Z ddl m
Z
ddlmZmZmZ ddlmZmZ dd lmZ dd
lmZ dd lmZ dd lm Z e G d de Z! G d de Z"e G d de Z# G d de Z$y# e $ r7Z e
j> d
e e
j> d e de dZ [ ww xY w)z!Piper TTS service implementation. N) dataclass)Path)AnyAsyncGenerator
AsyncIteratorOptional)logger)
ErrorFrameFrameTTSStoppedFrame) TTSSettings_warn_deprecated_param)
TTSService)
traced_tts)
PiperVoice)download_voicez Exception: zCIn order to use Piper, you need to `pip install pipecat-ai[piper]`.zMissing module: c e Zd ZdZy)PiperTTSSettingsz Settings for PiperTTSService.N__name__
__module__ __qualname____doc__ L/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/services/piper/tts.pyr r # s 'r r c e Zd ZU dZeZeed< dddddddee dee de
d e
d
ee f
fd Z d e
fd
Z ded e
eef f fd Zededed eedf fd Z xZS )PiperTTSServicezPiper TTS service implementation.
Provides local text-to-speech synthesis using Piper voice models. Automatically
downloads voice models if not already present and resamples audio output to
match the configured sample rate.
_settingsNF)voice_id download_dirforce_redownloaduse_cudasettingsr r! r" r# r$ c 2 t ddd }|t dt d ||_ ||j | t | ddd|d| |xs t
j }| j j }| d} t
| | z }
|
j s't j d| d t |||
t j d | d |
t j |
|
| _ t j d| d y)a Initialize the Piper TTS service.
Args:
voice_id: Piper voice model identifier (e.g. `en_US-ryan-high`).
.. deprecated:: 0.0.105
Use ``settings=PiperTTSSettings(voice=...)`` instead.
download_dir: Directory for storing voice model files. Defaults to
the current working directory.
force_redownload: Re-download the voice model even if it already exists.
use_cuda: Use CUDA for GPU-accelerated inference.
settings: Runtime-updatable settings. When provided alongside deprecated
parameters, ``settings`` values take precedence.
**kwargs: Additional arguments passed to the parent `TTSService`.
Nmodelvoicelanguager r( Tpush_start_framepush_stop_framesr$ z.onnxzDownloading Piper 'z' model)r" zLoading Piper 'z
' model from )r# zLoaded Piper 'r )r r r( apply_updatesuper__init__r cwdr existsr debugr r load_voice) selfr r! r" r# r$ kwargsdefault_settingsr4
model_filemodel_path_resolved __class__s r r/ zPiperTTSService.__init__5 s 6 ,$dTR ":/? I%- "
) )( 3
! !%
$1txxz %% xu%
"< 0: ="))+ LL.vhg> ? 6
.async_next s"
Bx
s
r; c t K t j | d { }|y |j 17 wrJ )asyncio to_threadaudio_int16_bytes)iteratoritemrN s r async_iteratorz/PiperTTSService.run_tts..async_iterator s; $ . .z8 DD<,,, Ds 868: Generating TTS []N)in_sample_raterG z exception: Unknown error occurred: errorz: Finished TTS [)r bytesr r2 start_tts_usage_metrics"_stream_audio_frames_from_iteratorr4
synthesizeconfig sample_ratestop_ttfb_metrics Exceptionr[ r
)r5 rF rG rU frameerN s @r run_ttszPiperTTSService.run_tts sm -mE.B - v /vQ78 +..t4 4 4 # F F t{{ 5 5d ;< #{{ 1 1 = =% G
e
,,...
5
/ C LLD6 aS1 2 %=aS#AB B B C
LLD6!1$q9 :((* * *
LLD6!1$q9 :((* * *s 2E?C
C AC C
$C %C
(C <C = C C
C
C E D,D E DE .E??E E?/E<5E86E<<E?)r r r r r Settings__annotations__r strr boolr/ r? dictr rC r r r rf
__classcell__r: s @r r r * s H
#''+!& /3=7 3-=7 tn =7
=7
=7 +,=7~d
,<
c3h
)+# )+3 )+>%QU+;V )+ )+r r c e Zd ZdZy)PiperHttpTTSSettingsz!Settings for PiperHttpTTSService.Nr r r r ro ro s +r ro c
e Zd ZU dZeZeed< ddddedej de
e de
e f fd Z d
e fd Z
ed ed
ed
eedf fd Z xZS )PiperHttpTTSServicezPiper HTTP TTS service implementation.
Provides integration with Piper's HTTP TTS server for text-to-speech
synthesis. Supports streaming audio generation with configurable sample
rates and automatic WAV header removal.
r N)r r$ base_urlaiohttp_sessionr r$ c t ddd }|t dt d ||_ ||j | t | d
dd|d| |j
d rt j d |dd }|| _ || _
y) ak Initialize the Piper TTS service.
Args:
base_url: Base URL for the Piper TTS HTTP server.
aiohttp_session: aiohttp ClientSession for making HTTP requests.
voice_id: Piper voice model identifier (e.g. `en_US-ryan-high`).
.. deprecated:: 0.0.105
Use ``settings=PiperHttpTTSSettings(voice=...)`` instead.
settings: Runtime-updatable settings. When provided alongside deprecated
parameters, ``settings`` values take precedence.
**kwargs: Additional arguments passed to the parent TTSService.
Nr& r r( Tr* /z0Base URL ends with a slash, this is not allowed.r ) ro r r( r- r. r/ endswithr warning _base_url_session)r5 rr rs r r$ r6 r7 r: s r r/ z PiperHttpTTSService.__init__ s 0 0d$QUV ":/CW M%- "
) )( 3
! !%
S ! NNM N }H!'
r r; c yr= r r> s r r? z(PiperHttpTTSService.can_generate_metrics r@ r rF rG c K t j | d| d ddi} || j j d}| j j | j || 4 d{ }|j dk7 rq|j d{ }t d |j d
| d t |
ddd d{ | j d{ y| j | d{ | j }| j |j j! | d| 2 3 d{ }| j d{ | '7 7 7 7 7 l7 ,7 6 ddd d{ 7 n# 1 d{ 7 sw Y nxY wn(# t" $ r } t d| Y d} ~ nd} ~ ww xY w| j d{ 7 y# | j d{ 7 w xY ww)a Generate speech from text using Piper's HTTP API.
Args:
text: The text to convert to speech.
context_id: Unique identifier for this TTS context.
Yields:
Frame: Audio frames containing the synthesized speech and status frames.
rV rW z Content-Typezapplication/json)rF r( )jsonheadersN z Error getting audio (status: z , error: )rZ )rG T)strip_wav_headerrG rY )r r2 r r( rz postry statusrF r
r rb r]
chunk_sizer^ content iter_chunkedrc )
r5 rF rG r~ dataresponser[
CHUNK_SIZErd re s
r rf zPiperHttpTTSService.run_tts
s v /vQ78 .
+ --D
}}))$..tW)U
Ya??c)"*--/ 1E$ =hoo=NiX]W^^_ ` *Z@@
. ((* * * 224888 !__
#'#J#J $$11*=%) ) $K $ %
00222 K'
1
.
+ 9
3 $
( C %=aS#AB B B C ((* * *$((* * *s+ G=AF (E&)F ,#FE(4F F E*F G='E,(G=-FE.=F?E4E0E4FE2
F&F (F*F ,G=.F0E42F4F5 F FF F
F FF G G&F=8G =GG G=GG= G:3G64G::G=)r r r r ro rg rh ri aiohttp
ClientSessionr r/ rj r? r r r rf rl rm s @r rq rq s $H## #'37
1( 1( !.. 1(
3- 1( /0
1(fd ++# ++3 ++>%QU+;V ++ ++r rq )%r rP dataclassesr pathlibr typingr r r r r logurur pipecat.frames.framesr
r r pipecat.services.settingsr
r pipecat.services.tts_servicer (pipecat.utils.tracing.service_decoratorsr piperr piper.download_voicesr ModuleNotFoundErrorre r[ rc r r ro rq r r r r s ( ! ? ?
J 3 ?, 4 { H+j H+f ; r+* r+O ,FLL;qc"#FLLVW
&qc*
++,s B C2CC