Elastic Compute Service:Detect and handle spot instance interruptions

Construa o objeto de solicitação

Antes de construir a solicitação, consulte API documentation para obter detalhes sobre os parâmetros.

// Build the request object
DescribeInstancesRequest request = new DescribeInstancesRequest().setRegionId("cn-hangzhou");

Faça a chamada

Ao chamar operações da OpenAPI, configure parâmetros de tempo de execução, como timeout e configurações de proxy. Consulte Advanced configuration.

// Set runtime options
RuntimeOptions runtime = new RuntimeOptions();
// Call the DescribeInstances operation
DescribeInstancesResponse response = client.describeInstancesWithOptions(request, runtime);
System.out.println(response.body.toMap());

Trate as exceções

O SDK para Java categoriza as exceções em TeaUnretryableException e TeaException:

• TeaUnretryableException: Geralmente ocorre devido a problemas de rede após o sistema atingir o número máximo de tentativas.

• TeaException: Ocorre principalmente devido a erros relacionados à lógica de negócios.

Implemente um tratamento de exceções adequado, como propagar exceções, registrar erros em log ou tentar a recuperação, para garantir a robustez do sistema.

Exemplo completo

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()
                // Required. Ensure the ALIBABA_CLOUD_ACCESS_KEY_ID environment variable is set.
                .setAccessKeyId(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"))
                // Required. Ensure the ALIBABA_CLOUD_ACCESS_KEY_SECRET environment variable is set.
                .setAccessKeySecret(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"))
                // Endpoint reference: 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();
            // Build the request object
            // Specify one or more ECS instance IDs to query.
            JSONArray instanceIds = new JSONArray();
            instanceIds.addAll(Arrays.asList("i-bp145cvd0exyqj****","i-bp1gehfgfrrk4lah****"));
            DescribeInstancesRequest request = new DescribeInstancesRequest()
                    .setRegionId("cn-hangzhou")
                    .setInstanceIds(instanceIds.toJSONString());
            // Set runtime options
            RuntimeOptions runtime = new RuntimeOptions();
            while (!instanceIds.isEmpty()) {
              // Call the DescribeInstances operation
              DescribeInstancesResponse response = client.describeInstancesWithOptions(request, runtime);
              // Get instance details from the response.
              DescribeInstancesResponseBody responseBody = response.getBody();
              DescribeInstancesResponseBody.DescribeInstancesResponseBodyInstances instanceList = responseBody.getInstances();
              // Check instance details and evaluate lockReason values.
              if (instanceList != null && instanceList.getInstance()!= null && !instanceList.getInstance().isEmpty()) {
                  for (DescribeInstancesResponseBody.DescribeInstancesResponseBodyInstancesInstance instance : instanceList.getInstance()) {
                      // Print the queried instance ID and zone 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()) {
                                  // If the instance is locked, print its ID and lock reason.
                                  System.out.println("instance:" + instance.getInstanceId() + "-->lockReason:" + lockReason.getLockReason() + ",vmStatus:" + instance.getStatus());
                                  if ("Recycling".equals(lockReason.getLockReason())) {
                                      // Print the ID of the instance scheduled for immediate release.
                                      System.out.println("spot instance will be recycled immediately, instance id:" + instance.getInstanceId());
                                      instanceIds.remove(instance.getInstanceId());
                                  }
                              }
                          }

                      }
                  }
                  // If no spot instance is locked yet, query again every two minutes.
                  System.out.print("try describeInstances again later ...");
                  Thread.sleep(2 * 60 * 1000);
              } else {
                  break;
              }
            }
        } catch (TeaUnretryableException ue) {
            // Print only for demonstration. Never ignore exceptions in production code.
            ue.printStackTrace();
            // Print error message
            System.out.println(ue.getMessage());
            // Print request details for debugging
            System.out.println(ue.getLastRequest());
        } catch (TeaException e) {
            // Print only for demonstration. Never ignore exceptions in production code.
            e.printStackTrace();
            // Print error code
            System.out.println(e.getCode());
            // Print error message (includes RequestId)
            System.out.println(e.getMessage());
            // Print detailed server-side error content
            System.out.println(e.getData());
        } catch (Exception e) {
            // Print only for demonstration. Never ignore exceptions in production code.
            e.printStackTrace();
        }
    }
}

Resultados retornados

Quando ocorre uma liberação, a saída é:

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

Instância Linux

# Get a metadata service token for authentication
TOKEN=`curl -X PUT "http://100.100.100.200/latest/api/token" -H "X-aliyun-ecs-metadata-token-ttl-seconds:<metadata service token TTL>"`
# Check whether the spot instance is scheduled for interruption
curl -H "X-aliyun-ecs-metadata-token: $TOKEN" http://100.100.100.200/latest/meta-data/instance/spot/termination-time

Instância Windows

# Get a metadata service token for authentication
$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
# Check whether the spot instance is scheduled for interruption
Invoke-RestMethod -Headers @{"X-aliyun-ecs-metadata-token" = $token} -Method GET -Uri http://100.100.100.200/latest/meta-data/instance/spot/termination-time

