告警監(jiān)控規(guī)則管理

代碼示例如下。具體的參數(shù)說明，請參見告警監(jiān)控規(guī)則數(shù)據(jù)結(jié)構(gòu)。

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 {
    // 設(shè)置日志服務(wù)的服務(wù)接入點。
    private static final String ENDPOINT = "cn-huhehaote.log.aliyuncs.com";
    // 本示例從環(huán)境變量中獲取AccessKey ID和AccessKey Secret。
    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");
    // 創(chuàng)建日志服務(wù)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();
    }
}
            

資源數(shù)據(jù)管理

代碼示例如下。具體的參數(shù)說明，請參見告警資源數(shù)據(jù)結(jié)構(gòu)。

相關(guān)文檔

• 在調(diào)用API接口過程中，若服務(wù)端返回結(jié)果中包含錯誤信息，則表示調(diào)用API接口失敗。您可以參考API錯誤碼對照表查找對應(yīng)的解決方法。更多信息，請參見API錯誤處理對照表。

• 阿里云OpenAPI開發(fā)者門戶提供調(diào)試、SDK、示例和配套文檔。通過OpenAPI，您無需手動封裝請求和簽名操作，就可以快速對日志服務(wù)API進行調(diào)試。更多信息，請參見OpenAPI開發(fā)者門戶。

• 為滿足越來越多的自動化日志服務(wù)配置需求，日志服務(wù)提供命令行工具CLI（Command Line Interface）。更多信息，請參見日志服務(wù)命令行工具CLI。

• 更多示例代碼，請參見Aliyun Log Java SDK on GitHub。