功能介紹

單句模式自動檢測一句話的結(jié)束，因此適合于需要與您的系統(tǒng)進行交互的場景，例如外呼、控制口令等場景。

實時語音識別引擎的單句識別模式，和連續(xù)識別模式類似，也會進行語音的端點檢測，如果檢測到靜音，將直接丟棄，檢測到語音才會饋入核心進行實際的解碼工作，如果檢測到一段語音的結(jié)束點，就會將當前這一段的識別結(jié)果返回。和連續(xù)識別不同的是，在單句模式下，返回第一段的識別結(jié)果后，將不再繼續(xù)識別后續(xù)的音頻。這主要是用于和用戶進行 語音交互 的場景下，當用戶說完一句話后，往往會等待后續(xù)的交互操作，例如聆聽根據(jù)識別結(jié)果播報的相關(guān)內(nèi)容，因而沒有必要繼續(xù)識別后續(xù)的音頻。

wss-URI

• wss-URI格式：

  wss /v1/{project_id}/rasr/sentence-stream

• 參數(shù)說明

  表1 參數(shù)說明

  參數(shù)名	是否必選	說明
  project_id	是	項目編號。獲取方法，請參見獲取項目ID。

  表2 請求Header參數(shù)

  參數(shù)	是否必選	參數(shù)類型	描述
  X-Auth-Token	是	String	用戶Token。 用于獲取操作API的權(quán)限。獲取方法請參見認證鑒權(quán)。響應消息頭中X-Subject-Token的值即為Token。
  Enterprise-Project-Id	否	String	企業(yè)項目ID。SIS支持通過企業(yè)項目管理（EPS）對不同用戶組和用戶的資源使用，進行分賬。 獲取方法：進入“企業(yè)項目管理”頁面，單擊企業(yè)項目名稱，在企業(yè)項目詳情頁獲取Enterprise-Project-Id（企業(yè)項目ID）。 企業(yè)項目創(chuàng)建步驟請參見用戶指南。 說明： 賬戶創(chuàng)建企業(yè)項目后，在傳參時，有以下三類場景。 攜帶正確的ID，正常使用SIS服務，賬單歸到企業(yè)ID對應的企業(yè)項目中。 攜帶錯誤的ID，正常使用SIS服務，賬單的企業(yè)項目會被分類為“default”。 不攜帶ID，正常使用SIS服務，賬單的企業(yè)項目會被分類為“default”。

• 請求示例（偽碼）

  wss://{endpoint}/v1/{project_id}/rasr/sentence-stream
  
  Request Header:
  X-Auth-Token: MIINRwYJKoZIhvcNAQcCoIINODCCDTQCAQExDTALBglghkgBZQMEAgEwgguVBgkqhkiG...

  

  “endpoint”即調(diào)用API的請求地址，不同服務不同區(qū)域的“endpoint”不同，具體請參見終端節(jié)點。

• Python3語言請求代碼示例

  # -*- coding: utf-8 -*-
  # 此demo僅供測試使用，強烈建議使用sdk。需提前安裝websocket-client, 執(zhí)行pip install websocket-client
  import websocket
  import threading
  import time
  import json
  
  def rasr_demo():
      url = 'wss://{{endpoint}}/v1/{{project_id}}/rasr/sentence-stream'  # endpoint和project_id需替換
      audio_path = '音頻路徑'
      token = '用戶對應region的token'
      header = {
          'X-Auth-Token': token
      }
      with open(audio_path, 'rb') as f:
          data = f.read()
      body = {
          'command': 'START',
          'config': {
              'audio_format': 'pcm8k16bit',
              'property': 'chinese_8k_general'
          }
      }
      def _on_message(ws, message):
          print(message)
      def _on_error(ws, error):
          print(error)
      ws = websocket.WebSocketApp(url, header, on_message=_on_message, on_error=_on_error)
      _thread = threading.Thread(target=ws.run_forever, args=(None, None, 30, 20))
      _thread.start()
      time.sleep(1)
      ws.send(json.dumps(body), opcode=websocket.ABNF.OPCODE_TEXT)
      now_index = 0
      byte_len = 4000
      while now_index < len(data):
          next_index = now_index + byte_len
          if next_index > len(data):
              next_index = len(data)
          send_array = data[now_index: next_index]
          ws.send(send_array, opcode=websocket.ABNF.OPCODE_BINARY)
          now_index += byte_len
          time.sleep(0.05)
      ws.send("{\"command\": \"END\", \"cancel\": \"false\"}", opcode=websocket.ABNF.OPCODE_TEXT)
      time.sleep(10)
      ws.close()
  if __name__ == '__main__':
      rasr_demo()

