Simple Log Service:Criar uma tarefa de SQL agendada

• O Simple Log Service está ativado. Para mais informações, consulte Activate Simple Log Service.

• O SDK do Simple Log Service para Java está inicializado. Para mais detalhes, consulte Inicializar o SDK do Simple Log Service para Java.

Além disso, o Simple Log Service fornece as classes ScheduledSQL, JobSchedule e ScheduledSQLConfiguration para simplificar a criação de tarefas de SQL agendada por meio do SDK para Java.

• ScheduledSQL: Cria a tarefa de SQL agendada.

• JobSchedule: Define a configuração de agendamento da tarefa.

• ScheduledSQLConfiguration: Estabelece a configuração básica da tarefa de SQL agendada.

Parâmetros da solicitação

ScheduledSQL

A tabela a seguir descreve os parâmetros.

JobSchedule

Execute JobSchedule jobSchedule = new JobSchedule(); para criar a configuração de agendamento da tarefa de SQL agendada. A tabela abaixo detalha os parâmetros.

ScheduledSQLConfiguration

Execute ScheduledSQLConfiguration scheduledSQLConfiguration = generateConfig(); para definir a configuração da tarefa de SQL agendada. A tabela a seguir descreve os parâmetros.

{
  addLabels: "{}",
  hashLabels: "[]",
  labelKeys: "[\"your label1\",\"your label2\"]",
  metricKeys: "[\"your Indicator1\",\"your Indicator2\"]",
  metricName: "",
  timeKey: ""
}

parameters

• Ao configurar uma tarefa de SQL agendada de um Logstore para um Metricstore, também é necessário definir os seguintes parâmetros adicionais:

  Tabela 1. Log2MetricParameters

  Nome do parâmetro	Exemplo	Descrição
  metricKeys	"[\"a\", \"b\", \"c\"]"	Colunas de métrica, correspondentes às colunas de métrica na configuração de SQL do console. O Simple Log Service agrega dados com base na sua instrução de consulta e análise. É possível selecionar uma ou mais colunas do tipo numérico nos resultados da consulta como colunas de métrica. Para mais informações, consulte Métricas.
  labelKeys	"[\"d\", \"e\", \"f\"]"	Colunas de rótulo, correspondentes aos Rótulos (Labels) na configuração de SQL do console. O Simple Log Service agrega dados conforme sua instrução de consulta e análise. Você pode escolher uma ou mais colunas dos resultados da consulta para atuar como rótulos. Para mais detalhes, consulte Métricas.
  hashLabels	"[\"d\", \"f\"]"	Corresponde à opção Rehash na configuração de SQL do console. Após ativar a chave Rehash, configure as colunas de hash para gravar dados com o mesmo valor de coluna em um único shard. Isso melhora a localidade dos dados e a eficiência das consultas. As colunas de hash disponíveis dependem dos resultados da sua consulta e análise. Selecione uma ou mais colunas dos resultados para usar como colunas de hash. Por exemplo, se você definir as colunas de hash como status, todos os dados com o mesmo valor de status serão gravados no mesmo shard.
  addLabels	"[\"m\":\"h\", \"n\":\"i\"]"	Corresponde aos Rótulos Adicionais (Additional Labels) na configuração de SQL do console. Adicione rótulos estáticos como pares chave-valor para identificar atributos da métrica. Por exemplo, defina label_key como app e label_value como ingress-nginx.
  timeKey	time	Corresponde à Coluna de Tempo (Time Column) na configuração de SQL do console. Se você selecionar uma coluna de tempo nos resultados da consulta (com valores de timestamp Unix, como atime:1627025331), o sistema usará essa coluna como timestamp da métrica. Caso selecione empty, o sistema utilizará o horário inicial do intervalo de consulta como timestamp da métrica.

• Para configurar uma tarefa de SQL agendada de um Metricstore para outro Metricstore, defina também os parâmetros adicionais listados abaixo:

  Tabela 2. Metric2MetricParameters

  Nome do parâmetro	Exemplo	Descrição
  metricName	my-metric	Insira um novo nome de métrica caso deseje renomeá-la. Para mais informações, consulte Métricas. Importante Recomendamos renomear apenas ao analisar uma única métrica. Se você analisar múltiplas métricas e renomeá-las, todas compartilharão o mesmo novo nome.
  hashLabels	"{\"m\":\"h\", \"n\":\"i\"}"	Corresponde à opção Rehash na configuração de SQL do console. Ao ativar a chave Rehash, configure as colunas de hash para gravar dados com o mesmo valor de rótulo em um único shard. Essa prática aumenta a localidade dos dados e otimiza a eficiência das consultas. As colunas de hash disponíveis dependem dos rótulos existentes nos dados da métrica. Por exemplo, se os dados da métrica incluírem os rótulos {"alert_id":"alert-1608815762-545495","alert_name":"Alert recovery closed","status":"inactive"}, as colunas de hash válidas são alert_id, alert_name e status. Caso defina as colunas de hash como status, todos os dados com o mesmo valor de status serão direcionados ao mesmo shard.
  addLabels	"{\"m\":\"h\", \"n\":\"i\"}"	Corresponde aos Rótulos Adicionais (Additional Labels) na configuração de SQL do console. Adicione rótulos estáticos como pares chave-valor para identificar atributos da métrica. Por exemplo, defina label_key como app e label_value como ingress-nginx.

