Elastic Compute Service:スポットインスタンスの中断イベントを検出して対応する

API 操作のリクエストオブジェクトの作成

リクエストオブジェクトを作成する前に、呼び出す API 操作 のパラメーターを表示します。

// リクエストオブジェクトを作成します。
DescribeInstancesRequest request = new DescribeInstancesRequest().setRegionId("cn-hangzhou");

呼び出しの開始

クライアントから API 操作を呼び出すときに、タイムアウトパラメーターやプロキシパラメーターなどの実行時パラメーターを指定できます。詳細については、「高度な設定」をご参照ください。

// 実行時パラメーターを指定します。
RuntimeOptions runtime = new RuntimeOptions();
// DescribeInstances 操作を呼び出します。
DescribeInstancesResponse response = client.describeInstancesWithOptions(request, runtime);
System.out.println(response.body.toMap());

例外の処理

ECS SDK for Java は、例外を次のタイプに分類します。

• TeaUnretryableException: ほとんどの場合、このタイプの例外はネットワークエラーが原因で発生し、最大リトライ回数に達したときに報告されます。

• TeaException: ほとんどの場合、このタイプの例外はビジネスエラーが原因で発生します。

システムの堅牢性と安定性を確保するために、例外の報告、例外のログ記録、リトライなどの操作を実行して、例外を適切に処理することをお勧めします。

例

import com.aliyun.ecs20140526.Client;
import com.aliyun.ecs20140526.models.DescribeInstancesRequest;
import com.aliyun.ecs20140526.models.DescribeInstancesResponse;
import com.aliyun.ecs20140526.models.DescribeInstancesResponseBody;
import com.aliyun.tea.TeaException;
import com.aliyun.tea.TeaUnretryableException;
import com.aliyun.teaopenapi.models.Config;
import com.aliyun.teautil.models.RuntimeOptions;
import com.alibaba.fastjson.JSONArray;

import java.util.Arrays;

