阿里云录音文件识别实例DEMO

1. <?php
   
2. require __DIR__ . '/vendor/autoload.php';
   
3. use AlibabaCloud\Client\AlibabaCloud;
   
4. use AlibabaCloud\Client\Exception\ClientException;
   
5. use AlibabaCloud\Client\Exception\ServerException;
   
6. class NLSFileTrans {
   
7.     // 请求参数
   
8.     private const KEY_APP_KEY = "appkey";
   
9.     private const KEY_FILE_LINK = "file_link";
   
10.     private const KEY_VERSION = "version";
    
11.     private const KEY_ENABLE_WORDS = "enable_words";
    
12.     // 响应参数
    
13.     private const KEY_TASK_ID = "TaskId";
    
14.     private const KEY_STATUS_TEXT = "StatusText";
    
15.     private const KEY_RESULT = "Result";
    
16.     // 状态值
    
17.     private const STATUS_SUCCESS = "SUCCESS";
    
18.     private const STATUS_RUNNING = "RUNNING";
    
19.     private const STATUS_QUEUEING = "QUEUEING";
    
20.     function submitFileTransRequest($appKey, $fileLink) {
    
21.         // 获取task JSON字符串，包含appkey和file_link参数等。
    
22.         // 新接入请使用4.0版本，已接入（默认2.0）如需维持现状，请注释掉该参数设置。
    
23.         // 设置是否输出词信息，默认为false，开启时需要设置version为4.0。
    
24.         $taskArr = array(self::KEY_APP_KEY => $appKey, self::KEY_FILE_LINK => $fileLink, self::KEY_VERSION => "4.0", self::KEY_ENABLE_WORDS => FALSE);
    
25.         $task = json_encode($taskArr);
    
26.         print $task . "\n";
    
27.         try {
    
28.             // 提交请求，返回服务端的响应。
    
29.             $submitTaskResponse = AlibabaCloud::nlsFiletrans()
    
30.                                               ->v20180817()
    
31.                                               ->submitTask()
    
32.                                               ->withTask($task)
    
33.                                               ->request();
    
34.             print $submitTaskResponse . "\n";
    
35.             // 获取录音文件识别请求任务的ID，以供识别结果查询使用。
    
36.             $taskId = NULL;
    
37.             $statusText = $submitTaskResponse[self::KEY_STATUS_TEXT];
    
38.             if (strcmp(self::STATUS_SUCCESS, $statusText) == 0) {
    
39.                 $taskId = $submitTaskResponse[self::KEY_TASK_ID];
    
40.             }
    
41.             return $taskId;
    
42.         } catch (ClientException $exception) {
    
43.             // 获取错误消息
    
44.             print_r($exception->getErrorMessage());
    
45.         } catch (ServerException $exception) {
    
46.             // 获取错误消息
    
47.             print_r($exception->getErrorMessage());
    
48.         }
    
49.     }
    
50.     function getFileTransResult($taskId) {
    
51.         $result = NULL;
    
52.         while (TRUE) {
    
53.             try {
    
54.                 $getResultResponse = AlibabaCloud::nlsFiletrans()
    
55.                                                  ->v20180817()
    
56.                                                  ->getTaskResult()
    
57.                                                  ->withTaskId($taskId)
    
58.                                                  ->request();
    
59.                 print "识别查询结果: " . $getResultResponse . "\n";
    
60.                 $statusText = $getResultResponse[self::KEY_STATUS_TEXT];
    
61.                 if (strcmp(self::STATUS_RUNNING, $statusText) == 0 || strcmp(self::STATUS_QUEUEING, $statusText) == 0) {
    
62.                     // 继续轮询
    
63.                     sleep(10);
    
64.                 }
    
65.                 else {
    
66.                     if (strcmp(self::STATUS_SUCCESS, $statusText) == 0) {
    
67.                         $result = $getResultResponse;
    
68.                     }
    
69.                     // 退出轮询
    
70.                     break;
    
71.                 }
    
72.             } catch (ClientException $exception) {
    
73.                 // 获取错误消息
    
74.                 print_r($exception->getErrorMessage());
    
75.             } catch (ServerException $exception) {
    
76.                 // 获取错误消息
    
77.                 print_r($exception->getErrorMessage());
    
78.             }
    
79.         }
    
80.         return $result;
    
81.     }
    
82. }
    
83. $accessKeyId = "您的AccessKey Id";
    
84. $accessKeySecret = "您的AccessKey Secret";
    
85. $appKey = "您的appkey";
    
86. $fileLink = "https://gw.alipayobjects.com/os/bmw-prod/0574ee2e-f494-45a5-820f-63aee583045a.wav";
    
87. /**
    
88.   * 第一步：设置一个全局客户端。
    
89.   * 使用阿里云RAM账号的AccessKey ID和AccessKey Secret进行鉴权。
    
90. */
    