• Java語言請求代碼示例

  import okhttp3.OkHttpClient;
  import okhttp3.Request;
  import okhttp3.Response;
  import okhttp3.WebSocket;
  import okhttp3.WebSocketListener;
  import okio.ByteString;
  import java.net.URL;
  
  /**
   * 此demo僅供測試使用，強烈建議使用SDK
   * 使用前需已配置okhttp、okio jar包。jar包可通過下載SDK獲取。
   */
  public class RasrDemo {
    public void rasrDemo() {
      try {
        // endpoint和projectId需要替換成實際信息。
        String url = "wss://{{endpoint}}/v1/{{project_id}}/rasr/sentence-stream";
        String token = "對應region的token";
        byte[] data = null;  // 存放將要發(fā)送音頻的byte數(shù)組
        OkHttpClient okHttpClient = new OkHttpClient();
        Request request = new Request.Builder().url(url).header("X-Auth-Token", token).build();
        WebSocket webSocket = okHttpClient.newWebSocket(request, new MyListener());
        webSocket.send("{\"command\": \"START\", \"config\": {\"audio_format\": \"pcm8k16bit\", \"property\": \"chinese_8k_general\"}}");
        webSocket.send(ByteString.of(data));
        webSocket.send("{  \"command\": \"END\",  \"cancel\": false}");
        Thread.sleep(10000);
        webSocket.close(1000, null);
      } catch (Exception e) {
        e.printStackTrace();
      }
    }
  
    class MyListener extends WebSocketListener {
      @Override
      public void onOpen(WebSocket webSocket, Response response) {
        System.out.println("conneected");
      }
      @Override
      public void onClosed(WebSocket webSocket, int code, String reason) {
        System.out.println("closed");
      }
      @Override
      public void onFailure(WebSocket webSocket, Throwable t, Response response) {
        t.printStackTrace();
      }
      @Override
      public void onMessage(WebSocket webSocket, String text) {
        System.out.println(text);
      }
    }
    public static void main(String[] args) {
      RasrDemo rasrDemo = new RasrDemo();
      rasrDemo.rasrDemo();
    }
  }

• JavaScript（nodejs推薦使用v18.20.2 ( LTS )版本）

  // 導入 Node.js 的 ws 庫
  const WebSocket = require('ws');
  function sentenceStreamDemo(endpoint,audioPath, projectID, token) {
      const url = `wss://${endpoint}/v1/${projectID}/rasr/sentence-stream`;  // 替換 endpoint 和 projectID
      // 讀取音頻文件內(nèi)容
      const fs = require('fs');
      let data = fs.readFileSync(audioPath);
      // HTTP Headers中攜帶Token
      const headers = {
          'X-Auth-Token': token,
          //  企業(yè)id 可選加
          // 'Enterprise-Project-Id': 企業(yè)id
      };
      // 創(chuàng)建WebSocket實例
      const ws = new WebSocket(url, {
          headers // 添加自定義HTTP頭
      });
      ws.on('open', async () => {
          const body = {
              command: 'START',
              config: {
                  audio_format: 'pcm16k16bit',
                  property: 'chinese_16k_general'
              }
          };
          ws.send(JSON.stringify(body));
          let nowIndex = 0;
          const byteLen = 3200; // 禁止空值輸入 建議范圍 2000-10000
          while (nowIndex < data.length) {
              const nextIndex = nowIndex + byteLen;
              const sendArray = data.slice(nowIndex, nextIndex > data.length ? data.length : nextIndex);
              ws.send(sendArray, { binary: true });
              nowIndex += byteLen;
              await new Promise(resolve => setTimeout(resolve, 100)); // 模擬延時(單位ms)
          }
          const endCommand = JSON.stringify({ command: 'END', cancel: 'false' });
          ws.send(endCommand);
      });
      ws.on('message', (data) => {
          if (data instanceof Buffer) {
              // 將Buffer轉(zhuǎn)換為UTF-8編碼的字符串
              const messageString = data.toString('utf8');
              console.log('Received (converted from Buffer):', messageString);
              const type = JSON.parse(messageString).resp_type;
              if (type ==='END'|| type ==='ERROR') {
                  ws.close();
              }
          }
      });
      ws.on('error', (error) => {
          console.error('WebSocket Error:', error);
      });
  };
  sentenceStreamDemo(endpoint,audioPath, projectID, token);