Elastic Compute Service:Deteksi dan tangani gangguan spot instance

Buat objek permintaan

Sebelum membuat permintaan, lihat dokumentasi API untuk detail parameter.

// Buat objek permintaan
DescribeInstancesRequest request = new DescribeInstancesRequest().setRegionId("cn-hangzhou");

Lakukan pemanggilan

Saat memanggil operasi OpenAPI, Anda dapat mengonfigurasi parameter waktu proses seperti timeout dan pengaturan proxy. Lihat Konfigurasi lanjutan.

// Setel opsi waktu proses
RuntimeOptions runtime = new RuntimeOptions();
// Panggil operasi DescribeInstances
DescribeInstancesResponse response = client.describeInstancesWithOptions(request, runtime);
System.out.println(response.body.toMap());

Tangani exception

SDK Java mengkategorikan exception menjadi TeaUnretryableException dan TeaException:

• TeaUnretryableException: Biasanya disebabkan oleh masalah jaringan setelah jumlah maksimum retry tercapai.

• TeaException: Terutama disebabkan oleh error terkait bisnis.

Terapkan penanganan exception yang tepat, seperti menyebarkan exception, mencatat error, atau mencoba pemulihan, untuk memastikan ketangguhan sistem.

Contoh lengkap

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()
                // Wajib diisi. Pastikan variabel lingkungan ALIBABA_CLOUD_ACCESS_KEY_ID telah disetel.
                .setAccessKeyId(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"))
                // Wajib diisi. Pastikan variabel lingkungan ALIBABA_CLOUD_ACCESS_KEY_SECRET telah disetel.
                .setAccessKeySecret(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"))
                // Referensi 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();
            // Buat objek permintaan
            // Tentukan satu atau beberapa ID Instance ECS untuk dikueri.
            JSONArray instanceIds = new JSONArray();
            instanceIds.addAll(Arrays.asList("i-bp145cvd0exyqj****","i-bp1gehfgfrrk4lah****"));
            DescribeInstancesRequest request = new DescribeInstancesRequest()
                    .setRegionId("cn-hangzhou")
                    .setInstanceIds(instanceIds.toJSONString());
            // Setel opsi waktu proses
            RuntimeOptions runtime = new RuntimeOptions();
            while (!instanceIds.isEmpty()) {
              // Panggil operasi DescribeInstances
              DescribeInstancesResponse response = client.describeInstancesWithOptions(request, runtime);
              // Dapatkan detail instans dari respons.
              DescribeInstancesResponseBody responseBody = response.getBody();
              DescribeInstancesResponseBody.DescribeInstancesResponseBodyInstances instanceList = responseBody.getInstances();
              // Periksa detail instans dan evaluasi nilai lockReason.
              if (instanceList != null && instanceList.getInstance()!= null && !instanceList.getInstance().isEmpty()) {
                  for (DescribeInstancesResponseBody.DescribeInstancesResponseBodyInstancesInstance instance : instanceList.getInstance()) {
                      // Cetak ID instans dan ID zona yang dikueri.
                      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()) {
                                  // Jika instans terkunci, cetak ID-nya dan alasan penguncian.
                                  System.out.println("instance:" + instance.getInstanceId() + "-->lockReason:" + lockReason.getLockReason() + ",vmStatus:" + instance.getStatus());
                                  if ("Recycling".equals(lockReason.getLockReason())) {
                                      // Cetak ID instans yang dijadwalkan untuk segera dirilis.
                                      System.out.println("spot instance will be recycled immediately, instance id:" + instance.getInstanceId());
                                      instanceIds.remove(instance.getInstanceId());
                                  }
                              }
                          }

                      }
                  }
                  // Jika belum ada spot instance yang terkunci, kueri lagi setiap dua menit.
                  System.out.print("try describeInstances again later ...");
                  Thread.sleep(2 * 60 * 1000);
              } else {
                  break;
              }
            }
        } catch (TeaUnretryableException ue) {
            // Hanya untuk demonstrasi. Jangan pernah mengabaikan exception dalam kode produksi.
            ue.printStackTrace();
            // Cetak pesan error
            System.out.println(ue.getMessage());
            // Cetak detail permintaan untuk debugging
            System.out.println(ue.getLastRequest());
        } catch (TeaException e) {
            // Hanya untuk demonstrasi. Jangan pernah mengabaikan exception dalam kode produksi.
            e.printStackTrace();
            // Cetak kode error
            System.out.println(e.getCode());
            // Cetak pesan error (termasuk RequestId)
            System.out.println(e.getMessage());
            // Cetak konten error detail sisi server
            System.out.println(e.getData());
        } catch (Exception e) {
            // Hanya untuk demonstrasi. Jangan pernah mengabaikan exception dalam kode produksi.
            e.printStackTrace();
        }
    }
}