91. AlibabaCloud::accessKeyClient($accessKeyId, $accessKeySecret)
    
92.             ->regionId("cn-shanghai")
    
93.             ->asGlobalClient();
    
94. $fileTrans = new NLSFileTrans();
    
95. /**
    
96.   *  第二步：提交录音文件识别请求，获取任务ID，用于后续的识别结果轮询。
    
97. */
    
98. $taskId = $fileTrans->submitFileTransRequest($appKey, $fileLink);
    
99. if ($taskId != NULL) {
    
100.     print "录音文件识别请求成功，task_id: " . $taskId . "\n";
     
101. }
     
102. else {
     
103.     print "录音文件识别请求失败!";
     
104.     return ;
     
105. }
     
106. /**
     
107.   * 第三步：根据任务ID轮询识别结果。
     
108. */
     
109. $result = $fileTrans->getFileTransResult($taskId);
     
110. if ($result != NULL) {
     
111.     print "录音文件识别结果查询成功: " . $result . "\n";
     
112. }
     
113. else {
     
114.     print "录音文件识别结果查询失败!";
     
115. }

复制代码

以上实例为PHPSDK2.0（openapi-sdk-php）

1. <?php
   
2. 
   
3. namespace App\Helpers\Utils\Alibaba;
   
4. 
   
5. use AlibabaCloud\Client\AlibabaCloud;
   
6. use AlibabaCloud\Client\Exception\ClientException;
   
7. use AlibabaCloud\Client\Exception\ServerException;
   
8. use Illuminate\Support\Facades\Log;
   
9. 
   
10. class NLSFileTrans {
    
11.     // 请求参数
    
12.     private const KEY_APP_KEY = "appkey";
    
13.     private const KEY_FILE_LINK = "file_link";
    
14.     private const KEY_VERSION = "version";
    
15.     private const KEY_ENABLE_WORDS = "enable_words";
    
16.     // 响应参数
    
17.     private const KEY_TASK_ID = "TaskId";
    
18.     private const KEY_STATUS_TEXT = "StatusText";
    
19.     private const KEY_RESULT = "Result";
    
20.     // 状态值
    
21.     private const STATUS_SUCCESS = "SUCCESS";
    
22.     private const STATUS_RUNNING = "RUNNING";
    
23.     private const STATUS_QUEUEING = "QUEUEING";
    
24. 
    
25.     public function submitFileTransRequest(string $appKey, $fileLink) {
    
26.         // 获取task JSON字符串，包含appkey和file_link参数等。
    
27.         // 新接入请使用4.0版本，已接入（默认2.0）如需维持现状，请注释掉该参数设置。
    
28.         // 设置是否输出词信息，默认为false，开启时需要设置version为4.0。
    
29.         $taskArr = array(
    
30.             self::KEY_APP_KEY => $appKey,
    
31.             self::KEY_FILE_LINK => $fileLink,
    
32.             self::KEY_VERSION => "4.0",
    
33.             self::KEY_ENABLE_WORDS => FALSE,
    
34.             // @ref: https://help.aliyun.com/document_detail/90727.html#sectiondiv-qto-pl7-lvd
    
35.             // 检查实际语音的采样率和控制台上Appkey绑定的ASR模型采样率是否一致
    
36.             "enable_sample_rate_adaptive" => true,
    
37.         );
    
38.         $task = json_encode($taskArr);
    
39.         Log::debug($task);
    
40. 
    
41.         // 提交请求，返回服务端的响应。
    
42.         $submitTaskResponse = AlibabaCloud::nlsFiletrans()
    
43.             ->v20180817()
    
44.             ->submitTask()
    
45.             ->withTask($task)
    
46.             ->request();
    
47.         Log::info($submitTaskResponse);
    
48.         // 获取录音文件识别请求任务的ID，以供识别结果查询使用。
    
49.         $taskId = NULL;
    
50.         $statusText = $submitTaskResponse[self::KEY_STATUS_TEXT];
    
51.         if (strcmp(self::STATUS_SUCCESS, $statusText) == 0) {
    
52.             $taskId = $submitTaskResponse[self::KEY_TASK_ID];
    
53.         }
    
54.         return $taskId;
    
55. 
    
56.     }
    
57. 
    
58.     public function getFileTransResult($taskId) {
    
59.         $result = NULL;
    
60.         try {
    
61.             $getResultResponse = AlibabaCloud::nlsFiletrans()
    
62.                 ->v20180817()
    
63.                 ->getTaskResult()
    
64.                 ->withTaskId($taskId)
    
65.                 ->request();
    
66.             Log::notice("识别查询结果: " . json_encode($getResultResponse));
    
67. 
    
68.             // $statusText = $getResultResponse[self::KEY_STATUS_TEXT];
    
69.             // if (strcmp(self::STATUS_RUNNING, $statusText) == 0 || strcmp(self::STATUS_QUEUEING, $statusText) == 0) {}
    
70.             // else {if (strcmp(self::STATUS_SUCCESS, $statusText) == 0) {$result = $getResultResponse;}}
    
71.             $result = $getResultResponse;
    
72.         } catch (ClientException $exception) {
    
73.             // 获取错误消息
    
74.             print_r($exception->getErrorMessage());
    
75.         } catch (ServerException $exception) {
    
76.             // 获取错误消息
    
77.             print_r($exception->getErrorMessage());
    
78.         }
    
79.         return $result;
    
80.     }
    
81. }
    

