Pipeline队列

更新时间：2022-01-10

队列分为免费型与专享型：

免费型队列中的转码任务分享百度智能云为音视频转码所提供的约400路720P转码计算资源。
专享型队列需额外采购，以便更好的满足那些对于转码时效性和稳定性有更高要求的用户的业务需求。

用户可以利用队列实现任务优先级。用户通过创建多个队列达到区分任务优先级的目的，将大部分任务创建至普通优先级队列，将高优的任务放入高优先级的队列，以利用队列先到先服务的工作原理来实现任务的优先级调整。

新建Pipeline

如下代码可以新建一个Pipeline，默认的capacity值为20：

                Java
                
            

                public void createPipeline (MediaClient client, String pipelineName,
       String sourceBucket, String targetBucket, int capacity) {
    // 新建一个Pipeline
    client.createPipeline(pipelineName, sourceBucket, targetBucket, capacity);
}
            

列出全部Pipeline

如下代码可以列出用户所有的Pipeline：

                Java
                
            

                public void listPipelines (MediaClient client) {
    // 获取用户的Pipeline列表
    List<PipelineStatus> list = client.listPipelines().getPipelines();

    // 遍历Pipeline列表
    for (PipelineStatus pipeline : list) {
        System.out.println(pipeline);
    }
}
            

查询指定的Pipeline

若只是查询某个Pipeline，则使用如下代码：

                Java
                
                public void getPipeline (MediaClient client, String pipelineName) {
    GetPipelineResponse pipeline = client.getPipeline(pipelineName);
    System.out.println(pipeline);
}

删除Pipeline

如下代码可以删除一个Pipeline：

                Java
                
                public void deletePipeline (MediaClient client, String pipelineName) {
    // 删除Pipeline
    client.deletePipeline(pipelineName);
}

需要注意的是，如果Pipeline有关联的Job未完成，则Pipeline无法被删除，必须等Job执行结束后才能成功删除。

更新指定的Pipeline

更新指定pipeline的capacity：

                Java
                
            

                public void updatePipeline (MediaClient client, String pipelineName, Integer capacity) {
    PipelineStatus pipeline = client.getPipeline(pipelineName).getPipeline();
    pipeline.getConfig().setCapacity(capacity);
    client.updatePipeline(new UpdatePipelineRequest().withPipeline(pipeline));
}
            

更新其他字段类似写法

MediaClient

Transcoding-Job转码任务

百度智能云

音视频处理 MCP