Simple Log Service:Use Simple Log Service SDK for Node.js to use the Dedicated SQL feature

Sample code

The following sample code provides an example on how to use the Dedicated SQL feature. For more information, see Alibaba Cloud Simple Log Service SDK for Node.js.

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

var sls = new ALY.SLS({
    // In this example, the AccessKey ID and AccessKey secret are obtained from environment variables. 
    "accessKeyId": process.env.ALIBABA_CLOUD_ACCESS_KEY_ID,                  
    "secretAccessKey": process.env.ALIBABA_CLOUD_ACCESS_KEY_SECRET, 
    // In this example, the security token is obtained from environment variables. 
    "securityToken" : process.env.ALIYUN_SECURITY_TOKEN,

    // The Simple Log Service endpoint. In this example, the Simple Log Service endpoint for the China (Hangzhou) region is used. Replace the parameter value with the actual endpoint. 
    endpoint: 'http://cn-hangzhou.log.aliyuncs.com',

    // The version number of Simple Log Service API. You do not need to modify the parameter. 
    apiVersion: '2015-06-01'

    // Optional. 
    //,httpOptions: {
    //    timeout: 1000  // You can set the parameter to 1 second. By default, the timeout parameter is not specified. 
    //} 
});
module.exports = sls;

// The name of the project. 
var projectName = 'aliyun-test-project';
// The name of the Logstore. 
var logStoreName = 'aliyun-test-logstore';
// The end of the time range to query. 
var to = Math.floor(new Date().getTime() / 1000);
// The beginning of the time range to query. 
var from = to - 900; // The value 900 indicates that the query time range is 15 minutes. 

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']); // The number of rows of log data that is processed. 
        console.log('elapsed milli',data.headers['x-log-elapsed-millisecond']);  // The time that is consumed to execute the SQL statement. 
        console.log('cores',data.headers['x-log-cpu-cores']);     // The number of CPU cores that are used to execute the SQL statement after the Dedicated SQL feature is enabled. 
        console.log('cpuSec',data.headers['x-log-cpu-sec']);      // The CPU time that is consumed to execute the SQL statement after the Dedicated SQL feature is enabled. Unit: seconds. You are charged for the Dedicated SQL feature based on the CPU time. For more information, see the topics that are related to billable items. 
        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']); // The number of rows of log data that is processed. 
        console.log('elapsed milli',data.headers['x-log-elapsed-millisecond']);  // The time that is consumed to execute the SQL statement. 
        console.log('cores',data.headers['x-log-cpu-cores']);     // The number of CPU cores that are used to execute the SQL statement after the Dedicated SQL feature is enabled. 
        console.log('cpuSec',data.headers['x-log-cpu-sec']);      // The CPU time that is consumed to execute the SQL statement after the Dedicated SQL feature is enabled. Unit: seconds. You are charged for the Dedicated SQL feature based on the CPU time. For more information, see the topics that are related to billable items. 
        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
})