代碼示例

代碼示例如下，更多信息，請(qǐng)參見Aliyun Log Node.js SDK。

const ALY = require('./node_modules/aliyun-sdk/index')

var sls = new ALY.SLS({
    // 本示例從環(huán)境變量中獲取AccessKey ID和AccessKey Secret。
    "accessKeyId": process.env.ALIBABA_CLOUD_ACCESS_KEY_ID,                  
    "secretAccessKey": process.env.ALIBABA_CLOUD_ACCESS_KEY_SECRET, 
    //本示例從環(huán)境變量中獲取SecurityToken。
    "securityToken" : process.env.ALIYUN_SECURITY_TOKEN,

    //日志服務(wù)的服務(wù)入口。此處以杭州為例，其它地域請(qǐng)根據(jù)實(shí)際情況填寫。
    endpoint: 'http://cn-hangzhou.log.aliyuncs.com',

    //日志服務(wù)API版本號(hào)，無需修改。
    apiVersion: '2015-06-01'

    //可選配置。
    //,httpOptions: {
    //    timeout: 1000  //1秒, 默認(rèn)沒有timeout。
    //} 
});
module.exports = sls;

//Project名稱。
var projectName = 'aliyun-test-project';
//Logstore名稱。
var logStoreName = 'aliyun-test-logstore';
//查詢的結(jié)束時(shí)間。
var to = Math.floor(new Date().getTime() / 1000);
//查詢的開始時(shí)間。
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);
            return;
        }   
        console.log(data);
        console.log('processed rows',data.headers['x-log-processed-rows']); //處理的日志行數(shù)。
        console.log('elapsed milli',data.headers['x-log-elapsed-millisecond']);  //SQL分析執(zhí)行的時(shí)長(zhǎng)。
        console.log('cores',data.headers['x-log-cpu-cores']);     //開啟SQL獨(dú)享版后，執(zhí)行SQL分析所使用的CPU核數(shù)。
        console.log('cpuSec',data.headers['x-log-cpu-sec']);      //開啟SQL獨(dú)享版后，執(zhí)行SQL分析所花費(fèi)的CPU時(shí)間，單位為秒。SQL獨(dú)享版按照CPU時(shí)間計(jì)費(fèi)，更多信息，請(qǐng)參見計(jì)費(fèi)項(xiàng)。
        console.log('success:', data);
    }); 
 sls.executeProjectSql({
    projectName: projectName,
    logStoreName: logStoreName,
    from: from,
    to: to,
    query: 'select count(0) from ' + logStoreName + ' where __time__ > '+ from +' and __time__ < '+to+'',
    powerSql:true
}, function(err, data) {
        if (err) {
            console.log('error:', err);
            return;
        }   
        console.log(data);
        console.log('processed rows',data.headers['x-log-processed-rows']); //處理的日志行數(shù)。
        console.log('elapsed milli',data.headers['x-log-elapsed-millisecond']);  //SQL分析執(zhí)行的時(shí)長(zhǎng)。
        console.log('cores',data.headers['x-log-cpu-cores']);     //開啟SQL獨(dú)享版后，執(zhí)行SQL分析所使用的CPU核數(shù)。
        console.log('cpuSec',data.headers['x-log-cpu-sec']);      //開啟SQL獨(dú)享版后，執(zhí)行SQL分析所花費(fèi)的CPU時(shí)間，單位為秒。SQL獨(dú)享版按照CPU時(shí)間計(jì)費(fèi)，更多信息，請(qǐng)參見計(jì)費(fèi)項(xiàng)。
        console.log('success:', data);
    
    });            

sls.executeLogStoreSql({
        projectName: projectName,
        logStoreName: logStoreName,
        from: from,
        to: to, 
        query:  '*|select count(method)',
        powerSql:true 
    })

sls.executeProjectSql({
    projectName: projectName,
    query: 'select count(method) from sls_operation_log where __time__ > to_unixtime(now()) - 300 and __time__ < to_unixtime(now())',
    powerSql:true
})