在 Python 中使用

from mizuoto.core.context import open_services

with open_services() as services:
    print(services.settings.view().data_dir)

from mizuoto.core.context import open_services
from mizuoto.core.tts.models import CommonParams, SpeakRequest, StyleInput, VoiceInput

with open_services() as s:
    req = SpeakRequest(
        model="qwen3tts/1.7b-custom-voice",
        text="你好，欢迎使用 Mizuoto。",
        voice_spec=VoiceInput(preset="vivian"),
        style=StyleInput(instruct="语气轻快"),
        params=CommonParams(seed=42),
    )
    print(s.tts.plan(req).segments)        # 只检查，不运行
    job = s.tts.speak(req, wait=True)      # 在当前线程运行，返回结束的任务
    if job.state != "completed":
        raise RuntimeError(job.error)
    out = s.outputs.get(job.result["output_id"])
    print(out.path, out.duration, out.sample_rate)

from pathlib import Path

s.models.list_models(engine="qwen3tts", installed=True)   # list[ModelInfo]
s.models.download(["qwen3tts/1.7b-base"], wait=True)       # 下载任务，结束后返回
s.runtime.doctor().findings                                # 本机的 torch 和各引擎，与 mizuoto doctor 相同
voice, warnings = s.voices.create_from_audio("小林", [Path("ref.wav")], ["参考音频里说的话。"], language="zh")
s.voices.list_voices(q="小林")
s.asr.transcribe(Path("clip.wav"), language="zh").text     # 需要已下载语音识别模型

with open_services(start_background=True) as s:
    job = s.tts.speak(req)               # 立即返回，state 为 "queued"
    job = s.jobs.wait(job.id, 600)       # 结束后返回；超时时返回当时的状态

from mizuoto.core.events.models import JobUpdatedEvent

def on_event(event):
    if isinstance(event, JobUpdatedEvent):
        print(event.job.title, event.job.state, event.job.progress)

unsubscribe = s.events.subscribe(on_event)
...
unsubscribe()

from mizuoto.core.errors import MizuotoError, ModelMissingError

try:
    s.tts.speak(req, wait=True)
except ModelMissingError as e:
    print("先下载：", e.detail.get("hint"))
except MizuotoError as e:
    print(e.code, e.message, e.detail)   # 另有 e.http_status、e.exit_code

from mizuoto import MizuotoServer

server = MizuotoServer(data_dir="./mizuoto-data", port=0)
url = server.start()     # 开始监听后立即返回，例如 http://127.0.0.1:54123
print(url)
...
server.stop()

with MizuotoServer(data_dir="./mizuoto-data", port=0) as server:
    print(server.url)
    voices = server.services.voices.list_voices()

server = MizuotoServer(
    data_dir="D:/MyApp/data/mizuoto",
    config_dir="D:/MyApp/config/mizuoto",
    settings={
        "compute": {"default_device": "cuda:0"},
        "paths": {"models_dir": "D:/MyApp/models/tts"},
        "downloads": {"source": "hf-mirror"},
    },
)

from contextlib import asynccontextmanager
from pathlib import Path

from fastapi import FastAPI

from mizuoto.api.app import create_app
from mizuoto.core.context import build_services

services = build_services(data_dir=Path("./mizuoto-data"), start_background=True)
child = create_app(services, bound_host="127.0.0.1", api_prefix="/voice")


@asynccontextmanager
async def lifespan(_app):
    async with child.router.lifespan_context(child):
        yield
    services.close()


app = FastAPI(lifespan=lifespan)
app.mount("/", child)   # 网页界面在 /voice/