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：主要是因為網路問題造成，一般是網路問題達到最大重試次數後拋出。

• 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"))
                // Endpoint 請參考 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();
            // 構造請求對象
            // 設定待查詢的一個或多個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("spot instance will be recycled immediately, instance id:" + instance.getInstanceId());
                                      instanceIds.remove(instance.getInstanceId());
                                  }
                              }
                          }

                      }
                  }
                  // 如果搶佔式執行個體還未被鎖定，將每隔兩分鐘查詢一次。
                  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());
            // 列印錯誤資訊，錯誤資訊中包含 RequestId
            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執行個體

# 擷取中繼資料服務器的訪問憑證用於鑒權
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提供的環境無法滿足您的業務需求，您可以使用容器鏡像建立方式部署函數。具體操作，請參見建立Custom Container函數。

      • 基本設定：配置函數的基本資料，包括函數名稱和請求處理常式類型。請求處理常式類型包括以下兩種。

        • 處理事件請求：通過定時器、調用API/SDK或其他阿里雲服務的觸發器來觸發函數執行。

        • 處理 HTTP 要求：用於處理HTTP請求或WebSocket請求的函數。如果您的使用情境是Web情境，建議您使用自訂運行時建立。

      • 函數代碼：配置函數的運行環境和代碼相關資訊。

        配置項	說明	樣本
        運行環境	選擇您熟悉的語言，例如Python、Java、PHP或Node.js等。Function Compute支援的運行環境，請參見Function Compute支援的函數運行環境列表。	Node.js14
        代碼上傳方式	選擇上傳函數代碼到Function Compute的方式。 使用範例程式碼：預設，您可以根據業務需要選擇Function Compute為您提供的建立函數的範例程式碼。 通過 ZIP 包上傳代碼：選擇函數代碼ZIP包並上傳。 通過 JAR 包上傳代碼：選擇函數代碼JAR包並上傳。 通過檔案夾上傳代碼：選擇包含函數代碼的檔案夾並上傳。 通過 OSS 上傳代碼：選擇上傳函數代碼的Bucket 名稱和檔案名稱。 說明 代碼上傳方式選擇使用範例程式碼時，不需要修改請求處理常式。當選擇其他代碼上傳方式時，則需要根據實際情況修改請求處理常式，否則函數執行時會報錯。 當運行環境選擇為Java 8或Java 11時，只支援使用範例程式碼、通過 JAR 包上傳代碼和通過 OSS 上傳代碼。其餘運行環境支援使用範例程式碼、通過 ZIP 包上傳代碼、通過檔案夾上傳代碼和通過 OSS 上傳代碼。	使用範例程式碼
        啟動命令	說明 僅當您選擇使用自訂運行時建立函數時，需設定此配置項。 程式的啟動命令。如果不配置啟動命令，您需要在代碼的根目錄手動建立一個名稱為bootstrap的啟動指令碼，您的程式通過此指令碼來啟動。	npm run start
        監聽連接埠	說明 僅當您選擇使用自訂運行時建立函數時，需設定此配置項。 您的代碼中的HTTP Server所監聽的連接埠。	9000

      • 進階配置：配置函數的執行個體相關資訊和函數執行逾時時間等。

        配置項	說明	樣本
        規格方案	根據您的業務情況，選擇或手動輸入合理的vCPU規格和記憶體規格組合。關於各資源使用的計費詳情，請參見計費概述。 說明 vCPU大小（單位為核）與記憶體大小（單位為GB）的比例必須設定在1∶1到1∶4之間。	0.35核，512 MB
        臨時硬碟大小	根據您的業務情況，選擇臨時隱藏檔的硬碟大小。 取值說明如下。 512 MB：預設值。不計費，Function Compute為您提供512 MB以內的硬碟免費使用額度。 10 GB：按9.5 GB進行計費。 說明 臨時硬碟中所有目錄可寫，共用臨時硬碟的空間。 臨時硬碟大小與底層執行函數的執行個體生命週期一致，執行個體被系統回收後，硬碟上的資料也會消失。如您需要對檔案進行持久化儲存，可以選擇掛載NAS或OSS。具體操作，請參見配置NAS檔案系統和配置OSS檔案系統。	512 MB
        執行個體並發度	設定函數執行個體的並發度。具體資訊，請參見設定執行個體並發度。	10
        執行逾時時間	設定逾時時間。執行逾時時間預設為60秒，最長為86400秒。	60
        請求處理常式	佈建要求處理常式，Function Compute的運行時會載入並調用您的請求處理常式處理請求。選擇使用自訂運行時建立和使用容器鏡像建立函數時，無需設定此配置項。 說明 代碼上傳方式選擇使用範例程式碼時，不需要修改請求處理常式。當選擇其他代碼上傳方式時，則需要根據實際情況修改請求處理常式，否則函數執行時會報錯。	index.handler
        時區	選擇函數的時區。此處設定函數的時區後，將自動為函數添加一條環境變數TZ，其值為您設定的目標時區。	UTC

      • 環境變數：設定函數運行環境中的環境變數。更多資訊，請參見環境變數。

      • 觸發器配置：設定函數的觸發器，您可以使用觸發器觸發函數執行。更多資訊，請參見觸發器管理。

   輕量訊息佇列

   1. 登入輕量訊息佇列（原 MNS）控制台。

   2. 在左側導覽列，選擇队列模型 > 队列列表。

   3. 在頂部功能表列，選擇地區。

   4. 在队列列表頁面，單擊创建队列。

   5. 在创建队列面板配置以下參數，然後單擊确定。

      • 名称：隊列名稱。

      • 消息最大长度：發送到隊列的訊息體的最大長度。

      • 长轮询时间：當隊列中沒有訊息時，該隊列的ReceiveMessage請求的最大等待時間長度。

      • 消息可见性超时时间：訊息從隊列中取出後從Active狀態變成Inactive狀態後的期間。

      • 消息保存时长：訊息在隊列中的最長存活時間。從發送到隊列開始經過此參數指定的時間後，不論訊息是否被取出都將被刪除。

      • 消息延时时间：發送到隊列的所有訊息將延後此參數指定的時間後被消費。

      • 启用日志功能：是否開啟日誌管理功能。

      队列列表頁面目標隊列已建立。

   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) {
           // 處理payload，例如記錄日誌或進行商務邏輯處理
           System.out.println("Received webhook payload: " + payload);
           // 返回成功響應
           return ResponseEntity.ok("Webhook received");
       }
   }

