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";