Elastic Compute Service:プリエンプティブインスタンスの中断イベントの検出と対応

インターフェースのリクエストオブジェクトを作成する

リクエストオブジェクトを作成する前に、API ドキュメント を参照してパラメータ情報を取得してください。

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

呼び出しを開始する

クライアントを介して OpenAPI を呼び出す場合、タイムアウト構成やプロキシ構成などのランタイムパラメータを設定できます。詳細については、「詳細設定」をご参照ください。

// ランタイムパラメータを指定する
RuntimeOptions runtime = new RuntimeOptions();
// DescribeInstances インターフェースを呼び出す
DescribeInstancesResponse response = client.describeInstancesWithOptions(request, runtime);
System.out.println(response.body.toMap());

例外処理

Java SDK は、例外を TeaUnretryableException と TeaException に分類します。

• TeaUnretryableException: このタイプの例外は、ネットワークの問題が原因で発生します。再試行回数が上限に達すると、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.aliyun.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 とゾーン情報を表示します。
                      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("スポットインスタンスはすぐにリサイクルされます。インスタンス ID:" + instance.getInstanceId());
                                      instanceIds.remove(instance.getInstanceId());
                                  }
                              }
                          }

                      }
                  }
                  // プリエンプティブルインスタンスがロックされていない場合は、2 分ごとにクエリされます。
                  System.out.print("後で DescribeInstances を再試行します...");
                  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
スポットインスタンスはすぐにリサイクルされます。インスタンス ID:i-bp1i9c3qiv1qs6nc****

Linux インスタンス

# 認証のためにメタデータサーバーのアクセス認証情報を取得する
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 インスタンス