Fluxo de trabalho

Procedimento

1. Prepare o canal de recebimento

   Fila de mensagens leve

   1. Faça login no console do Simple Message Queue (antigo MNS).

   2. No painel de navegação à esquerda, escolha Queue Model > Queues.

   3. Na barra de navegação superior, selecione uma região.

   4. Na página Queues, clique em Create Queue.

   5. No painel Create Queue, configure os seguintes parâmetros e clique em OK:

      • Name: o nome da fila.

      • Maximum Message Length: o tamanho máximo da mensagem enviada à fila.

      • Long Polling Period: a duração máxima em que o sistema mantém as solicitações de long polling após a chamada da operação ReceiveMessage.

      • Visibility Timeout Period: a duração em que uma mensagem permanece no estado Inactive após a sua recepção na fila.

      • Message Retention Period: o tempo máximo de retenção de uma mensagem na fila. Após o período que você especifique, o sistema exclua a mensagem, independentemente de sua recepção.

      • Message Delay Period: o período após o qual o sistema consome todas as mensagens enviadas para a fila.

      • Enable Logging Feature: defina se o recurso de log deve ser ativado. Se necessário, ative o log.

      Após a criação, a fila aparece na página Queues.

   Webhook

   Importante

   Implante o service de webhook em um servidor acessível pela Internet. Certifique-se de permitir o tráfego de entrada na porta de resposta.

   Código de exemplo em 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) {
           // Process the payload, such as logging or executing business logic
           System.out.println("Received webhook payload: " + payload);
           // Return a success response
           return ResponseEntity.ok("Webhook received");
       }
   }

2. Crie uma política de assinatura

   1. Faça login no console do Cloud Monitor.

   2. No painel de navegação à esquerda, escolha Event Hub > Event Subscriptions.

   3. Na aba Subscription Policies, clique em Create Subscription Policy.

   4. Na página Create Subscription Policy, configure os parâmetros da política.

      Este exemplo aborda apenas os parâmetros relevantes para eventos de interrupção de instância spot. Para todos os parâmetros, consulte Manage event subscriptions (recommended).

      • Basic Information: Insira um Name e uma Description para a política de assinatura.

      • Alert Subscription:

        • Subscription Type: Selecione System Events.

        • Subscription Scope:

        • Service: Selecione ECS.

        • Event Type: Selecione Status Notification.

        • Event Name: Selecione Spot Instance Interruption Notification.

        • Event Severity: Selecione Warning.

        • Application Groups, Event Content e Event Resource: Deixe esses parâmetros vazios para assinar todos os eventos do sistema ECS com o nome Spot Instance Interruption Notification em todos os grupos de aplicativos da sua conta.

      • Noise Reduction: Use o valor padrão.

      • Notification: O The Custom Notification Method usa o método padrão.

      • Push and Integration: Clique em Add Channel. Na janela pop-up, clique em Add Channel, selecione o canal preparado na Etapa 1 como Target Type e preencha os campos restantes. Para detalhes sobre o canal de push, consulte Manage push channels.

3. Simule um evento de interrupção

   As interrupções de instâncias spot ocorrem de forma passiva, dificultando a depuração do código de tratamento de interrupções. Use o recurso Debug Event Subscription para simular um evento de interrupção de instância spot.

   1. Na aba Subscription Policies, clique em Debug Event Subscription.

   2. No painel Create Event Debug, defina Service como ECS e Name como Spot Instance Interruption Notification.

      O sistema gera um payload de depuração no formato JSON. Substitua os placeholders relacionados a recursos pelos valores reais da instância spot a ser simulada.

      • Substitua Alibaba Cloud account UID pelo UID da sua conta Alibaba Cloud.

      • Substitua <resource-id> e <instanceId> pelo ID da instância spot.

      • Substitua <region ID> pelo ID da região da instância spot.

        {
            "product": "ECS",
            "resourceId": "acs:ecs:cn-shanghai:Alibaba Cloud account UID: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. Clique em OK.

      O sistema exibe a mensagem The operation is successful. e envia uma notificação de alerta de teste com base na sua política de assinatura.

4. Receba e visualize notificações

   Fila de mensagens leve

   1. Faça login no console do Simple Message Queue (antigo MNS). No painel de navegação à esquerda, clique em Queues.

   2. Na barra de navegação superior, selecione uma região. Na página Queues, encontre a fila de destino e clique em Action > Send Messages.

   3. Opcional: Na página Send/Receive Messages Quick Experience, clique em Edit Parameters of Receiving Messages e edite os parâmetros. No painel Edit Parameters of Receiving Messages, defina Receive Times e Polling Period e clique em OK.

   4. Na página Queue Send/Receive Messages Quick Experience, clique em Receive Message. A lista de mensagens aparece na seção Received Messages.

   5. Opcional: Na lista de mensagens, encontre a mensagem de destino, clique em Details na coluna Actions e visualize o conteúdo da mensagem na caixa de diálogo Message Details.

   Webhook

   Verifique os logs de invocação e o conteúdo da notificação no seu aplicativo de webhook implantado.