Query interruption events of preemptible instances

Query interruption events of preemptible instances by using Cloud Monitor SDK

This section describes how to query interruption events of preemptible instances by using Cloud Monitor SDK for Java.

1. Access Cloud Monitor SDK for Java. For more information, see Cloud Monitor SDK for Java.
2. Query interruption events of preemptible instances by using the SDK.

   import com.aliyuncs.DefaultAcsClient;
   import com.aliyuncs.IAcsClient;
   import com.aliyuncs.exceptions.ClientException;
   import com.aliyuncs.exceptions.ServerException;
   import com.aliyuncs.profile.DefaultProfile;
   import com.google.gson.Gson;
   import java.util.*;
   import com.aliyuncs.cms.model.v20190101.*;
   
   public class DescribeSystemEventAttribute {
       public static void main(String[] args) {
           // Initialize a DefaultAcsClient instance.
           DefaultProfile profile = DefaultProfile.getProfile("cn-hangzhou", "<AccessKeyID>", "<AccessKeySecret>");
           IAcsClient client = new DefaultAcsClient(profile);
   
           // Query interruption events of preemptible instances.
           DescribeSystemEventAttributeRequest request = new DescribeSystemEventAttributeRequest();
           request.setRegionId("cn-hangzhou");
           request.setProduct("ECS");
           request.setEventType("StatusNotification");
           request.setName("Instance:PreemptibleInstanceInterruption");
           try {
               // Receive the responses.
               DescribeSystemEventAttributeResponse response = client.getAcsResponse(request);
               System.out.println(new Gson().toJson(response));
           } catch (ServerException e) {
               e.printStackTrace();
           } catch (ClientException e) {
               System.out.println("ErrCode:" + e.getErrCode());
               System.out.println("ErrMsg:" + e.getErrMsg());
               System.out.println("RequestId:" + e.getRequestId());
           }
       }
   }

3. Check interruption events of preemptible instances based on the responses.

   The following example shows the event notification in the JSON format:

   {
     "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"                       
     }
   }

   The following table describes parameters in the content field.

   Subfield	Description	Example
   instanceId	The ID of the preemptible instance.	i-bp1ecr********5go2go
   action	The action on the preemptible instance. If the parameter is set to delete, the interrupted preemptible instance is forcibly recycled.	delete

Query interruption events of preemptible instances by using instance metadata

1. Remotely connect to an ECS instance. For more information, see Overview.
2. Run the following command to query instance metadata:

   curl 'http://100.100.100.200/latest/meta-data/instance/spot/termination-time'

   • If the response is empty, the instance can still be used.
   • If information in the 2015-01-05T18:02:00Z (UTC+0) format is returned, the preemptible instance will be recycled at that point in time.

Query interruption events of preemptible instances by calling an API operation

This section describes how to call the DescribeInstances operation to determine whether the instance has entered the to be recycled state based on the returned OperationLocks parameter.

import com.alibaba.fastjson.JSONArray;
import com.aliyuncs.AcsRequest;
import com.aliyuncs.AcsResponse;
import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.IAcsClient;
import com.aliyuncs.ecs.model.v20140526.DescribeInstancesRequest;
import com.aliyuncs.ecs.model.v20140526.DescribeInstancesResponse;
import com.aliyuncs.profile.DefaultProfile;
import com.aliyuncs.profile.IClientProfile;
import java.util.*;

public class DescribeInstancesSample {
    public static void main(String[] args) throws InterruptedException {
        // Initialize a DefaultAcsClient instance.
        OpenApiCaller caller = new OpenApiCaller();
        // Specify the IDs of one or more ECS instances to be queried.
        JSONArray allInstances = new JSONArray();
        allInstances.addAll(Arrays.asList("i-bp1i9c3qiv1qs6nc****"));
        while (!allInstances.isEmpty()) {
            DescribeInstancesRequest request = new DescribeInstancesRequest();
            // Specify the region where the instance is located.
            request.setRegionId("cn-hangzhou");
            // Specify the instance ID for higher query efficiency.
            request.setInstanceIds(allInstances.toJSONString());
            // Receive the responses.
            DescribeInstancesResponse response = caller.doAction(request);
            // Obtain instance-related returned results.
            List<DescribeInstancesResponse.Instance> instanceList = response.getInstances();
            if (instanceList != null && !instanceList.isEmpty()) {
                for (DescribeInstancesResponse.Instance instance : instanceList) {
                    // Output the ID and zone information of the queried instance.
                    System.out.println("result:instance:" + instance.getInstanceId() + ",az:" + instance.getZoneId());
                    if (instance.getOperationLocks() != null) {
                        for (DescribeInstancesResponse.Instance.LockReason lockReason : instance.getOperationLocks()) {
                            // If the instance is locked, specify the instance ID and the corresponding lock reason.
                            System.out.println("instance:" + instance.getInstanceId() + "-->lockReason:" + lockReason.getLockReason() + ",vmStatus:" + instance.getStatus());
                            if ("Recycling".equals(lockReason.getLockReason())) {
                                // Specify the IDs of the instances to be recycled.
                                System.out.println("spot instance will be recycled immediately, instance id:" + instance.getInstanceId());
                                allInstances.remove(instance.getInstanceId());
                            }
                        }
                    }
                }
                // If the preemptible instance is not locked, it will be queried every two minutes.
                System.out.print("try describeInstances again later ...");
                Thread.sleep(2 * 60 * 1000);
            } else {
                break;
            }
        }
    }
}

// Initialize a DefaultAcsClient instance.
class OpenApiCaller{
    IClientProfile profile;
    IAcsClient client;
    public OpenApiCaller() {
        profile = DefaultProfile.getProfile("cn-hangzhou", "<AccessKeyID>", "<AccessKeySecret>");
        client = new DefaultAcsClient(profile);
    }

    public  <T extends AcsResponse> T doAction(AcsRequest<T> var1) {
        try {
            return  client.getAcsResponse(var1);
        } catch (Throwable e) {
            e.printStackTrace();
            return null;
        }
    }
}

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