Merge branch 'asrjob' into 'master' (merge request !16)

新增语音识别任务

Author: tencentyuncos

ci_media.go

@@ -220,7 +220,7 @@ type MediaProcessJobOperation struct {
 	Tag                 string           `xml:"Tag,omitempty"`
 	Output              *JobOutput       `xml:"Output,omitempty"`
 	Transcode           *Transcode       `xml:"Transcode,omitempty"`
-	Watermark           *Watermark       `xml:"Watermark,omitempty"`
+	Watermark           []Watermark      `xml:"Watermark,omitempty"`
 	TemplateId          string           `xml:"TemplateId,omitempty"`
 	WatermarkTemplateId []string         `xml:"WatermarkTemplateId,omitempty"`
 	ConcatTemplate      *ConcatTemplate  `xml:"ConcatTemplate,omitempty"`
@@ -977,3 +977,87 @@ func (s *CIService) DescribeWorkflowExecution(ctx context.Context, runId string)
 	resp, err := s.client.send(ctx, &sendOpt)
 	return &res, resp, err
 }
+
+type SpeechRecognition struct {
+	ChannelNum      string `xml:"ChannelNum,omitempty"`
+	ConvertNumMode  string `xml:"ConvertNumMode,omitempty"`
+	EngineModelType string `xml:"EngineModelType,omitempty"`
+	FilterDirty     string `xml:"FilterDirty,omitempty"`
+	FilterModal     string `xml:"FilterModal,omitempty"`
+	ResTextFormat   string `xml:"ResTextFormat,omitempty"`
+}
+
+type SpeechRecognitionResult struct {
+	AudioTime float64  `xml:"AudioTime,omitempty"`
+	Result    []string `xml:"Result,omitempty"`
+}
+type ASRJobOperation struct {
+	Tag                     string                   `xml:"Tag,omitempty"`
+	Output                  *JobOutput               `xml:"Output,omitempty"`
+	SpeechRecognition       *SpeechRecognition       `xml:"SpeechRecognition,omitempty"`
+	SpeechRecognitionResult *SpeechRecognitionResult `xml:"SpeechRecognitionResult,omitempty"`
+}
+
+type CreateASRJobsOptions struct {
+	XMLName   xml.Name         `xml:"Request"`
+	Tag       string           `xml:"Tag,omitempty"`
+	Input     *JobInput        `xml:"Input,omitempty"`
+	Operation *ASRJobOperation `xml:"Operation,omitempty"`
+	QueueId   string           `xml:"QueueId,omitempty"`
+	CallBack  string           `xml:"CallBack,omitempty"`
+}
+
+type ASRJobDetail struct {
+	Code         string           `xml:"Code,omitempty"`
+	Message      string           `xml:"Message,omitempty"`
+	JobId        string           `xml:"JobId,omitempty"`
+	Tag          string           `xml:"Tag,omitempty"`
+	State        string           `xml:"State,omitempty"`
+	CreationTime string           `xml:"CreationTime,omitempty"`
+	QueueId      string           `xml:"QueueId,omitempty"`
+	Input        *JobInput        `xml:"Input,omitempty"`
+	Operation    *ASRJobOperation `xml:"Operation,omitempty"`
+}
+
+type CreateASRJobsResult struct {
+	XMLName    xml.Name      `xml:"Response"`
+	JobsDetail *ASRJobDetail `xml:"JobsDetail,omitempty"`
+}
+
+func (s *CIService) CreateASRJobs(ctx context.Context, opt *CreateASRJobsOptions) (*CreateASRJobsResult, *Response, error) {
+	var res CreateASRJobsResult
+	sendOpt := sendOptions{
+		baseURL: s.client.BaseURL.CIURL,
+		uri:     "/asr_jobs",
+		method:  http.MethodPost,
+		body:    opt,
+		result:  &res,
+	}
+	resp, err := s.client.send(ctx, &sendOpt)
+	return &res, resp, err
+}
+
+type DescribeMutilASRJobResult struct {
+	XMLName        xml.Name       `xml:"Response"`
+	JobsDetail     []ASRJobDetail `xml:"JobsDetail,omitempty"`
+	NonExistJobIds []string       `xml:"NonExistJobIds,omitempty"`
+}
+
+func (s *CIService) DescribeMultiASRJob(ctx context.Context, jobids []string) (*DescribeMutilASRJobResult, *Response, error) {
+	jobidsStr := ""
+	if len(jobids) < 1 {
+		return nil, nil, errors.New("empty param jobids")
+	} else {
+		jobidsStr = strings.Join(jobids, ",")
+	}
+
+	var res DescribeMutilASRJobResult
+	sendOpt := sendOptions{
+		baseURL: s.client.BaseURL.CIURL,
+		uri:     "/asr_jobs/" + jobidsStr,
+		method:  http.MethodGet,
+		result:  &res,
+	}
+	resp, err := s.client.send(ctx, &sendOpt)
+	return &res, resp, err
+}