复制代码

1. <?php
   
2. 
   
3. namespace App\Services;
   
4. 
   
5. use AlibabaCloud\Client\AlibabaCloud;
   
6. use AlibabaCloud\Client\Exception\ClientException;
   
7. use AlibabaCloud\Client\Exception\ServerException;
   
8. use App\Enums\ErrorCode;
   
9. use App\Helpers\Utils\Alibaba\NLSFileTrans;
   
10. use App\Helpers\Utils\Alibaba\OSS;
    
11. use App\Models\Work;
    
12. use Spatie\Permission\Exceptions\UnauthorizedException;
    
13. 
    
14. class ApiService
    
15. {
    
16.     /**
    
17.      * 提交录音文件识别请求，获取任务ID
    
18.      * @param string $fileLink
    
19.      * @return array
    
20.      */
    
21.     public function asrCreateTask(string $fileLink) {
    
22.         $accessKeyId = config('constant.alibaba_access_key_id');
    
23.         $accessKeySecret = config('constant.alibaba_access_key_secret');
    
24.         $appKey = config('constant.alibaba_app_key');
    
25. 
    
26.         /**
    
27.          * 第一步：设置一个全局客户端。
    
28.          * 使用阿里云RAM账号的AccessKey ID和AccessKey Secret进行鉴权。
    
29.          */
    
30.         AlibabaCloud::accessKeyClient($accessKeyId, $accessKeySecret)
    
31.             ->regionId("cn-shanghai")
    
32.             ->asGlobalClient();
    
33. 
    
34.         $fileTrans = new NLSFileTrans();
    
35.         /**
    
36.          * @var $appKeyId string
    
37.          * @ref: https://nls-portal.console.aliyun.com/applist 我的所有项目(不是access key)
    
38.          * 确认开通了asr+tts服务
    
39.          * https://nls-portal.console.aliyun.com/
    
40.          */
    
41.         try {
    
42.             $taskId = $fileTrans->submitFileTransRequest($appKey, $fileLink);
    
43.             if ($taskId != NULL) {
    
44.                 $msg = "录音文件识别请求成功";
    
45.                 return ['message' => $msg, 'code' => ErrorCode::OK, 'result' => ['task_id'=>$taskId], 'time'=>time()];
    
46.             }
    
47.         } catch (ClientException $e) {
    
48.             // 获取错误消息
    
49.             return ['message' => "failed", 'code'=> $e->getErrorCode(), 'error'=>$e->getErrorMessage()];
    
50.         } catch (ServerException $e) {
    
51.             return ['message' => "failed", 'code'=> $e->getErrorCode(), 'error'=>$e->getErrorMessage()];
    
52.         }
    
53.         return ['message'=>"failed", 'code'=> ErrorCode::API_ERROR, 'error'=>"语音识别任务创建失败"];
    
54.     }
    
55. 
    
56.     /**
    
57.      * 异步查询ASR任务结果
    
58.      * @param string $taskId
    
59.      * @return array
    
60.      * @throws ClientException
    
61.      */
    
62.     public function asrQuery(string $taskId) {
    
63.         $accessKeyId = config('constant.alibaba_access_key_id');
    
64.         $accessKeySecret = config('constant.alibaba_access_key_secret');
    
65.         /**
    
66.          * 第一步：设置一个全局客户端。
    
67.          * 使用阿里云RAM账号的AccessKey ID和AccessKey Secret进行鉴权。
    
68.          */
    
69.         AlibabaCloud::accessKeyClient($accessKeyId, $accessKeySecret)
    
70.             ->regionId("cn-shanghai")
    
71.             ->asGlobalClient();
    
72. 
    
73.         $fileTrans = new NLSFileTrans();
    
74.         /**
    
75.          * 第三步：根据任务ID轮询识别结果。
    
76.          * @var $result \AlibabaCloud\Client\Result\Result
    
77.          */
    
78.         $result = $fileTrans->getFileTransResult($taskId);
    
79.         if (is_null($result)) {
    
80.             return ['message'=>"failed", 'code'=> ErrorCode::API_ERROR, 'error'=>"录音文件识别结果查询失败!",'time'=>time()];
    
81.         }
    
82.         /** @var $s string JSON string */
    
83.         $s = $result->toJson();
    
84.         header("Content-Type: application/json");
    
85.         echo $s;
    
86.         exit(0);
    
87.     }
    
88. 
    
89.     public function fetchWork(int $workId, int $memberId, string $downloadType = 'wav') {
    
90.         /** @var $work Work */
    
91.         $work = Work::find($workId);
    
92.         if (empty($work)) {
    
93.             throw new \InvalidArgumentException("作品ID不存在", ErrorCode::PARAM_ERROR);
    
94.         }
    
95.         if (0 != $work->getMemberId()-$memberId) {
    
96.             throw new UnauthorizedException(ErrorCode::PERMISSION_DENIED, "只能下载自己的作品");
    
97.         }
    
98.         return $work;
    
99.     }
    
100. 
     
101.     public function upload(string $path, string $ext, string $bucket) {
     
102.         $oss = new OSS();
     
103.         $filename = md5_file($path);
     
104. 
     
105.         $uri = sprintf("%s/%s.%s", date("Y-m-d", time()), $filename, $ext);
     
106.         $oss->bucket($bucket)->upload($uri, $path, $bucket);
     
107.         return "https://".$bucket.".".OSS::END_POINT."/".$uri;
     
108.     }
     
109. }