Parâmetros de resposta

Para descrições dos parâmetros de resposta, consulte Criar uma tarefa de SQL agendada.

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.CreateScheduledSQLRequest;
public class App {
    // This example retrieves the AccessKey ID and AccessKey secret from environment variables.
    static String accessId = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
    static String accessKey = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");
    // Set project and Logstore names.
    static String sourceProject="aliyun-test-sourceProject";
    static String destProject="aliyun-test-destProject";
    static String sourceLogstore = "logstore-name";
    static String destLogstore = "project-name";
    static String roleArn = "acs:ram::11111111:role/aliyunlogetlrole";
    // Set the Simple Log Service endpoint. This example uses the China (Hangzhou) region. Replace it with your region.
    static String endpoint = "http://cn-hangzhou.log.aliyuncs.com";
    static String destEndpoint = "http://cn-hangzhou-intranet.log.aliyuncs.com";
    static long fromTime = 1648105200; //2022-03-23 15:00:00
    private static String script = "* | select a,b,c from log";
    private static ScheduledSQLBaseParameters generateParams(String dataFormat) {
        if (dataFormat.equalsIgnoreCase("log2log")) {
            return null;
        } else if (dataFormat.equalsIgnoreCase("log2metric")) {
            Log2MetricParameters params = new Log2MetricParameters();
            params.setMetricKeys("[\"a\", \"b\", \"c\"]");
            params.setLabelKeys("[\"d\", \"e\", \"f\"]");
            params.setHashLabels("[\"d\", \"f\"]");
            params.setAddLabels("{\"m\":\"h\", \"n\":\"i\"}");
            params.setTimeKey("time");
            return params;
        } else if (dataFormat.equalsIgnoreCase("metric2metric")) {
            Metric2MetricParameters params = new Metric2MetricParameters();
            params.setMetricName("name");
            params.setHashLabels("[\"d\", \"f\"]");
            params.setAddLabels("{\"m\":\"h\", \"n\":\"i\"}");
            return params;
        }
        return null;
    }
    private static ScheduledSQLConfiguration generateConfig() {
        ScheduledSQLConfiguration scheduledSQLConfiguration = new ScheduledSQLConfiguration();
        scheduledSQLConfiguration.setScript(script);
        scheduledSQLConfiguration.setSqlType("searchQuery");
        scheduledSQLConfiguration.setResourcePool("enhanced");
        scheduledSQLConfiguration.setRoleArn(roleArn);
        scheduledSQLConfiguration.setDestRoleArn(roleArn);
        scheduledSQLConfiguration.setSourceLogstore(sourceLogstore);
        scheduledSQLConfiguration.setDestEndpoint(destEndpoint);
        scheduledSQLConfiguration.setDestProject(destProject);
        scheduledSQLConfiguration.setDestLogstore(destLogstore);
        scheduledSQLConfiguration.setDataFormat("log2log");
        scheduledSQLConfiguration.setFromTimeExpr("@m-1m");
        scheduledSQLConfiguration.setToTimeExpr("@m");
        scheduledSQLConfiguration.setMaxRetries(20);
        scheduledSQLConfiguration.setMaxRunTimeInSeconds(600);
        scheduledSQLConfiguration.setFromTime(fromTime);
        scheduledSQLConfiguration.setToTime(0L);
        ScheduledSQLBaseParameters params = generateParams(scheduledSQLConfiguration.getDataFormat());
        scheduledSQLConfiguration.setParameters(params);
        return scheduledSQLConfiguration;
    }
    private static ScheduledSQL generateScheduledSQL() {
        ScheduledSQL scheduledSQLStructure = new ScheduledSQL();
        scheduledSQLStructure.setName("job-name");
        scheduledSQLStructure.setDisplayName("display-name");
        scheduledSQLStructure.setDescription("desc-name");
        ScheduledSQLConfiguration scheduledSQLConfiguration = generateConfig();
        scheduledSQLStructure.setConfiguration(scheduledSQLConfiguration);
        JobSchedule jobSchedule = new JobSchedule();
        jobSchedule.setType(JobScheduleType.FIXED_RATE);
        jobSchedule.setInterval("1m");
        jobSchedule.setDelay(10);
        jobSchedule.setRunImmediately(false);
        scheduledSQLStructure.setSchedule(jobSchedule);
        return scheduledSQLStructure;
    }
    public static void main(String[] args) {
        Client client = new Client(endpoint, accessId, accessKey);
        ScheduledSQL scheduledSQL = generateScheduledSQL();
        CreateScheduledSQLRequest request = new CreateScheduledSQLRequest(sourceProject, scheduledSQL);
        try {
            client.createScheduledSQL(request);
        } catch (LogException e) {
            e.printStackTrace();
        }
    }
}