# 認証のためにメタデータサーバーのアクセス認証情報を取得する
$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. 受信チャネルを準備する

   Function Compute

   1. Function Compute コンソール にログインします。左側のナビゲーションウィンドウで、[関数] をクリックします。

   2. 上部のナビゲーションバーで、リージョンを選択します。[サービス] ページで、目的のサービスをクリックします。

   3. [関数] ページで、[関数の作成] をクリックします。

   4. [関数の作成] ページで、関数を作成する方法を選択し、次のパラメータを設定して、[作成] をクリックします。

      説明

      この例では、組み込みランタイムの使用 と カスタムランタイムの使用 が使用されています。Function Compute が提供するランタイムがビジネス要件を満たせない場合は、コンテナーイメージの使用 を選択して関数を 作成 できます。詳細については、「カスタムコンテナ関数の作成」をご参照ください。

      • [基本設定]: [関数名] や [ハンドラタイプ] など、関数の基本情報を設定します。[ハンドラタイプ] は、次のいずれかの値に設定できます。

        • [イベントハンドラ]: タイマーの使用、API オペレーションの呼び出し、SDK の使用、または他の Alibaba Cloud サービスと統合されたトリガーを使用して関数をトリガーします。

        • [HTTP ハンドラ]: HTTP リクエストまたは WebSocket リクエストによって関数の実行をトリガーします。Web シナリオでは、カスタムランタイムの使用 を選択することをお勧めします。

      • [コード] セクションで、関数のランタイムとコード関連の情報を設定します。

        パラメータ	説明	例
        [ランタイム]	Function ComputePython、Java、PHP、Node.js などのプログラミング言語を選択します。Function Compute でサポートされているランタイムの詳細については、「Function Compute でサポートされているランタイム」をご参照ください。	Node.js 14
        [コードのアップロード方法]	Function Compute に機能コードをアップロードする方法を選択します。 [サンプルコードを使用]: Function Compute が提供するサンプルコードを選択して、ビジネス要件に基づいて関数を作成します。これはデフォルトのメソッドです。 [ZIP をアップロード]: コードを含む ZIP パッケージを選択してアップロードします。 [JAR をアップロード]: 関数コードを含む JAR ファイルを選択してアップロードします。 [フォルダをアップロード]: 関数コードを含むフォルダを選択してアップロードします。 [OSS]: 関数コードの [バケット名] パラメータと [オブジェクト名] パラメータを指定します。 説明 [コードのアップロード方法] を [サンプルコードを使用] に設定した場合、[ハンドラ] を変更する必要はありません。別のコードアップロード方法を選択した場合は、ビジネス要件に基づいて [ハンドラ] を変更する必要があります。そうしないと、関数の実行時にエラーが報告されます。 [ランタイム] を [Java 8] または [Java 11] に設定した場合、[サンプルコードを使用]、[JAR をアップロード]、または [OSS] のみを選択して関数コードをアップロードできます。他のランタイムの場合は、[サンプルコードを使用]、[ZIP をアップロード]、[フォルダをアップロード]、または [OSS] を選択できます。	サンプルコードを使用
        [起動コマンド]	説明 このパラメータは、カスタムランタイムの使用 を選択して関数を作成する場合にのみ設定する必要があります。 プログラムの起動コマンドを設定します。起動コマンドを設定しない場合は、コードのルートディレクトリに bootstrap という名前の起動スクリプトを手動で作成する必要があります。bootstrap スクリプトは、プログラムを起動するために使用されます。	npm run start
        [リスニングポート]	説明 このパラメータは、カスタムランタイムの使用 を選択して関数を作成する場合にのみ設定する必要があります。 コード内の HTTP サーバーがリスニングするポートを指定します。	9000

      • [詳細設定]: インスタンス情報と関数の実行タイムアウト期間を設定します。

        パラメータ	説明	例
        [仕様]	ビジネス要件に基づいて、[vCPU 容量] と [メモリ容量] を設定します。リソースの課金については、「課金の概要」をご参照ください。 説明 vCPU 容量とメモリ容量 (GB) の比率は 1:1 から 1:4 の範囲で設定する必要があります。	0.35 vCPU、512 MB
        [一時ディスクのサイズ]	ビジネス要件に基づいて、ファイルを一時的に保存するために使用するハードディスクのサイズを指定します。 有効な値: 512 MB（デフォルト）: このサイズのテンポラリ ディスクの使用は課金されません。Function Compute は 512 MB の無料ディスク容量を提供します。 10 GB: 9.5 GB のディスクサイズに基づいて課金されます。 説明 データは一時ハードディスクのすべてのディレクトリに書き込むことができます。ディレクトリは一時ハードディスクのスペースを共有します。 一時ハードディスクのライフサイクルは、基盤となるインスタンスのライフサイクルと一致します。インスタンスがシステムによってリサイクルされると、ハードディスク上のデータはクリアされます。保存されたデータを永続化するには、NAS ファイルシステムまたは Object Storage Service (OSS) を使用できます。詳細については、「NAS ファイルシステムを設定する」および「OSS ファイルシステムを設定する」をご参照ください。	512 MB
        [インスタンスの同時実行性]	インスタンスの同時実行性を指定します。詳細については、「インスタンスの同時実行性を設定する」をご参照ください。	10
        [実行タイムアウト期間]	関数の実行のタイムアウト期間を指定します。[実行タイムアウト期間] のデフォルト値は 60 秒で、最大値は 86,400 秒です。	60
        [ハンドラ]	関数のハンドラを指定します。Function Compute ランタイムは、ハンドラをロードして呼び出し、リクエストを処理します。 カスタムランタイムの使用 または [コンテナイメージを使用] を選択した場合は、このパラメーターは必須ではありません。 説明 [コードのアップロード方法] を [サンプルコードを使用] に設定した場合、[ハンドラ] を変更する必要はありません。別のコードアップロード方法を選択した場合は、ビジネス要件に基づいて [ハンドラ] を変更する必要があります。そうしないと、関数の実行時にエラーが報告されます。	index.handler
        [タイムゾーン]	関数のタイムゾーンを指定します。関数のタイムゾーンを設定すると、環境変数 [TZ] が関数に自動的に追加されます。値は設定したタイムゾーンです。	UTC

      • [環境変数]: 関数のランタイムの環境変数を設定します。詳細については、「環境変数」をご参照ください。

      • [トリガー設定] セクションで、ビジネス要件に基づいて関数のトリガーを設定します。トリガーを使用して関数をトリガーできます。詳細については、「トリガーを管理する」をご参照ください。

   Simple Message Queue

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

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

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

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

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

      • 名前: キューの名前。

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

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

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

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

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

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

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

   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) { // Webhook ペイロードを受信する
           // ペイロードを処理する（例：ロギングまたはビジネスロジック処理）
           System.out.println("Received webhook payload: " + payload);
           // 成功レスポンスを返す
           return ResponseEntity.ok("Webhook received");
       }
   }

