本文介绍通过Java SDK使用SQL独享版的代码示例。

前提条件

已安装最新版本的Java SDK。更多信息,请参见安装Java SDK

背景信息

日志服务提供SQL独享版,用于增强SQL分析能力,支持千亿行数据的计算。更多信息,请参见开启SQL独享版
日志服务提供executeLogStoreSql接口和executeProjectSql接口,帮助您更简单的使用SQL独享版。
  • executeLogStoreSql接口:在指定Logstore中使用SQL独享版。该接口支持的查询和分析语法兼容标准的SQL92语法,格式为查询语句|分析语句,其中分析语句采用标准的SQL92语法。
  • executeProjectSql接口:在指定Project中使用SQL独享版。该接口支持的查询和分析语法为标准的SQL92语法,即您的过滤条件和查询时间要写在SQL分析语句的WHERE语句中。
说明 如果您执行分析操作时,需要先过滤一部分数据再分析,建议您使用查询语句|分析语句语法,效率更高,即推荐使用executeLogStoreSql接口。

示例代码

代码示例如下,更多信息,请参见Aliyun Log Java SDK

import com.aliyun.openservices.log.Client;
import com.aliyun.openservices.log.common.LogContent;
import com.aliyun.openservices.log.common.LogItem;
import com.aliyun.openservices.log.common.QueriedLog;
import com.aliyun.openservices.log.exception.LogException;
import com.aliyun.openservices.log.response.GetLogsResponse;

import java.util.Date;

public class SlsSample {

    public static void main(String args[]) throws LogException,
            InterruptedException {
        //阿里云访问密钥AccessKey。更多信息,请参见访问密钥。阿里云账号AccessKey拥有所有API的访问权限,风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维。
        String accessId = "your_access_id";
        String accessKey = "your_access_key";
        //Project名称。
        String project = "aliyun-test-project";
        //日志服务的服务入口。更多信息,请参见服务入口。此处以杭州为例,其它地域请根据实际情况填写。
        String host = "cn-hangzhou.log.aliyuncs.com"; 
        //Logstore名称。
        String logStore = "aliyun-test-logstore";
        //Shard ID。
        int shardId = 0;
        
        //创建日志服务Client。
        Client client = new Client(host, accessId, accessKey);

        //在指定的Logstore内执行SQL分析。
        try {
            String sql = "* | select count(1)";
            int from = (int) (new Date().getTime() / 1000 - 600);
            int to = (int) (new Date().getTime() / 1000);
            GetLogsResponse logsResponse = client.executeLogstoreSql(project, logStore, 1627268185, 1627269085, "* | SELECT count(*)", true);
            System.out.println("Returned sql result count:" + logsResponse.GetCount());
            for (QueriedLog log : logsResponse.getLogs()) {
                LogItem item = log.GetLogItem();
                System.out.println("time : " + item.mLogTime);
                for (LogContent content : item.mContents) {
                    System.out.println(content.mKey + ":" + content.mValue);
                }
            }
            //打印计算结果的统计信息。
            //处理的日志行数。
            System.out.println("proccesedRows:" + logsResponse.getProcessedRow());
            //SQL分析执行的时长。
            System.out.println("elapsedMilli:" + logsResponse.getElapsedMilliSecond());
            //开启SQL独享版后,执行SQL分析所花费的CPU时间,单位为秒。SQL独享版按照CPU时间计费,更多信息,请参见计费项。
            System.out.println("cpuSec:" + logsResponse.getCpuSec());
            //开启SQL独享版后,执行SQL分析所使用的CPU核数。
            System.out.println("cpuCores:" + logsResponse.getCpuCores());
            System.out.println("requestId:" + logsResponse.GetRequestId());

        } catch (LogException e) {
            System.out.println("error code :" + e.GetErrorCode());
            System.out.println("error message :" + e.GetErrorMessage());
            throw e;
        }

        //在指定的Project内执行SQL分析。
        try {
            int now = (int) (new Date().getTime() / 1000);
            String sql = "select count(1) as cnt from xxx where __time__ > " + now;
            GetLogsResponse logsResponse = client.executeProjectSql(project, "select avg(latency),max(latency) ,count(1) as c from sample-logstore where status>200 and __time__>=1500975424 and __time__ < 1501035044 GROUP BY method ORDER BY c", true);
            System.out.println("Returned sql result count:" + logsResponse.GetCount());
            for (QueriedLog log : logsResponse.getLogs()) {
                LogItem item = log.GetLogItem();
                for (LogContent content : item.mContents) {
                    System.out.println(content.mKey + ":" + content.mValue);
                }
            }
            //打印计算结果的统计信息。
            //处理的日志行数。
            System.out.println("proccesedRows:" + logsResponse.getProcessedRow());
            //SQL分析执行的时长。
            System.out.println("elapsedMilli:" + logsResponse.getElapsedMilliSecond());
            //开启SQL独享版后,执行SQL分析所花费的CPU时间,单位为秒。SQL独享版按照CPU时间计费,更多信息,请参见计费项。
            System.out.println("cpuSec:" + logsResponse.getCpuSec());
            //开启SQL独享版后,执行SQL分析所使用的CPU核数。
            System.out.println("cpuCores:" + logsResponse.getCpuCores());
            System.out.println("requestId:" + logsResponse.GetRequestId());
        } catch (LogException e) {
            System.out.println("error code :" + e.GetErrorCode());
            System.out.println("error message :" + e.GetErrorMessage());
            throw e;
        }
    }
}
  • executeLogStoreSql接口
    调用executeLogStoreSql接口使用SQL独享版,格式为GetLogsResponse logsResponse = client.executeLogstoreSql(project, logStore, from, to, query, powerSql),各个参数说明如下表所示。
    参数名称 类型 是否必选 示例 说明
    project String 不涉及 Project名称。

    在创建Client时,已定义project,此处无需配置。

    logStore String 不涉及 Logstore名称。

    在创建Client时,已定义logStore,此处无需配置。

    from Long 1627268185 查询起始时间。Unix时间戳格式,表示从1970-1-1 00:00:00 UTC计算起的秒数。
    to Long 1627269085 查询结束时间点。Unix时间戳格式,表示从1970-1-1 00:00:00 UTC计算起的秒数。
    query String "* | SELECT count(*)" 日志服务查询和分析语句,格式为查询语句|分析语句。更多信息,请参见基础语法
    powerSql Boolean true 是否使用SQL独享版。更多信息,请参见开启SQL独享版
    • true:使用SQL独享版。
    • false(默认值):使用SQL普通版。
  • executeProjectSql接口
    调用executeProjectSql接口使用SQL独享版,格式为GetLogsResponse logsResponse = client.executeProjectSql(project, query, powerSql),各个参数说明如下表所示。
    参数名称 类型 是否必选 示例 说明
    project String 不涉及 Project名称。

    在创建Client时,已定义project,此处无需配置。

    query String "select avg(latency),max(latency) ,count(1) as c from sample-logstore where status>200 and __time__>=1500975424 and __time__ < 1501035044 GROUP BY method ORDER BY c" 标准的SQL语句,即您的过滤条件和查询时间需要写在SQL分析语句的WHERE语句中。
    powerSql Boolean true 是否使用SQL独享版。更多信息,请参见开启SQL独享版
    • true:使用SQL独享版。
    • false(默认值):使用SQL普通版。