Hasil yang dikembalikan

Saat rilis dipicu, output-nya adalah:

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****

Instans Linux

# Dapatkan token layanan metadata untuk autentikasi
TOKEN=`curl -X PUT "http://100.100.100.200/latest/api/token" -H "X-aliyun-ecs-metadata-token-ttl-seconds:<metadata service token TTL>"`
# Periksa apakah spot instance dijadwalkan untuk gangguan
curl -H "X-aliyun-ecs-metadata-token: $TOKEN" http://100.100.100.200/latest/meta-data/instance/spot/termination-time

Instans Windows

# Dapatkan token layanan metadata untuk autentikasi
$token = Invoke-RestMethod -Headers @{"X-aliyun-ecs-metadata-token-ttl-seconds" = "<metadata service token TTL>"} -Method PUT -Uri http://100.100.100.200/latest/api/token
# Periksa apakah spot instance dijadwalkan untuk gangguan
Invoke-RestMethod -Headers @{"X-aliyun-ecs-metadata-token" = $token} -Method GET -Uri http://100.100.100.200/latest/meta-data/instance/spot/termination-time

Alur kerja

Prosedur

1. Siapkan saluran penerima

   Lightweight Message Queue

   1. Masuk ke Konsol Simple Message Queue (sebelumnya MNS).

   2. Di panel navigasi kiri, pilih Queue Model > Queues.

   3. Di bilah navigasi atas, pilih wilayah.

   4. Di halaman Queues, klik Create Queue.

   5. Di panel Create Queue, konfigurasikan parameter berikut lalu klik OK:

      • Name: nama antrian.

      • Maximum Message Length: panjang maksimum pesan yang dikirim ke antrian.

      • Long Polling Period: durasi maksimum permintaan long polling ditahan setelah operasi ReceiveMessage dipanggil.

      • Visibility Timeout Period: durasi pesan berada dalam status Inactive setelah pesan diterima dari antrian.

      • Message Retention Period: durasi maksimum pesan ada dalam antrian. Setelah periode retensi yang ditentukan, pesan dihapus terlepas dari apakah pesan telah diterima atau belum.

      • Message Delay Period: periode setelah semua pesan yang dikirim ke antrian dikonsumsi.

      • Enable Logging Feature: menentukan apakah fitur logging diaktifkan.

      Setelah antrian dibuat, antrian tersebut ditampilkan di halaman Queues.

   Webhook

   Penting

   Deploy layanan webhook pada server yang dapat diakses Internet. Pastikan lalu lintas masuk diizinkan pada port respons.

   Kode contoh 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) {
           // Proses muatan, seperti mencatat log atau menjalankan logika bisnis
           System.out.println("Received webhook payload: " + payload);
           // Kembalikan respons sukses
           return ResponseEntity.ok("Webhook received");
       }
   }

