Simple Log Service:Crear una tarea de SQL programada

• Simple Log Service está activado. Para obtener más información, consulte Activar Simple Log Service.

• El SDK de Simple Log Service para Java está inicializado. Para obtener más información, consulte Initialize Simple Log Service SDK for Java.

Además, Simple Log Service proporciona las clases ScheduledSQL, JobSchedule y ScheduledSQLConfiguration para simplificar la creación de tareas de SQL programado mediante el SDK de Java.

• ScheduledSQL: Crea una tarea de SQL programado.

• JobSchedule: Crea una configuración de programación para la tarea de SQL programado.

• ScheduledSQLConfiguration: Crea la configuración básica para la tarea de SQL programado.

Parámetros de solicitud

ScheduledSQL

La siguiente tabla describe los parámetros.

JobSchedule

Llame a JobSchedule jobSchedule = new JobSchedule(); para crear una configuración de programación para la tarea de SQL programado. La siguiente tabla describe los parámetros.

ScheduledSQLConfiguration

Llame a ScheduledSQLConfiguration scheduledSQLConfiguration = generateConfig(); para crear una configuración para la tarea de SQL programado. La siguiente tabla describe los parámetros.

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

parameters

• Al configurar una tarea de SQL programado desde un Logstore hacia un Metricstore, también debe configurar los siguientes parámetros adicionales:

  Tabla 1. Log2MetricParameters

  Nombre del parámetro	Ejemplo	Descripción
  metricKeys	"[\"a\", \"b\", \"c\"]"	Columnas de métricas, correspondientes a las columnas de métricas en la configuración de SQL de la consola. Simple Log Service agrega datos según su sentencia de consulta y análisis. Puede seleccionar una o varias columnas de tipo numérico de los resultados de la consulta como columnas de métricas. Para obtener más información, consulte Metrics.
  labelKeys	"[\"d\", \"e\", \"f\"]"	Columnas de etiquetas, correspondientes a Labels en la configuración de SQL de la consola. Simple Log Service agrega datos según su sentencia de consulta y análisis. Puede seleccionar una o varias columnas de los resultados de la consulta como etiquetas. Para obtener más información, consulte Metrics.
  hashLabels	"[\"d\", \"f\"]"	Corresponde a Rehash en la configuración de SQL de la consola. Tras habilitar el interruptor Rehash, puede configurar hash columns para escribir los datos con el mismo valor de columna en un único shard. Esto mejora la localidad de los datos y la eficiencia de las consultas. Las hash columns disponibles dependen de sus resultados de consulta y análisis. Puede seleccionar una o varias columnas de los resultados como columnas hash. Por ejemplo, si establece hash columns en status, todos los datos con el mismo valor de status se escribirán en el mismo shard.
  addLabels	"[\"m\":\"h\", \"n\":\"i\"]"	Corresponde a Additional Labels en la configuración de SQL de la consola. Agregue etiquetas estáticas como pares clave-valor para identificar atributos de las métricas. Por ejemplo, establezca label_key en app y label_value en ingress-nginx.
  timeKey	time	Corresponde a Time Column en la configuración de SQL de la consola. Si selecciona una columna de tiempo de los resultados de la consulta (con valores de marca de tiempo Unix, como atime:1627025331), el sistema utilizará esa columna como marca de tiempo de la métrica. Si selecciona empty, el sistema usará la hora de inicio del rango de tiempo de la consulta como marca de tiempo de la métrica.

• Al configurar una tarea de SQL programado desde un Metricstore hacia otro Metricstore, también debe configurar los siguientes parámetros adicionales:

  Tabla 2. Metric2MetricParameters

  Nombre del parámetro	Ejemplo	Descripción
  metricName	my-metric	Introduzca un nuevo nombre de métrica si desea cambiarle el nombre. Para obtener más información, consulte Metrics. Importante Se recomienda cambiar el nombre únicamente al analizar una sola métrica. Si analiza varias métricas y les cambia el nombre, todas compartirán el mismo nombre nuevo.
  hashLabels	"{\"m\":\"h\", \"n\":\"i\"}"	Corresponde a Rehash en la configuración de SQL de la consola. Tras habilitar el interruptor Rehash, puede configurar hash columns para escribir los datos con el mismo valor de etiqueta en un único shard. Esto mejora la localidad de los datos y la eficiencia de las consultas. Las hash columns disponibles dependen de las etiquetas existentes en los datos de la métrica. Por ejemplo, si los datos de la métrica incluyen las etiquetas {"alert_id":"alert-1608815762-545495","alert_name":"Alert recovery closed","status":"inactive"}, las hash columns válidas son alert_id, alert_name y status. Si establece hash columns en status, todos los datos con el mismo valor de status se escribirán en el mismo shard.
  addLabels	"{\"m\":\"h\", \"n\":\"i\"}"	Corresponde a Additional Labels en la configuración de SQL de la consola. Agregue etiquetas estáticas como pares clave-valor para identificar atributos de las métricas. Por ejemplo, establezca label_key en app y label_value en ingress-nginx.

Parámetros de respuesta

Para consultar la descripción de los parámetros de respuesta, véase Create a scheduled SQL task.

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();
        }
    }
}