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

前提条件

開始する前に、以下の条件を満たしていることを確認してください。

• AccessKey ペアを持つ Resource Access Management (RAM) ユーザー。手順については、「AccessKey ペアの作成」をご参照ください。

• RAM ユーザーに AliyunECSFullAccess ポリシーがアタッチされていること。

• AccessKey ペアが環境変数 ALIBABA_CLOUD_ACCESS_KEY_ID および ALIBABA_CLOUD_ACCESS_KEY_SECRET に設定されていること。手順については、「Linux、macOS、Windows における環境変数の設定」をご参照ください。

• Java 向け ECS SDK がインストール済みであること。以下の Maven 依存関係を追加してください。

  <dependencies>
      <dependency>
          <groupId>com.aliyun</groupId>
          <artifactId>ecs20140526</artifactId>
          <version>5.3.0</version>
      </dependency>
  </dependencies>

  その他のインストール方法については、「Java 向け ECS SDK のインストール」をご参照ください。

サンプル

以下のサンプルでは、スポットインスタンスのリストを 2 分ごとにポーリングし、「再利用予定」状態になったインスタンスをログ出力します。すべてのサンプルは環境変数から認証情報を読み取ります。

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"))
                // 対象リージョンのエンドポイントを指定します。
                .setEndpoint("ecs.cn-hangzhou.aliyuncs.com");
        return new Client(config);
    }

    public static void main(String[] args) {
        try {
            Client client = Sample.createClient();

            // 監視対象のスポットインスタンス 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();

                if (instanceList != null && instanceList.getInstance() != null && !instanceList.getInstance().isEmpty()) {
                    for (DescribeInstancesResponseBody.DescribeInstancesResponseBodyInstancesInstance instance : instanceList.getInstance()) {
                        System.out.println("インスタンス: " + instance.getInstanceId() + ", ゾーン: " + instance.getZoneId());

                        if (instance.getOperationLocks() != null) {
                            DescribeInstancesResponseBody.DescribeInstancesResponseBodyInstancesInstanceOperationLocks operationLocks = instance.getOperationLocks();
                            if (operationLocks.getLockReason() != null && !operationLocks.getLockReason().isEmpty()) {
                                for (DescribeInstancesResponseBody.DescribeInstancesResponseBodyInstancesInstanceOperationLocksLockReason lockReason : operationLocks.getLockReason()) {
                                    System.out.println("インスタンス " + instance.getInstanceId() + " のロック理由: " + lockReason.getLockReason() + ", ステータス: " + instance.getStatus());
                                    if ("Recycling".equals(lockReason.getLockReason())) {
                                        // インスタンスは「再利用予定」状態です — グレースフルシャットダウン処理をここに実装します。
                                        System.out.println("スポットインスタンスが再利用されます: " + instance.getInstanceId());
                                        instanceIds.remove(instance.getInstanceId());
                                    }
                                }
                            }
                        }
                    }
                    // 2 分後に再度ポーリングします。
                    System.out.println("2 分後に再度確認します...");
                    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());
            System.out.println(e.getMessage());
            System.out.println(e.getData());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

再利用がトリガーされた際の出力例は以下の通りです。

インスタンス: i-bp1i9c3qiv1qs6nc****, ゾーン: cn-hangzhou-i
インスタンス i-bp1i9c3qiv1qs6nc**** のロック理由: Recycling, ステータス: Stopped
スポットインスタンスが再利用されます: i-bp1i9c3qiv1qs6nc****

SDK の例外タイプ（ネットワークエラーの場合は TeaUnretryableException、業務エラーの場合は TeaException）および高度なランタイムオプションの詳細については、「アクセス認証情報の管理」をご参照ください。

前提条件

開始する前に、以下の条件を満たしていることを確認してください。

• AccessKey ペアを持つ RAM ユーザー。手順については、「AccessKey ペアの作成」をご参照ください。

• RAM ユーザーに AliyunCloudMonitorFullAccess ポリシーがアタッチされていること。

• AccessKey ペアが環境変数 ALIBABA_CLOUD_ACCESS_KEY_ID および ALIBABA_CLOUD_ACCESS_KEY_SECRET に設定されていること。手順については、「Linux、macOS、Windows における環境変数の設定」をご参照ください。

• Java 向け CloudMonitor SDK がインストール済みであること。以下の Maven 依存関係を追加してください。

  <dependencies>
      <dependency>
          <groupId>com.aliyun</groupId>
          <artifactId>cms20190101</artifactId>
          <version>8.1.3</version>
      </dependency>
  </dependencies>

  その他のインストール方法については、「Java 向け CloudMonitor SDK のインストール」をご参照ください。

サンプル

以下のサンプルでは、CloudMonitor から Instance:PreemptibleInstanceInterruption イベントをクエリします。

import com.aliyun.cms20190101.Client;
import com.aliyun.teaopenapi.models.Config;
import com.aliyun.cms20190101.models.DescribeSystemEventAttributeRequest;
import com.aliyun.cms20190101.models.DescribeSystemEventAttributeResponse;
import com.aliyun.tea.TeaException;
import com.aliyun.tea.TeaUnretryableException;
import com.aliyun.teautil.models.RuntimeOptions;

public class Sample {
    // 環境変数から認証情報を使用して CloudMonitor クライアントを初期化します。
    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"))
                // 対象リージョンの CloudMonitor エンドポイントを指定します。
                .setEndpoint("metrics.cn-hangzhou.aliyuncs.com");
        return new Client(config);
    }

    public static void main(String[] args) {
        try {
            Client client = Sample.createClient();

            // スポットインスタンスの中断イベントをクエリします。
            DescribeSystemEventAttributeRequest request = new DescribeSystemEventAttributeRequest()
                    .setProduct("ECS")
                    .setEventType("StatusNotification")
                    .setName("Instance:PreemptibleInstanceInterruption");

            RuntimeOptions runtime = new RuntimeOptions();
            DescribeSystemEventAttributeResponse response = client.describeSystemEventAttributeWithOptions(request, runtime);
            System.out.println(response.body.toMap());
        } 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());
            System.out.println(e.getMessage());
            System.out.println(e.getData());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

応答フォーマット

スポットインスタンスの中断イベントの例は以下の通りです。

{
  "ver": "1.0",
  "id": "2256A988-0B26-4E2B-820A-8A********E5",
  "product": "ECS",
  "resourceId": "acs:ecs:cn-hangzhou:169070********30:instance/i-bp1ecr********5go2go",
  "level": "INFO",
  "name": "Instance:PreemptibleInstanceInterruption",
  "userId": "169070********30",
  "eventTime": "20190409T121826.922+0800",
  "regionId": "cn-hangzhou",
  "content": {
    "instanceId": "i-bp1ecr********5go2go",
    "action": "delete"
  }
}

中断処理に関連する content フィールドの説明は以下の通りです。

その他の応答フィールドの説明については、「DescribeSystemEventAttribute」をご参照ください。