2. 建立訂閱策略

   1. 登入CloudMonitor控制台。

   2. 在左側導覽列，選擇事件中心 > 事件訂閱。

   3. 在訂閱策略頁簽，單擊建立訂閱策略。

   4. 在建立訂閱策略頁面，設定訂閱策略的相關參數。

      本樣本僅說明訂閱搶佔式執行個體中斷事件所涉及的參數，更多參數說明，請參見管理事件訂閱（推薦）。

      • 基本資料：輸入訂閱策略名稱和描述。

      • 警示訂閱：

        • 訂閱類型：選擇系統事件

        • 訂閱範圍：

        • 產品：選擇Elastic Compute Service

        • 事件類型：選擇狀態通知

        • 事件名稱：選擇搶佔式執行個體中斷通知

        • 事件等級：選擇警示（Warning）

        • 應用分組、事件內容和事件資源：均不設定，表示訂閱本帳號內所有應用分組中的所有ECS執行個體的系統事件搶佔式執行個體中斷通知。

      • 合并降噪：使用預設值。

      • 通知：自訂通知方式使用預設通知方式。

      • 推送與整合：點擊添加渠道，快顯視窗中點擊增加渠道，目標類型選擇第1步準備的渠道，其他參數根據提示完成填寫即可。更多推送渠道說明，請參見管理推送渠道。

3. 類比中斷事件

   搶佔式執行個體的中斷事件為被動觸發事件，當您在開發搶佔式執行個體中斷事件處理常式過程中，無法有效地進行代碼調試。您可以藉助調試事件訂閱類比搶佔式執行個體中斷事件。

   1. 在訂閱策略頁簽，單擊調試事件訂閱。

   2. 在建立事件調試面板，產品選擇Elastic Compute Service，名稱選擇搶佔式執行個體中斷通知。

      系統自動產生JSON格式的調試內容，您需要將JSON檔案中資源相關的資訊替換為待類比中斷事件的搶佔式執行個體的資訊。

      • 阿里雲帳號UID變數需要替換為當前登入的阿里雲帳號UID。

      • <resource-id>以及<instanceId>需要替換為搶佔式執行個體的執行個體ID。

      • <地區ID>需要替換為搶佔式執行個體所屬的地區ID。

        {
            "product": "ECS",
            "resourceId": "acs:ecs:cn-shanghai:阿里雲帳號UID:instance/<resource-id>",
            "level": "WARN",
            "instanceName": "instanceName",
            "regionId": "<地區ID>",
            "groupId": "0",
            "name": "Instance:PreemptibleInstanceInterruption",
            "content": {
                "instanceId": "i-2zeg014dfo4y892z***",
                "instanceName": "wor***b73",
                "action": "delete"
            },
            "status": "Normal"
        }

   3. 單擊確定。

      系統提示操作成功，CloudMonitor自動根據訂閱策略中的通知方式發送一條警示測試通知。

4. 接收和查看

   Function Compute

   1. 登入Function Compute控制台，在左側導覽列，單擊服務及函數。

   2. 在頂部功能表列，選擇地區，然後在服務列表頁面，單擊目標服務操作列的函數管理。

   3. 在函數管理頁面，單擊目標函數名稱，然後在函數詳情頁面，單擊調用日誌頁簽。

   輕量訊息佇列

   1. 登入輕量訊息佇列（原 MNS）控制台，在左側導覽列，單擊队列列表。

   2. 在頂部功能表列，選擇地區，然後在隊列列表頁面，找到目標隊列，在其右側操作列選擇收发消息。

   3. 可選：在收發訊息快速體驗頁面，單擊编辑接收消息参数，在编辑接收消息参数面板配置单次获取最大条数和轮询时间，然後單擊確定。

   4. 在隊列收發訊息快速體驗頁面，單擊接收消息按鈕，接收訊息列表地區顯示隊列的訊息列表。

   5. 可選：在訊息列表中找到目標訊息，在其右側操作列單擊详情，在訊息詳情對話方塊中查看訊息內容等資訊。

   Webhook

   在部署了Webhook的程式中查看調用情況和通知內容。