Simple Log Service:Use Simple Log Service SDK for Java to manage alerts

Manage alert monitoring rules

The following sample code is provided for reference. For more information about the parameters in the sample code, see Data structure of an alert monitoring rule.

import com.alibaba.fastjson.JSON;
import com.aliyun.openservices.log.Client;
import com.aliyun.openservices.log.common.*;
import com.aliyun.openservices.log.exception.LogException;
import com.aliyun.openservices.log.request.*;
import com.aliyun.openservices.log.response.*;

import java.util.*;

public class App {
    // The Simple Log Service endpoint. 
    private static final String ENDPOINT = "cn-huhehaote.log.aliyuncs.com";
    // In this example, the AccessKey ID and AccessKey secret are obtained from environment variables. 
    private static final String ACCESS_KEY_ID = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
    private static final String ACCESS_KEY_SECRET = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");
    // Create a Simple Log Service client. 
    private static final Client client = new Client(ENDPOINT, ACCESS_KEY_ID, ACCESS_KEY_SECRET);
    private static final String PROJECT = "demo-alert";
    private static final String ALERT_ID = "nginx-status-error";

    private static void createAlert() throws LogException {
        JobSchedule schedule = new JobSchedule();
        schedule.setType(JobScheduleType.FIXED_RATE);
        schedule.setInterval("1m");

        AlertConfiguration configuration = new AlertConfiguration();
        configuration.setVersion("2.0");
        configuration.setType("default");
        configuration.setDashboard("internal-alert-analysis");

        Query query = new Query();
        query.setStoreType("log");
        query.setRegion("cn-huhehaote");
        query.setProject(PROJECT);
        query.setStore("nginx-access-log");
        query.setQuery("status >= 400 | select count(*) as cnt");
        query.setTimeSpanType(TimeSpanType.TRUNCATED);
        query.setStart("-1m");
        query.setEnd("absolute");
        query.setPowerSqlMode("auto");
        configuration.setQueryList(Collections.singletonList(query));

        AlertConfiguration.GroupConfiguration groupConfiguration = new AlertConfiguration.GroupConfiguration();
        groupConfiguration.setType("no_group");
        configuration.setGroupConfiguration(groupConfiguration);

        AlertConfiguration.SeverityConfiguration severityConfiguration = new AlertConfiguration.SeverityConfiguration();
        severityConfiguration.setSeverity(AlertConfiguration.Severity.Medium);
        AlertConfiguration.ConditionConfiguration conditionConfiguration = new AlertConfiguration.ConditionConfiguration();
        conditionConfiguration.setCondition("cnt > 0");
        conditionConfiguration.setCountCondition("");
        severityConfiguration.setEvalCondition(conditionConfiguration);
        configuration.setSeverityConfigurations(Collections.singletonList(severityConfiguration));

        AlertConfiguration.Tag serviceLabel = new AlertConfiguration.Tag();
        serviceLabel.setKey("service");
        serviceLabel.setValue("nginx");
        configuration.setLabels(Collections.singletonList(serviceLabel));

        AlertConfiguration.Tag titleAnno = new AlertConfiguration.Tag();
        titleAnno.setKey("title");
        titleAnno.setValue("Nginx Status Error");
        AlertConfiguration.Tag descAnno = new AlertConfiguration.Tag();
        descAnno.setKey("desc");
        descAnno.setValue("Nginx Status Error, count: ${cnt}");
        List<AlertConfiguration.Tag> annotations = new LinkedList<AlertConfiguration.Tag>();
        annotations.add(titleAnno);
        annotations.add(descAnno);
        configuration.setAnnotations(annotations);

        configuration.setAutoAnnotation(true);
        configuration.setSendResolved(false);
        configuration.setThreshold(1);
        configuration.setNoDataFire(false);
        configuration.setNoDataSeverity(AlertConfiguration.Severity.Medium);

        AlertConfiguration.PolicyConfiguration policyConfiguration = new AlertConfiguration.PolicyConfiguration();
        policyConfiguration.setAlertPolicyId("sls.builtin.dynamic");
        policyConfiguration.setActionPolicyId("test-action-policy");
        policyConfiguration.setRepeatInterval("1m");
        policyConfiguration.setUseDefault(false);
        configuration.setPolicyConfiguration(policyConfiguration);

        Alert alert = new Alert();
        alert.setName(ALERT_ID);
        alert.setDisplayName("Nginx Status Error");
        alert.setState(JobState.ENABLED);
        alert.setSchedule(schedule);
        alert.setConfiguration(configuration);

        CreateAlertRequest request = new CreateAlertRequest(PROJECT, alert);
        CreateAlertResponse response = client.createAlert(request);
        System.out.println("[create alert] " + JSON.toJSONString(response));
    }

    public static void getAndUpdateAlert() throws LogException {
        GetAlertRequest getAlertRequest = new GetAlertRequest(PROJECT, ALERT_ID);
        GetAlertResponse getAlertResponse = client.getAlert(getAlertRequest);
        System.out.println("[get alert] " + JSON.toJSONString(getAlertResponse));

        Alert alert = getAlertResponse.getAlert();
        alert.getConfiguration().getQueryList().get(0).setQuery("status >= 500 | select count(*) as cnt");

        UpdateAlertRequest updateAlertRequest = new UpdateAlertRequest(PROJECT, alert);
        UpdateAlertResponse updateAlertResponse = client.updateAlert(updateAlertRequest);
        System.out.println("[update alert] " + JSON.toJSONString(updateAlertResponse));
    }

    public static void disableAndEnableAlert() throws LogException {
        DisableAlertRequest disableAlertRequest = new DisableAlertRequest(PROJECT, ALERT_ID);
        DisableAlertResponse disableAlertResponse = client.disableAlert(disableAlertRequest);
        System.out.println("[disable alert] " + JSON.toJSONString(disableAlertResponse));

        EnableAlertRequest enableAlertRequest = new EnableAlertRequest(PROJECT, ALERT_ID);
        EnableAlertResponse enableAlertResponse = client.enableAlert(enableAlertRequest);
        System.out.println("[enable alert] " + JSON.toJSONString(enableAlertResponse));
    }

    public static void listAlerts() throws LogException {
        ListAlertRequest request = new ListAlertRequest(PROJECT);
        request.setOffset(0);
        request.setSize(100);
        ListAlertResponse response = client.listAlert(request);
        System.out.println("[list alerts] " + JSON.toJSONString(response));
    }

    public static void deleteAlert() throws LogException {
        DeleteAlertRequest request = new DeleteAlertRequest(PROJECT, ALERT_ID);
        DeleteAlertResponse response = client.deleteAlert(request);
        System.out.println("[delete alert] " + JSON.toJSONString(response));
    }

    public static void main(String[] args) throws LogException {
        createAlert();
        getAndUpdateAlert();
        disableAndEnableAlert();
        listAlerts();
        deleteAlert();
    }
}
            

Manage alert resource data

The following sample code is provided for reference. For more information about the parameters in the sample code, see Data structure of alert resource data.

References

• If the response that is returned by Simple Log Service contains error information after you call an API operation, the call fails. You can handle errors based on the error codes that are returned when API calls fail. For more information, see Error codes.

• Simple Log Service is also compatible with Alibaba Cloud SDKs. For more information, see Simple Log Service_SDK Center_Alibaba Cloud OpenAPI Explorer.

• Simple Log Service provides the command-line interface (CLI) to meet the requirements for automated configurations in Simple Log Service. For more information, see Overview of Simple Log Service CLI.

• For more sample code, see Alibaba Cloud Simple Log Service SDK for Java on GitHub.