example/CI/media_process/media_process.go

@@ -947,6 +947,72 @@ func DescribeMultiWorkflowExecution() {
 	fmt.Printf("%+v\n", describeWorkflowExecutionsRes)
 }
 
+func InvokeASRJob() {
+	u, _ := url.Parse("https://wwj-cq-1253960454.cos.ap-chongqing.myqcloud.com")
+	cu, _ := url.Parse("https://wwj-cq-1253960454.ci.ap-chongqing.myqcloud.com")
+	b := &cos.BaseURL{BucketURL: u, CIURL: cu}
+	c := cos.NewClient(b, &http.Client{
+		Transport: &cos.AuthorizationTransport{
+			SecretID:  os.Getenv("COS_SECRETID"),
+			SecretKey: os.Getenv("COS_SECRETKEY"),
+			Transport: &debug.DebugRequestTransport{
+				RequestHeader: true,
+				// Notice when put a large file and set need the request body, might happend out of memory error.
+				RequestBody:    true,
+				ResponseHeader: true,
+				ResponseBody:   true,
+			},
+		},
+	})
+	// CreateMediaJobs
+	createJobOpt := &cos.CreateASRJobsOptions{
+		Tag: "SpeechRecognition",
+		Input: &cos.JobInput{
+			Object: "abc.mp3",
+		},
+		Operation: &cos.ASRJobOperation{
+			Output: &cos.JobOutput{
+				Region: "ap-chongqing",
+				Object: "music.txt",
+				Bucket: "wwj-cq-1253960454",
+			},
+			SpeechRecognition: &cos.SpeechRecognition{
+				ChannelNum:      "1",
+				EngineModelType: "8k_zh",
+			},
+		},
+		QueueId: "p1db6a1a76ff04806b6af0d96e9bc80ab",
+	}
+	createJobRes, _, err := c.CI.CreateASRJobs(context.Background(), createJobOpt)
+	log_status(err)
+	fmt.Printf("%+v\n", createJobRes.JobsDetail)
+	DescribeJobRes, _, err := c.CI.DescribeMultiASRJob(context.Background(), []string{createJobRes.JobsDetail.JobId})
+	log_status(err)
+	fmt.Printf("%+v\n", DescribeJobRes.JobsDetail)
+}
+
+func DescribeASRJob() {
+	u, _ := url.Parse("https://wwj-cq-1253960454.cos.ap-chongqing.myqcloud.com")
+	cu, _ := url.Parse("https://wwj-cq-1253960454.ci.ap-chongqing.myqcloud.com")
+	b := &cos.BaseURL{BucketURL: u, CIURL: cu}
+	c := cos.NewClient(b, &http.Client{
+		Transport: &cos.AuthorizationTransport{
+			SecretID:  os.Getenv("COS_SECRETID"),
+			SecretKey: os.Getenv("COS_SECRETKEY"),
+			Transport: &debug.DebugRequestTransport{
+				RequestHeader: true,
+				// Notice when put a large file and set need the request body, might happend out of memory error.
+				RequestBody:    true,
+				ResponseHeader: true,
+				ResponseBody:   true,
+			},
+		},
+	})
+	DescribeJobRes, _, err := c.CI.DescribeMultiASRJob(context.Background(), []string{"sa59de0a06a4711ec9b81df13272c69a9"})
+	log_status(err)
+	fmt.Printf("%+v\n", DescribeJobRes.JobsDetail[0].Operation.SpeechRecognitionResult)
+}
+
 func main() {
 	// InvokeSnapshotJob()
 	// InvokeConcatJob()
@@ -965,5 +1031,7 @@ func main() {
 	// InvokeSuperResolutionJob()
 	// TriggerWorkflow()
 	// DescribeWorkflowExecutions()
-	DescribeMultiWorkflowExecution()
+	// DescribeMultiWorkflowExecution()
+	//InvokeASRJob()
+	DescribeASRJob()
 }