MPS サービスを開始すると、システムは自動的に MPS キューを作成します。 インターフェイスを使用して、MPS キューを管理することもできます (パイプライン)。 たとえば、SearchPipeline、QueryPipelineList、UpdatePipeline などがあります。

MPS キューの検索

SearchPipeline インターフェイスを使用して、MPS キュー情報を検索します。
$region = '<region>';
    $accessKeyId = '<accessKeyId>';
    $accessKeySecret = '<accessKeySecret>';
    $profile = DefaultProfile::getProfile($region, $accessKeyId, $accessKeySecret);
    $client = new DefaultAcsClient($profile);
    $request = new Mts\SearchPipelineRequest();
    // If an error occurs, it can throw ClientException or 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";
    }

MPS キューの照会

pipelineId がある場合は、pipelineId を使用して QueryPipelineList インターフェイスを呼び出し、MPS キュー 情報を照会します。
$region = '<region>';
    $accessKeyId = '<accessKeyId>';
    $accessKeySecret = '<accessKeySecret>';
    // The known pipeline ID, separated by comma (,)
    $pipelineIds = '<pipelineIds>';
    $profile = DefaultProfile::getProfile($region, $accessKeyId, $accessKeySecret);
    $client = new DefaultAcsClient($profile);
    $request = new Mts\QueryPipelineListRequest();
    $request->setPipelineIds($pipelineIds);
    // If an error occurs, it can throw ClientException or 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";
    }

MPS キューの更新

UpdatePipeline インターフェイスを使用して、MPS キューの名前とステータスを含む、MPS キュー情報を更新します。 ステータスには "有効" と "一時停止" があります。
$region = '<region>';
    $accessKeyId = '<accessKeyId>';
    $accessKeySecret = '<accessKeySecret>';
    $profile = DefaultProfile::getProfile($region, $accessKeyId, $accessKeySecret);
    $client = new DefaultAcsClient($profile);
    $request = new Mts\SearchPipelineRequest();
    // If an error occurs, it can throw ClientException or 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";