Qwen-ASR realtime Python SDK

from dashscope.audio.qwen_omni import OmniRealtimeConversation, OmniRealtimeCallback

class MyCallback(OmniRealtimeCallback):
  """实时识别回调"""
  def __init__(self, conversation):
    self.conversation = conversation
    self.handlers = {
      'session.created': self._handle_session_created,
      'conversation.item.input_audio_transcription.completed': self._handle_final_text,
      'conversation.item.input_audio_transcription.text': self._handle_stash_text,
      'input_audio_buffer.speech_started': lambda r: print('======语音开始======'),
      'input_audio_buffer.speech_stopped': lambda r: print('======语音结束======')
    }

  def on_open(self):
    print('连接已打开')

  def on_close(self, code, msg):
    print(f'连接已关闭，状态码: {code}，消息: {msg}')

  def on_event(self, response):
    try:
      handler = self.handlers.get(response['type'])
      if handler:
        handler(response)
    except Exception as e:
      print(f'[Error] {e}')

  def _handle_session_created(self, response):
    print(f"会话已创建: {response['session']['id']}")

  def _handle_final_text(self, response):
    print(f"最终识别文本: {response['transcript']}")

  def _handle_stash_text(self, response):
    print(f"中间识别结果: {response['stash']}")

conversation = OmniRealtimeConversation(
  model='qwen3-asr-flash-realtime',
  url='wss://dashscope.aliyuncs.com/api-ws/v1/realtime',
  callback=MyCallback(conversation=None)  # 先传 None，之后再注入。
)
# 将 conversation 注入回调。
conversation.callback.conversation = conversation

from dashscope.audio.qwen_omni import MultiModality
from dashscope.audio.qwen_omni.omni_realtime import TranscriptionParams

transcription_params = TranscriptionParams(
  language='zh',
  sample_rate=16000,
  input_audio_format="pcm"
)

conversation.update_session(
  output_modalities=[MultiModality.TEXT],
  enable_turn_detection=True,
  turn_detection_type="server_vad",
  turn_detection_threshold=0.0,
  turn_detection_silence_duration_ms=400,
  enable_input_audio_transcription=True,
  transcription_params=transcription_params
)

transcription_params = TranscriptionParams(
  language='zh',
  sample_rate=16000,
  input_audio_format="pcm"
)