复制代码

1. <?php
   
2. namespace app\index\loglic;
   
3. use AlibabaCloud\Client\AlibabaCloud;
   
4. use AlibabaCloud\Client\Exception\ClientException;
   
5. use AlibabaCloud\Client\Exception\ServerException;
   
6. class AliRecord
   
7. {
   
8.     private $error = '';
   
9.    
   
10.     //获取错误信息
    
11.     public function getError()
    
12.     {
    
13.         return $this->error;
    
14.     }
    
15. 
    
16.     //获取任务ID
    
17.     function submitFileTransRequest($fileLink='')
    
18.     {
    
19.         AlibabaCloud::accessKeyClient(config('apis.aliyun_key'), config('apis.aliyun_secret'))->regionId(config('apis.aliyun_region'))->asGlobalClient();
    
20. 
    
21.         $task = json_encode([
    
22.             "appkey"         => config('trans.aliyun_appkey'),
    
23.             "file_link"      => $fileLink,
    
24.             "version"        => "4.0",
    
25.             "enable_words"   => FALSE,
    
26.             "enable_sample_rate_adaptive" => TRUE
    
27.         ]);
    
28. 
    
29.         $taskId = NULL;
    
30. 
    
31.         try {
    
32.             // 提交请求，返回服务端的响应。
    
33.             $result = AlibabaCloud::nlsFiletrans()->v20180817()->submitTask()->withTask($task)->request()->toArray();
    
34.             //判断结果
    
35.             if($result['StatusText'] == 'SUCCESS'){
    
36.                 $taskId = $result['TaskId'];
    
37.             }else{
    
38.                 $this->error = $result['StatusText'].$result['StatusCode'];
    
39.             }
    
40.         } catch (ClientException $exception) {
    
41.             $this->error = $exception->getErrorMessage();
    
42.         } catch (ServerException $exception) {
    
43.             $this->error = $exception->getErrorMessage();
    
44.         }
    
45. 
    
46.         return $taskId;
    
47.     }
    
48. 
    
49.     //查询识别结果
    
50.     function getFileTransResult($taskId='')
    
51.     {
    
52.         AlibabaCloud::accessKeyClient(config('apis.aliyun_key'), config('apis.aliyun_secret'))->regionId(config('apis.aliyun_region'))->asGlobalClient();
    
53. 
    
54.         $result = NULL;
    
55. 
    
56.         while(TRUE){
    
57.             try{
    
58.                 $response = AlibabaCloud::nlsFiletrans()->v20180817()->getTaskResult()->withTaskId($taskId)->request();
    
59.                 $response = $response->toArray();
    
60.                 //转换状态
    
61.                 $statusText = $response['StatusText'];
    
62.                 if(in_array($statusText,['RUNNING','QUEUEING'])){
    
63.                     sleep(5);
    
64.                 }else{
    
65.                     //是否成功
    
66.                     if($statusText == 'SUCCESS'){
    
67.                         $result = $response['Result']['Sentences'];
    
68.                     }else{
    
69.                         $this->error = $statusText;
    
70.                     }
    
71.                     //退出轮询
    
72.                     break;
    
73.                 }
    
74.             }catch(ClientException $exception){
    
75.                 $this->error = $exception->getErrorMessage();
    
76.             }catch(ServerException $exception){
    
77.                 $this->error = $exception->getErrorMessage();
    
78.             }
    
79.         }
    
80. 
    
81.         return $result;
    
82.     }
    
83. }

复制代码