Pipeline队列
更新时间：2025-08-04
队列分为免费型与专享型：
- 免费型队列中的转码任务分享百度智能云为音视频转码所提供的约400路720P转码计算资源。
- 专享型队列需额外采购，以便更好的满足那些对于转码时效性和稳定性有更高要求的用户的业务需求。
用户可以利用队列实现任务优先级。用户通过创建多个队列达到区分任务优先级的目的，将大部分任务创建至普通优先级队列，将高优的任务放入高优先级的队列，以利用队列先到先服务的工作原理来实现任务的优先级调整。
新建Pipeline
如下代码可以新建一个Pipeline。
Go
1pipelineName := "test"
2sourceBucket := "testBucket"
3targetBucket := "targetBucket"
4capacity := 10
5err := MEDIA_CLIENT.CreatePipeline(pipelineName, sourceBucket, targetBucket, capacity)
6if err != nil {
7 fmt.Printf("create Pipeline error: %+v\n", err)
8 return
9}
10fmt.Println("create pipeline success")列出全部pipeline
如下代码可以列出用户所有的pipeline
Go
1pipelines, err := MEDIA_CLIENT.ListPipelines()
2if err != nil {
3 fmt.Printf("list Pipeline error: %+v\n", err)
4 return
5}
6fmt.Println("list pipeline success\n")
7for _, pipeline := range pipelines.Pipelines {
8 fmt.Printf("pipeline: %+v\n", pipeline)
9}查询指定pipeline
如下代码可以按照pipelineName查询pipeline。
Go
1pipelineName := "test"
2pipeline, err := MEDIA_CLIENT.GetPipeline(pipelineName)
3if err != nil {
4 fmt.Printf("list Pipeline error: %+v\n", err)
5 return
6}
7fmt.Println("get pipeline success")
8fmt.Printf("pipeline: %+v\n", pipeline)删除pipeline
如下代码可以按照pipelineName删除pipeline。
Go
1pipelineName := "test"
2err := MEDIA_CLIENT.DeletePipeline(pipelineName)
3if err != nil {
4 fmt.Printf("delete Pipeline error: %+v\n", err)
5 return
6}
7fmt.Println("delete pipeline success")需要注意的是，如果Pipeline有关联的Job未完成，则Pipeline无法被删除，必须等Job执行结束后才能成功删除。
更新指定的Pipeline
如下代码可以对指定的pipeline进行更新。
Go
1pipelineName := "test"
2args, _ := MEDIA_CLIENT.GetPipelineUpdate(pipelineName)
3args.Description = "update"
4args.TargetBucket = "vwdemo"
5args.SourceBucket = "vwdemo"
6
7config := &api.UpdatePipelineConfig{}
8config.Capacity = 2
9config.Notification = "zz"
10args.UpdatePipelineConfig = config
11err := MEDIA_CLIENT.UpdatePipeline(pipelineName, args)
12if err != nil {
13 fmt.Printf("update Pipeline error: %+v\n", err)
14 return
15}
16fmt.Println("update pipeline success")