Simple Log Service:Simple Log Service SDK for Node.jsを使用して専用SQL機能を使用する

サンプルコード

次のサンプルコードは、Dedicated SQL機能の使用方法の例を示しています。 詳細については、「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
})