Konuşmatik Developer API

import osimport timeimport requests API_KEY = os.environ["KONUSMATIK_API_KEY"]BASE_URL = "https://api.konusmatik.com/api/v1"HEADERS = {"Authorization": f"Bearer {API_KEY}"} def transcribe_audio_corporate_async(file_path: str) -> str:    # 1. İşi Oluştur (HTTP 201 Created döner, bağlantı inference süresince açık kalmaz)    with open(file_path, "rb") as f:        resp = requests.post(            f"{BASE_URL}/corporate/asr/jobs",            headers=HEADERS,            files={"file": (os.path.basename(file_path), f, "audio/wav")},            data={"language": "tr"}        )    resp.raise_for_status()    job_id = resp.json()["id"]    print(f"İş başarıyla kabul edildi. Job ID: {job_id}")     # 2. Polling ile Durumu Sorgula (2-3 saniyelik makul aralık)    while True:        poll_resp = requests.get(f"{BASE_URL}/corporate/asr/jobs/{job_id}", headers=HEADERS)        poll_resp.raise_for_status()        job_data = poll_resp.json()        status = job_data["status"]         if status == "completed":            print("İş tamamlandı!")            break        elif status == "failed":            raise RuntimeError(f"İş başarısız oldu: {job_data.get('error_message')}")         print(f"Mevcut durum: {status}... Bekleniyor.")        time.sleep(2.5)     # 3. Sonucu Al    result_resp = requests.get(f"{BASE_URL}/corporate/asr/jobs/{job_id}/result", headers=HEADERS)    result_resp.raise_for_status()    return result_resp.json()["text"] if __name__ == "__main__":    text = transcribe_audio_corporate_async("toplanti_kaydi.wav")    print("\nTranskripsiyon Sonucu:\n", text)

import osimport timeimport requests API_KEY = os.environ["KONUSMATIK_API_KEY"]BASE_URL = "https://api.konusmatik.com/api/v1"HEADERS = {"Authorization": f"Bearer {API_KEY}", "Content-Type": "application/json"} def synthesize_corporate_async(text: str, output_path: str = "output.wav"):    # 1. İşi Oluştur (Anında 201 Created döner)    resp = requests.post(        f"{BASE_URL}/corporate/tts/jobs",        headers=HEADERS,        json={            "text": text,            "voice": "deniz",            "synthesis_options": {"format": "wav", "speed": 1.0}        }    )    resp.raise_for_status()    job_id = resp.json()["id"]    print(f"TTS İşi oluşturuldu. Job ID: {job_id}")     # 2. Polling ile Takip Et    while True:        poll_resp = requests.get(f"{BASE_URL}/corporate/tts/jobs/{job_id}", headers={"Authorization": f"Bearer {API_KEY}"})        poll_resp.raise_for_status()        job_data = poll_resp.json()        status = job_data["status"]         if status == "completed":            print("Ses sentezi tamamlandı!")            break        elif status == "failed":            raise RuntimeError(f"Hata: {job_data.get('error_message')}")         time.sleep(2.0)     # 3. Sesi İndir (Stream veya Signed Download URL)    stream_resp = requests.get(f"{BASE_URL}/corporate/tts/jobs/{job_id}/stream", headers={"Authorization": f"Bearer {API_KEY}"})    stream_resp.raise_for_status()    with open(output_path, "wb") as f:        f.write(stream_resp.content)    print(f"WAV Ses dosyası kaydedildi: {output_path}") if __name__ == "__main__":    synthesize_corporate_async("Kurumsal toplu seslendirme sistemi.")

import asyncioimport base64import jsonimport osimport sysimport sounddevice as sdimport websockets API_KEY = os.environ.get("KONUSMATIK_API_KEY")if not API_KEY:    print("HATA: 'KONUSMATIK_API_KEY' ortam değişkeni bulunamadı.")    print("PowerShell'de ayarlamak için: $env:KONUSMATIK_API_KEY = 'API_ANAHTARINIZ'")    sys.exit(1) WS_URL = "wss://api.konusmatik.com/api/v1/realtime"SAMPLE_RATE = 24000  # Konuşmatik Realtime PCM16 varsayılan örnekleme hızı (24 kHz)CHANNELS = 1          # MonoBLOCK_SIZE = 2400     # Her 100ms için 2400 örnek (4800 byte) async def main():    headers = {"Authorization": f"Bearer {API_KEY}"}    audio_queue = asyncio.Queue()    loop = asyncio.get_running_loop()     # Mikrofon geri çağırma fonksiyonu (ayrı ses thread'inden çalışır)    def audio_callback(indata, frames, time_info, status):        if status:            print(f"[Ses Uyarısı]: {status}", file=sys.stderr)        loop.call_soon_threadsafe(audio_queue.put_nowait, bytes(indata))     print("Konuşmatik Realtime API'ye bağlanılıyor...")    async with websockets.connect(WS_URL, additional_headers=headers) as ws:        # 1. Oturum Yapılandırması        await ws.send(json.dumps({            "type": "session.update",            "session": {                "model": "konusmatik-asr-v2",                "input_audio_format": "pcm16",                "language": "tr",                "turn_detection": {"type": "server_vad"}            }        }))         # 2. Mikrofondan Ses Gönderme Görevi        async def send_audio():            try:                while True:                    data = await audio_queue.get()                    audio_b64 = base64.b64encode(data).decode("ascii")                    await ws.send(json.dumps({                        "type": "input_audio_buffer.append",                        "audio": audio_b64                    }))            except asyncio.CancelledError:                pass         # 3. Sunucudan Gelen Yanıtları Dinleme Görevi        async def receive_events():            try:                async for message in ws:                    event = json.loads(message)                    event_type = event.get("type", "")                     if event_type == "session.updated":                        print("Mikrofon aktif! Konuşmaya başlayabilirsiniz (Çıkmak için Ctrl+C)...")                        print("------------------------------------------------------------------")                    elif event_type == "conversation.item.input_audio_transcription.delta":                        print(event.get("delta", ""), end="", flush=True)                    elif event_type == "conversation.item.input_audio_transcription.completed":                        transcript = event.get("transcript", "")                        print(f"\n[Nihai Cümle]: {transcript}\n")                    elif event_type == "error":                        print(f"\n[Sunucu Hatası]: {event.get('error', event)}")            except asyncio.CancelledError:                pass         # Mikrofon akışını başlat (sounddevice)        stream = sd.RawInputStream(            samplerate=SAMPLE_RATE,            channels=CHANNELS,            dtype="int16",            blocksize=BLOCK_SIZE,            callback=audio_callback        )         with stream:            send_task = asyncio.create_task(send_audio())            receive_task = asyncio.create_task(receive_events())            try:                # İki görevi aynı anda çalıştır                await asyncio.gather(send_task, receive_task)            except asyncio.CancelledError:                pass            finally:                send_task.cancel()                receive_task.cancel() if __name__ == "__main__":    try:        asyncio.run(main())    except KeyboardInterrupt:        print("\n\nProgram kullanıcı tarafından durduruldu.")