在開通服務時，系統會自動建立一個使用者管道。您還可以通過一系列介面管理管道（pipeline）。例如：SearchPipeline、QueryPipelineList、UpdatePipeline。

搜尋管道

可以直接通過 SearchPipeline介面搜尋管道資訊。 
$region = '<region>';
    $accessKeyId = '<accessKeyId>';
    $accessKeySecret = '<accessKeySecret>';
    $profile = DefaultProfile::getProfile($region, $accessKeyId, $accessKeySecret);
    $client = new DefaultAcsClient($profile);
    $request = new Mts\SearchPipelineRequest();
    // 如果出錯，可能會拋出ClientException或ServerException異常
    $response = $client->getAcsResponse($request);
    $pipelines = $response->PipelineList->Pipeline;
    foreach ($pipelines as $pipeline) {
        echo 'pipeline id:' . $pipeline->Id . ', name:' . $pipeline->Name . ', state:' . $pipeline->State . "\n";
    }

查詢管道

如果已經知道pipelineId，可以通過pipelineId調用 QueryPipelineList介面查詢管道資訊。 
$region = '<region>';
    $accessKeyId = '<accessKeyId>';
    $accessKeySecret = '<accessKeySecret>';
    // 已知的管道ID，多個管道用','分隔
    $pipelineIds = '<pipelineIds>';
    $profile = DefaultProfile::getProfile($region, $accessKeyId, $accessKeySecret);
    $client = new DefaultAcsClient($profile);
    $request = new Mts\QueryPipelineListRequest();
    $request->setPipelineIds($pipelineIds);
    // 如果出錯，可能會拋出ClientException或ServerException異常
    $response = $client->getAcsResponse($request);
    $pipelines = $response->PipelineList->Pipeline;
    foreach ($pipelines as $pipeline) {
        echo 'pipeline id:' . $pipeline->Id . ', name:' . $pipeline->Name . ', state:' . $pipeline->State . "\n";
    }

更新管道

通過 UpdatePipeline更新管道資訊，包括更新管道名稱，狀態。管道的狀態包括Active、Paused。 
$region = '<region>';
    $accessKeyId = '<accessKeyId>';
    $accessKeySecret = '<accessKeySecret>';
    $profile = DefaultProfile::getProfile($region, $accessKeyId, $accessKeySecret);
    $client = new DefaultAcsClient($profile);
    $request = new Mts\SearchPipelineRequest();
    // 如果出錯，可能會拋出ClientException或ServerException異常
    $response = $client->getAcsResponse($request);
    $pipelines = $response->PipelineList->Pipeline;
    $pipeline = $pipelines[0];
    $request = new Mts\UpdatePipelineRequest();
    $request->setPipelineId($pipeline->Id);
    $request->setName($pipeline->Name);
    $request->setState($pipeline->State == 'Paused' ? 'Active' : 'Paused');
    $response = $client->getAcsResponse($request);
    $pipeline = $response->Pipeline;
    echo 'pipeline id:' . $pipeline->Id . ', name:' . $pipeline->Name . ', state:' . $pipeline->State . "\n";