2. Buat kebijakan langganan

   1. Masuk ke Konsol Cloud Monitor.

   2. Di panel navigasi kiri, pilih Event Hub > Event Subscriptions.

   3. Di tab Subscription Policies, klik Create Subscription Policy.

   4. Di halaman Create Subscription Policy, konfigurasikan parameter kebijakan.

      Contoh ini hanya mencakup parameter yang relevan dengan event gangguan spot instance. Untuk semua parameter, lihat Kelola langganan event (disarankan).

      • Basic Information: Masukkan Name dan Description untuk kebijakan langganan.

      • Alert Subscription:

        • Subscription Type: Pilih System Events.

        • Subscription Scope:

        • Service: Pilih ECS.

        • Event Type: Pilih Status Notification.

        • Event Name: Pilih Spot Instance Interruption Notification.

        • Event Severity: Pilih Warning.

        • Application Groups, Event Content, dan Event Resource: Biarkan parameter ini kosong untuk berlangganan semua event sistem ECS dengan nama Spot Instance Interruption Notification di seluruh kelompok aplikasi dalam akun Anda.

      • Noise Reduction: Gunakan default.

      • Notification: The Custom Notification Method menggunakan metode default.

      • Push and Integration: Klik Add Channel. Di jendela pop-up, klik Add Channel, pilih saluran yang disiapkan di Langkah 1 sebagai Target Type, lalu lengkapi bidang lainnya. Untuk detail saluran push, lihat Kelola saluran push.

3. Simulasikan event gangguan

   Gangguan spot instance bersifat pasif, sehingga sulit untuk melakukan debug kode penanganan gangguan. Gunakan fitur Debug Event Subscription untuk mensimulasikan event gangguan spot instance.

   1. Di tab Subscription Policies, klik Debug Event Subscription.

   2. Di panel Create Event Debug, atur Service ke ECS dan Name ke Spot Instance Interruption Notification.

      Sistem menghasilkan muatan debug dalam format JSON. Ganti placeholder terkait resource dengan nilai aktual untuk spot instance yang akan disimulasikan.

      • Ganti UID Akun Alibaba Cloud dengan UID Akun Alibaba Cloud Anda.

      • Ganti <resource-id> dan <instanceId> dengan ID spot instance.

      • Ganti <region ID> dengan ID wilayah spot instance.

        {
            "product": "ECS",
            "resourceId": "acs:ecs:cn-shanghai:UID Akun Alibaba Cloud:instance/<resource-id>",
            "level": "WARN",
            "instanceName": "instanceName",
            "regionId": "<region ID>",
            "groupId": "0",
            "name": "Instance:PreemptibleInstanceInterruption",
            "content": {
                "instanceId": "i-2zeg014dfo4y892z***",
                "instanceName": "wor***b73",
                "action": "delete"
            },
            "status": "Normal"
        }

   3. Klik OK.

      Sistem menampilkan pesan The operation is successful. dan mengirim notifikasi peringatan uji berdasarkan kebijakan langganan Anda.

4. Terima dan lihat notifikasi

   Lightweight Message Queue

   1. Masuk ke Konsol Simple Message Queue (sebelumnya MNS). Di panel navigasi kiri, klik Queues.

   2. Di bilah navigasi atas, pilih wilayah. Di halaman Queues, temukan antrian target Anda lalu klik Action > Send Messages.

   3. Opsional: Pada halaman Send/Receive Messages Quick Experience, klik Edit Parameters of Receiving Messages. Di panel Edit Parameters of Receiving Messages, atur Receive Times dan Polling Period, lalu klik OK.

   4. Di halaman Queue Send/Receive Messages Quick Experience, klik Receive Message. Daftar pesan muncul di bagian Received Messages.

   5. Opsi: Di daftar pesan, temukan pesan target Anda, klik Details di kolom Actions, lalu lihat konten pesan di kotak dialog Message Details.

   Webhook

   Anda dapat memeriksa log pemanggilan dan konten notifikasi di aplikasi webhook yang telah di-deploy.