deploy docker

producer_chat/producer_chat.py

@@ -10,7 +10,6 @@ import json
 import uuid
 from datetime import datetime, timezone
 from dotenv import load_dotenv
-import tempfile
 import hashlib
 from pydantic import BaseModel, Field
 
@@ -65,8 +64,7 @@ KAFKA_TTS_TOPIC = os.getenv('KAFKA_TTS_TOPIC')
 KAFKA_ASR_TOPIC = os.getenv('KAFKA_ASR_TOPIC')
 KAFKA_CHAT_TOPIC = os.getenv('KAFKA_CHAT_TOPIC')
 
-OUTPUT_PATH= os.getenv('OUTPUT_PATH')
-
+UPLOAD_DIR = os.getenv('UPLOAD_DIR')
 # 初始化 Kafka Producer
 producer = KafkaProducer(
     bootstrap_servers=[KAFKA_BROKER],
@@ -261,7 +259,6 @@ async def tts_request(request: TTSRequest, api_key_info: dict = Depends(verify_a
 async def asr_request(audio: UploadFile = File(...), api_key_info: dict = Depends(verify_api_key)):
     task_id = str(uuid.uuid4())
     
-    UPLOAD_DIR = "/obscura/task/audio_upload"
     os.makedirs(UPLOAD_DIR, exist_ok=True)
     file_path = os.path.join(UPLOAD_DIR, f"{task_id}.wav")