：管道管理

可以直接通過 SearchPipeline介面搜尋管道資訊。

String region = "<region>";
    String accessKeyId = "<accessKeyId>";
    String accessKeySecret = "<accessKeySecret>";
    DefaultProfile profile = DefaultProfile.getProfile(region, accessKeyId, accessKeySecret);
    DefaultAcsClient client = new DefaultAcsClient(profile);
    SearchPipelineRequest request = new SearchPipelineRequest();
    // 如果出錯，可能會拋出ClientException或ServerException異常
    SearchPipelineResponse response = client.getAcsResponse(request);
    List<SearchPipelineResponse.Pipeline> pipelines = response.getPipelineList();
    for (SearchPipelineResponse.Pipeline pipeline : pipelines) {
        System.out.println("pipeline id:" + pipeline.getId() + ", name:" + pipeline.getName() + ", state:" + pipeline.getState());
    }

如果已經知道pipelineId，可以通過pipelineId調用 QueryPipelineList介面查詢管道資訊。

String region = "<region>";
    String accessKeyId = "<accessKeyId>";
    String accessKeySecret = "<accessKeySecret>";
    // 已知的管道ID，多個管道用','分隔
    String pipelineIds = "<pipelineIds>";
    DefaultProfile profile = DefaultProfile.getProfile(region, accessKeyId, accessKeySecret);
    DefaultAcsClient client = new DefaultAcsClient(profile);
    QueryPipelineListRequest request = new QueryPipelineListRequest();
    request.setPipelineIds(pipelineId);
    // 如果出錯，可能會拋出ClientException或ServerException異常
    QueryPipelineListResponse response = client.getAcsResponse(request);
    List<QueryPipelineListResponse.Pipeline> pipelines = response.getPipelineList();
    for (QueryPipelineListResponse.Pipeline pipeline : pipelines) {
        System.out.println("pipeline id:" + pipeline.getId() + ", name:" + pipeline.getName() + ", state:" + pipeline.getState());
    }

通過 UpdatePipeline更新管道資訊，包括更新管道名稱，狀態。管道的狀態包括Active、Paused。

String region = "<region>";
    String accessKeyId = "<accessKeyId>";
    String accessKeySecret = "<accessKeySecret>";
    DefaultProfile profile = DefaultProfile.getProfile(region, accessKeyId, accessKeySecret);
    DefaultAcsClient client = new DefaultAcsClient(profile);
    // 檢索使用者管道，預設只有一個。
    SearchPipelineRequest searchPipelineRequest = new SearchPipelineRequest();
    // 如果出錯，可能會拋出ClientException或ServerException異常
    SearchPipelineResponse searchPipelineResponse = client.getAcsResponse(searchPipelineRequest);
    List<SearchPipelineResponse.Pipeline> pipelines = searchPipelineResponse.getPipelineList();
    SearchPipelineResponse.Pipeline queryPipeline = pipelines.get(0);
    // 更新管道狀態
    UpdatePipelineRequest request = new UpdatePipelineRequest();
    request.setPipelineId(queryPipeline.getId());
    request.setState("Paused");
    request.setName(queryPipeline.getName());
    // 如果出錯，會拋ClientException異常
    UpdatePipelineResponse response = client.getAcsResponse(request);
    UpdatePipelineResponse.Pipeline pipeline = response.getPipeline();
    System.out.println("pipeline id:" + pipeline.getId() + ", name:" + pipeline.getName() + ", state:" + pipeline.getState());