public class Sample {
    private static Client createClient() throws Exception {
        Config config = new Config()
                // 必須。ALIBABA_CLOUD_ACCESS_KEY_ID 環境変数が設定されていることを確認してください。
                .setAccessKeyId(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"))
                // 必須。ALIBABA_CLOUD_ACCESS_KEY_SECRET 環境変数が設定されていることを確認してください。
                .setAccessKeySecret(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"))
                // エンドポイントを指定します。エンドポイントの詳細については、https://api.alibabacloud.com/product/Ecs をご参照ください。
                .setEndpoint("ecs.cn-hangzhou.aliyuncs.com");
        return new Client(config);
    }

    public static void main(String[] args) {
        try {
            Client client = Sample.createClient();
            // リクエストオブジェクトを作成します。
            // 1 つ以上の ECS インスタンスの ID を指定します。
            JSONArray instanceIds = new JSONArray();
            instanceIds.addAll(Arrays.asList("i-bp145cvd0exyqj****","i-bp1gehfgfrrk4lah****"));
            DescribeInstancesRequest request = new DescribeInstancesRequest()
                    .setRegionId("cn-hangzhou")
                    .setInstanceIds(instanceIds.toJSONString());
            // 実行時パラメーターを指定します。
            RuntimeOptions runtime = new RuntimeOptions();
            while (!instanceIds.isEmpty()) {
              // DescribeInstances 操作を呼び出します。
              DescribeInstancesResponse response = client.describeInstancesWithOptions(request, runtime);
              // インスタンス固有の結果を取得します。
              DescribeInstancesResponseBody responseBody = response.getBody();
              DescribeInstancesResponseBody.DescribeInstancesResponseBodyInstances instanceList = responseBody.getInstances();
              // インスタンス情報を取得し、lockReason パラメーターの値に基づいてインスタンスのステータスを判断します。
              if (instanceList != null && instanceList.getInstance()!= null && !instanceList.getInstance().isEmpty()) {
                  for (DescribeInstancesResponseBody.DescribeInstancesResponseBodyInstancesInstance instance : instanceList.getInstance()) {
                      // クエリされたインスタンスの ID とゾーン ID を表示します。
                      System.out.println("result:instance:" + instance.getInstanceId() + ",az:" + instance.getZoneId());
                      if (instance.getOperationLocks() != null ) {
                          DescribeInstancesResponseBody.DescribeInstancesResponseBodyInstancesInstanceOperationLocks operationLocks  = instance.getOperationLocks();
                          if(operationLocks.getLockReason()!=null && !operationLocks.getLockReason().isEmpty()){
                              for (DescribeInstancesResponseBody.DescribeInstancesResponseBodyInstancesInstanceOperationLocksLockReason lockReason : operationLocks.getLockReason()) {
                                  // インスタンスがロックされている場合は、インスタンス ID とインスタンスがロックされている理由を表示します。
                                  System.out.println("instance:" + instance.getInstanceId() + "-->lockReason:" + lockReason.getLockReason() + ",vmStatus:" + instance.getStatus());
                                  if ("Recycling".equals(lockReason.getLockReason())) {
                                      // 回収されるインスタンスの ID を表示します。
                                      System.out.println("spot instance will be recycled immediately, instance id:" + instance.getInstanceId());
                                      instanceIds.remove(instance.getInstanceId());
                                  }
                              }
                          }

                      }
                  }
                  // スポットインスタンスがロックされていない場合、インスタンスは 2 分ごとにクエリされます。
                  System.out.print("try describeInstances again later ...");
                  Thread.sleep(2 * 60 * 1000);
              } else {
                  break;
              }
            }
        } catch (TeaUnretryableException ue) {
            // 実際のビジネスシナリオでは例外を慎重に処理し、プロジェクトで例外を無視しないでください。この例では、例外は参考のためにのみ提供されています。
            ue.printStackTrace();
            // エラーメッセージを表示します。
            System.out.println(ue.getMessage());
            // エラー発生時にリクエストメッセージを表示し、リクエスト情報をクエリします。
            System.out.println(ue.getLastRequest());
        } catch (TeaException e) {
            // 実際のビジネスシナリオでは例外を慎重に処理し、プロジェクトで例外を無視しないでください。この例では、例外は参考のためにのみ提供されています。
            e.printStackTrace();
            // エラーコードを表示します。
            System.out.println(e.getCode());
            // リクエスト ID を含むエラーメッセージを表示します。
            System.out.println(e.getMessage());
            // サーバーから返された詳細なエラー情報を表示します。
            System.out.println(e.getData());
        } catch (Exception e) {
            // 実際のビジネスシナリオでは例外を慎重に処理し、プロジェクトで例外を無視しないでください。この例では、例外は参考のためにのみ提供されています。
            e.printStackTrace();
        }
    }
}

応答

スポットインスタンスの回収がトリガーされた場合、次の応答が返されます。

result:instance:i-bp1i9c3qiv1qs6nc****,az:cn-hangzhou-i
instance:i-bp1i9c3qiv1qs6nc****-->lockReason:Recycling,vmStatus:Stopped
spot instance will be recycled immediately, instance id:i-bp1i9c3qiv1qs6nc****

Linux ECS インスタンス

# メタデータサーバーのアクセス認証情報を取得して認証します。
TOKEN=`curl -X PUT "http://100.100.100.200/latest/api/token" -H "X-aliyun-ecs-metadata-token-ttl-seconds:<メタデータサーバーアクセス認証情報の有効期間>"`
# スポットインスタンスが中断されて回収されたかどうかをクエリします。
curl -H "X-aliyun-ecs-metadata-token: $TOKEN" http://100.100.100.200/latest/meta-data/instance/spot/termination-time

Windows ECS インスタンス

# メタデータサーバーのアクセス認証情報を取得して認証します。
$token = Invoke-RestMethod -Headers @{"X-aliyun-ecs-metadata-token-ttl-seconds" = "<メタデータサーバーアクセス認証情報の有効期間>"} -Method PUT -Uri http://100.100.100.200/latest/api/token
# スポットインスタンスが中断されて回収されたかどうかをクエリします。
Invoke-RestMethod -Headers @{"X-aliyun-ecs-metadata-token" = $token} -Method GET -Uri http://100.100.100.200/latest/meta-data/instance/spot/termination-time

ワークフロー

手順

1. プッシュチャンネルの作成

   SMQ

   1. Simple Message Queue (旧称：MNS) コンソールにログインします。

   2. 左側のナビゲーションウィンドウで、キューモデル > キュー を選択します。

   3. 上部のナビゲーションバーで、リージョンを選択します。

   4. キュー ページで、キューを作成 をクリックします。

   5. キューを作成 パネルで、次のパラメーターを設定し、OK をクリックします。

      • 名前: キューの名前。

      • メッセージの最大長さ: キューに送信されるメッセージの最大長。

      • ロングポーリング期間: ReceiveMessage 操作が呼び出された後、ロングポーリングリクエストが保持される最大期間。

      • メッセージの可視性タイムアウト時間: メッセージがキューから受信された後、メッセージが非アクティブ状態のままである期間。

      • メッセージの保持期間: メッセージがキューに存在する最大期間。指定された保持期間が経過すると、メッセージが受信されたかどうかに関係なく、メッセージは削除されます。

      • メッセージ遅延時間: キューに送信されたすべてのメッセージが消費されるまでの期間。

      • ログ機能の有効化: ロギング機能を有効にするかどうかを指定します。

      キューが作成されると、キュー ページに表示されます。

   Webhook

   重要

   Webhook サービスは、インターネットにアクセスできるサーバーにデプロイする必要があります。サーバーの Webhook ポートが、対応するセキュリティグループとファイアウォールで開いていることを確認してください。

   Java のサンプルコード:

   import org.springframework.http.ResponseEntity;
   import org.springframework.web.bind.annotation.PostMapping;
   import org.springframework.web.bind.annotation.RequestBody;
   import org.springframework.web.bind.annotation.RestController;
   
   @RestController
   public class WebhookController {
       @PostMapping("/callback")
       public ResponseEntity<String> receiveWebhook(@RequestBody String payload) {
           // ペイロードを処理します (ロギングやビジネスロジックの実行など)。
           System.out.println("Received webhook payload: " + payload);
           // 成功応答を返します。
           return ResponseEntity.ok("Webhook received");
       }
   }

2. サブスクリプションポリシーの作成

   1. CloudMonitor コンソールにログインします。

   2. 左側のナビゲーションウィンドウで、[イベントセンター] > [イベントサブスクリプション] を選択します。

   3. [サブスクリプションポリシー] タブで、[サブスクリプションポリシーの作成] をクリックします。

   4. [サブスクリプションポリシーの作成] ページで、パラメーターを設定します。

      スポットインスタンスの中断イベントをサブスクライブするために必要な次のパラメーターに注意してください。他のパラメーターの詳細については、「イベントサブスクリプションの管理 (推奨)」をご参照ください。

      • 基本情報: サブスクリプションポリシーの名前と説明を入力します。

      • アラームサブスクリプション:

        • サブスクリプションタイプ: [システムイベント] を選択します。

        • サブスクリプション範囲:

        • 製品: Elastic Compute Service (ECS) を選択します。

        • イベントタイプ：[ステータス通知] を選択します。

        • イベント名: [Instance:PreemptibleInstanceInterruption] を選択します。

        • イベントレベル: [警告 (Warning)] を選択します。

        • アプリケーショングループ、イベント内容、および イベントリソース: パラメーターを空のままにします。これは、現在のアカウントに属するすべてのアプリケーショングループ内のすべての ECS インスタンスの [Instance:PreemptibleInstanceInterruption] システムイベントをサブスクライブすることを示します。

      • 複合ノイズリダクション: デフォルト設定を使用します。

      • 通知: [カスタム通知方法] パラメーターには、デフォルト設定を使用します。

      • プッシュと統合: [チャンネルの追加] をクリックします。表示されるダイアログボックスで、[チャンネルの増加] をクリックします。[プッシュチャンネルの作成] パネルで、[ターゲットタイプ] パラメーターをステップ 1 で作成したプッシュチャンネルに設定します。次に、画面の指示に従って他のパラメーターを設定します。プッシュチャンネルの詳細については、「プッシュチャンネルの管理」をご参照ください。

3. スポットインスタンス中断イベントのシミュレーション

   スポットインスタンスの中断イベントはトリガーイベントです。スポットインスタンスの中断イベントハンドラを開発するとき、コードをデバッグすることはできません。CloudMonitor の [イベントサブスクリプションのデバッグ] 機能を使用して、スポットインスタンスの中断イベントをシミュレートできます。

   1. [サブスクリプションポリシー] タブで、[イベントサブスクリプションのデバッグ] をクリックします。

   2. [イベントデバッグの作成] パネルで、[プロダクト] パラメーターを [Elastic Compute Service (ECS)] に、[名前] パラメーターを [Instance:PreemptibleInstanceInterruption] に設定します。

      CloudMonitor は、JSON 形式でデバッグコンテンツを自動的に生成します。デバッグコンテンツ内のリソース情報を、中断イベントをシミュレートするスポットインスタンスの情報に置き換えます。

      • <Alibaba Cloud アカウント ID> 変数を Alibaba Cloud アカウントの ID に置き換えます。

      • <リソース ID> と <インスタンス ID> 変数をスポットインスタンスの ID に置き換えます。

      • <リージョン ID> 変数をスポットインスタンスのリージョン ID に置き換えます。

        {
            "product": "ECS",
            "resourceId": "acs:ecs:cn-shanghai:<Alibaba Cloud アカウント ID>UID:instance/<リソース ID>",
            "level": "WARN",
            "instanceName": "instanceName",
            "regionId": "<リージョン ID>",
            "groupId": "0",
            "name": "Instance:PreemptibleInstanceInterruption",
            "content": {
                "instanceId": "i-2zeg014dfo4y892z***",
                "instanceName": "wor***b73",
                "action": "delete"
            },
            "status": "Normal"
        }

   3. [OK] をクリックします。

      [操作は成功しました] メッセージが表示されます。CloudMonitor は、サブスクリプションポリシーで指定された通知方法に基づいて、テストアラート通知を自動的に送信します。

4. スポットインスタンス中断イベントのアラート通知の受信と表示

   SMQ

   1. SMQ コンソールにログインします。左側のナビゲーションウィンドウで、[キューモデル] > [キュー] を選択します。

   2. 上部のナビゲーションバーで、リージョンを選択します。キュー ページで、管理するキューを見つけ、[操作] 列の メッセージの送受信 をクリックします。

   3. (オプション) [クイックエクスペリエンス] ページの [メッセージの受信] セクションで、受信メッセージパラメータの編集 をクリックします。受信メッセージパラメータの編集 パネルで、一回に取得できる最大メッセージ数 と ポーリング期間 パラメーターを設定し、[OK] をクリックします。

   4. [クイックエクスペリエンス] ページで、メッセージを受信 をクリックします。メッセージのリストが [メッセージの受信] セクションに表示されます。

   5. (オプション) メッセージリストでメッセージを見つけ、[操作] 列の 詳細情報 をクリックします。[メッセージ詳細] ダイアログボックスで、メッセージ内容などのメッセージに関する情報を表示します。

   Webhook

   Webhook サービスの呼び出しログと、サービスにプッシュされたアラート通知を表示します。