本文介绍通过Node.js SDK使用SQL独享版的代码示例。
前提条件
背景信息
日志服务提供executeLogStoreSql接口和executeProjectSql接口,帮助您更简单的使用SQL独享版。
- executeLogStoreSql接口:在指定Logstore中使用SQL独享版。该接口支持的查询和分析语法兼容标准的SQL92语法,格式为
查询语句|分析语句
,其中分析语句采用标准的SQL92语法。 - executeProjectSql接口:在指定Project中使用SQL独享版。该接口支持的查询和分析语法为标准的SQL92语法,即您的过滤条件和查询时间要写在SQL分析语句的WHERE语句中。
说明 如果您执行分析操作时,需要先过滤一部分数据再分析,建议您使用
查询语句|分析语句
语法,效率更高,即推荐使用executeLogStoreSql接口。
代码示例
代码示例如下,更多信息,请参见Aliyun Log Node.js SDK。
var ALY = require('../../index.js');
var sls = new ALY.SLS({
//阿里云访问密钥AccessKey。更多信息,请参见访问密钥。阿里云账号AccessKey拥有所有API的访问权限,风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维。
"accessKeyId": "your_access_id",
"secretAccessKey": "your_access_key",
//STS token。更多信息,请参见AssumeRole。
"securityToken" :"your_token",
//日志服务的服务入口。更多信息,请参见服务入口。此处以杭州为例,其它地域请根据实际情况填写。
endpoint: 'http://cn-hangzhou.log.aliyuncs.com',
//日志服务API版本号,无需修改。
apiVersion: '2015-06-01'
//可选配置。
//,httpOptions: {
// timeout: 1000 //1秒, 默认没有timeout。
//}
});
module.exports = sls;
//Project名称。
var projectName = 'aliyun-test-project';
//Logstore名称。
var logStoreName = 'aliyun-test-logstore';
//查询的结束时间。
var to = Math.floor(new Date().getTime() / 1000);
//查询的开始时间。
var from = to - 900; //15分钟。
sls.executeLogStoreSql({
projectName: projectName,
logStoreName: logStoreName,
from: from,
to: to,
query: '*|select count(method)',
powerSql:true
}, function(err, data) {
if (err) {
console.log('error:', err);
reject(err);
return;
}
console.log(data);
console.log('processed rows',data.headers['x-log-processed-rows']); //处理的日志行数。
console.log('elapsed milli',data.headers['x-log-elapsed-millisecond']); //SQL分析执行的时长。
console.log('cores',data.headers['x-log-cpu-cores']); //开启SQL独享版后,执行SQL分析所使用的CPU核数。
console.log('cpuSec',data.headers['x-log-cpu-sec']); //开启SQL独享版后,执行SQL分析所花费的CPU时间,单位为秒。SQL独享版按照CPU时间计费,更多信息,请参见计费项。
// console.log('success:', data);
resolve(data);
});
调用executeLogStoreSql接口使用SQL独享版,接口格式如下:
sls.executeLogStoreSql({
projectName: projectName,
logStoreName: logStoreName,
from: from,
to: to,
query: '*|select count(method)',
powerSql:true
})
各个参数说明如下表所示。
参数名称 | 类型 | 是否必选 | 示例 | 说明 |
---|---|---|---|---|
projectName | String | 是 | 不涉及 | Project名称。
在配置基本信息时,已定义projectName,此处无需配置。 |
logStoreName | String | 是 | 不涉及 | Logstore名称。
在配置基本信息时,已定义logStoreName,此处无需配置。 |
from | Long | 是 | 不涉及 | 查询的起始时间。Unix时间戳格式,表示从1970-1-1 00:00:00 UTC计算起的秒数。
在配置基本信息时,已定义from,此处无需配置。 |
to | Long | 是 | 不涉及 | 查询的结束时间。Unix时间戳格式,表示从1970-1-1 00:00:00 UTC计算起的秒数。
在配置基本信息时,已定义to,此处无需配置。 |
query | String | 是 | '*|select count(method)' |
日志服务查询和分析语句,格式为查询语句|分析语句 。更多信息,请参见基础语法。
日志服务默认返回100行结果,您也可以使用LIMIT子句指定返回结果的行数。更多信息,请参见LIMIT子句。 |
powerSql | Boolean | 否 | true | 是否使用SQL独享版。更多信息,请参见开启SQL独享版。
|