2. サブスクリプションポリシーを作成する

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

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

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

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

      この例では、プリエンプティブルインスタンスの割り込みイベントのサブスクライブに関連するパラメータのみを説明します。その他のパラメータの説明については、「<イベントサブスクリプションの管理 (推奨)」をご参照ください。

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

      • [アラートサブスクリプション]:

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

        • [サブスクリプションスコープ]:

        • [プロダクト]: [elastic Compute Service (ECS)] を選択します。

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

        • [イベント名]: [プリエンプティブルインスタンスの割り込み通知] を選択します。

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

        • [アプリケーショングループ]、[イベントコンテンツ]、および [イベントリソース]: これらのパラメータは設定しません。これは、このアカウント内のすべてのアプリケーショングループのすべての ECS インスタンスのすべてのシステムイベントが [プリエンプティブルインスタンスの割り込み通知] をサブスクライブしていることを示します。

      • [マージとノイズリダクション]: デフォルト値を使用します。

      • [通知]: [カスタム通知方法] のデフォルトの通知方法を使用します。

      • [プッシュと統合]: [チャネルを追加] をクリックします。ポップアップウィンドウで、[チャネルを追加] をクリックします。[ターゲットタイプ] に手順 1 で準備したチャネルを選択します。指示に従って他のパラメータを入力します。プッシュチャネルの詳細については、「プッシュチャネルの管理」をご参照ください。

3. 割り込みイベントをシミュレートする

   プリエンプティブルインスタンスの割り込みイベントは、パッシブにトリガーされるイベントです。プリエンプティブルインスタンスの割り込みイベントハンドラを開発する場合、コードを効果的にデバッグすることはできません。[イベントサブスクリプションのデバッグ] を使用して、プリエンプティブルインスタンスの割り込みイベントをシミュレートできます。

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

   2. [イベントデバッグの作成] パネルで、[プロダクト] を [elastic Compute Service (ECS)] として選択し、[名前] を [プリエンプティブルインスタンスの割り込み通知] として選択します。

      システムは JSON 形式でデバッグコンテンツを自動的に生成します。JSON ファイルのリソース関連情報を、割り込みイベントをシミュレートするプリエンプティブルインスタンスの情報に置き換える必要があります。

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

      • <resource-id> 変数と <instanceId> 変数をスポットインスタンスの ID に置き換えます。

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

        { // デバッグコンテンツの例
            "product": "ECS", // プロダクト名。変更しないでください。
            "resourceId": "acs:ecs:cn-shanghai:Alibaba Cloud アカウント UID:instance/<resource-id>", // リソース ID。<resource-id> を実際の値に置き換えてください。
            "level": "WARN", // イベントレベル。変更しないでください。
            "instanceName": "instanceName", // インスタンス名
            "regionId": "<region ID>", // リージョン ID。<region ID> を実際の値に置き換えてください。
            "groupId": "0", // アプリケーショングループ ID
            "name": "Instance:PreemptibleInstanceInterruption", // イベント名。変更しないでください。
            "content": { // イベントコンテンツ
                "instanceId": "i-2zeg014dfo4y892z***", // インスタンス ID。<instanceId> を実際の値に置き換えてください。
                "instanceName": "wor***b73", // インスタンス名
                "action": "delete" // アクション。変更しないでください。
            },
            "status": "Normal" // ステータス
        }

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

      システムに [操作は成功しました] メッセージが表示されます。その後、CloudMonitor はサブスクリプションポリシーで指定された通知方法に従って、アラームテスト通知を自動的に発行します。

4. 受信と表示

   Function Compute

   1. Function Compute コンソール にログインします。左側のナビゲーションウィンドウで、[サービスと関数] をクリックします。

   2. トップメニューバーで、リージョンを選択します。[サービスリスト] ページで、[アクション] 列のターゲットサービスをクリックし、[関数管理] をクリックします。

   3. [関数管理] ページで、ターゲットの関数名をクリックします。関数の詳細ページで、[呼び出しログ] タブをクリックします。

   Simple Message Queue

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

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

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

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

   5. オプション:メッセージリストで、ターゲットメッセージを見つけます。[アクション] 列で、詳細情報 をクリックします。[メッセージの詳細] ダイアログボックスで、メッセージの内容やその他の情報を表示します。

   Webhook

   Webhook がデプロイされているプログラムで、呼び出しステータスと通知コンテンツを表示します。