全部產品
Search
文件中心

Simple Log Service:通過C++ SDK使用SQL獨享版

更新時間:Jul 23, 2024

本文介紹通過C++ SDK使用SQL獨享版的程式碼範例。

前提條件

  • 已建立RAM使用者並完成授權。具體操作,請參見建立RAM使用者並完成授權

  • 已配置環境變數ALIBABA_CLOUD_ACCESS_KEY_IDALIBABA_CLOUD_ACCESS_KEY_SECRET。具體操作,請參見在Linux、macOS和Windows系統配置環境變數

    重要
    • 阿里雲帳號的AccessKey擁有所有API的存取權限,建議您使用RAM使用者的AccessKey進行API訪問或日常營運。

    • 強烈建議不要把AccessKey ID和AccessKey Secret儲存到工程代碼裡,否則可能導致AccessKey泄露,威脅您帳號下所有資源的安全。

  • 已安裝最新版本的C++ SDK。具體操作,請參見Aliyun Log C++ SDK

背景資訊

Log Service提供SQL獨享版,用於增強SQL分析能力,支援千億行資料的計算。更多資訊,請參見開啟SQL獨享版

Log Service提供ExecuteLogStoreSql介面和ExecuteProjectSql介面,協助您更簡單的使用SQL獨享版。

  • ExecuteLogStoreSql介面:在指定Logstore中使用SQL獨享版。該介面支援的查詢和分析文法相容標準的SQL92文法,格式為查詢語句|分析語句,其中分析語句採用標準的SQL92文法。

  • ExecuteProjectSql介面:在指定Project中使用SQL獨享版。該介面支援的查詢和分析文法為標準的SQL92文法,即您的過濾條件和查詢時間要寫在SQL分析語句的WHERE語句中。

說明

如果您執行分析操作時,需要先過濾一部分資料再分析,建議您使用查詢語句|分析語句文法,效率更高,即推薦使用ExecuteLogStoreSql介面。

程式碼範例

程式碼範例如下,更多資訊,請參見Aliyun Log C++ SDK

#include <cstdlib>

// Log Service的服務存取點。此處以杭州為例,其它地區請根據實際情況填寫。
std::string endpoint = "cn-hangzhou.log.aliyuncs.com";
// 本樣本從環境變數中擷取AccessKey ID和AccessKey Secret。
string accessId = (string)getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
string accessKey = (string)getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");
// Project名稱。
std::string project = "your_project_name";
// Logstore名稱。
std::string logStore = "your_logstore";

// 建立Log ServiceClient。
LOGClient client(endpoint, accessId, accessKey);

// 在指定的Logstore內執行SQL分析。
try
{
    std::string sql = "* | select count(1)";
    int from = time(NULL) - 600;
    int to = from + 600;
    LogStoreSqlResponse logsResponse = client.ExecuteLogStoreSql(project, logStore,
                                                                 1627268185,1627269085,"* | SELECT count(*)",true);
    // 列印計算結果的統計資訊。
    std::cout << "Returned sql result:" << std::endl
              << "count:" << logsResponse.result.logline << std::endl          //計算結果中的行數。
              << "processed rows:" << logsResponse.processedRows << std::endl  //處理的日誌行數。
              << "elapsed milli:" << logsResponse.elapsedMilli << std::endl    //SQL分析執行的時間長度。
              << "cpu sec:" << logsResponse.cpuSec << std::endl                //開啟SQL獨享版後,執行SQL分析所花費的CPU時間,單位為秒。SQL獨享版按照CPU時間計費,更多資訊,請參見計費項目。
              << "cpu core:" << logsResponse.cpuCore << std::endl;             //開啟SQL獨享版後,執行SQL分析所使用的CPU核心數。
    for (std::vector<LogItem>::const_iterator itr = logsResponse.result.logdatas.begin();
         itr != logsResponse.result.logdatas.end(); ++itr)
    {
        const LogItem &item = *itr;
        for (std::vector<std::pair<std::string, std::string>>::const_iterator itr_data = item.data.begin();
             itr_data != item.data.end(); ++itr_data)
        {
            std::cout << itr_data->first << ":" << itr_data->second;
        }
    }
}
catch (LOGException &e)
{
    std::cout << "error code :" << e.GetErrorCode() << std::endl;
    std::cout << "error message :" << e.GetMessage() << std::endl;
    throw e;
}

// 在指定的Project內執行SQL分析。
try
{
    int now = time(NULL);
    std::string sql = "select count(1) as cnt from xxx where __time__ > " + to_string(now);
    ProjectSqlResponse 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);
    
    // 列印計算結果的統計資訊。
    std::cout << "Returned sql result:" << std::endl       
              << "count:" << logsResponse.result.logline << std::endl          //計算結果中的行數。
              << "processed rows:" << logsResponse.processedRows << std::endl  //處理的日誌行數。
              << "elapsed milli:" << logsResponse.elapsedMilli << std::endl    //SQL分析執行的時間長度。
              << "cpu sec:" << logsResponse.cpuSec << std::endl                //開啟SQL獨享版後,執行SQL分析所花費的CPU時間,單位為秒。SQL獨享版按照CPU時間計費,更多資訊,請參見計費項目。
              << "cpu core:" << logsResponse.cpuCore << std::endl;             //開啟SQL獨享版後,執行SQL分析所使用的CPU核心數。
    for (std::vector<LogItem>::const_iterator itr = logsResponse.result.logdatas.begin(); itr != logsResponse.result.logdatas.end(); ++itr)
    {
        const LogItem &item = *itr;
        for (std::vector<std::pair<std::string, std::string>>::const_iterator itr_data = item.data.begin();
             itr_data != item.data.end(); ++itr_data)
        {
            std::cout << itr_data->first << ":" << itr_data->second;
        }
    }
}
catch (LOGException &e)
{
    std::cout << "error code :" << e.GetErrorCode() << std::endl;
    std::cout << "error message :" << e.GetMessage() << std::endl;
    throw e;
}
  • ExecuteLogStoreSql介面

    調用ExecuteLogStoreSql介面使用SQL獨享版,格式為LogStoreSqlResponse 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(*)"

    Log Service查詢和分析語句,格式為查詢語句|分析語句。更多資訊,請參見基礎文法

    Log Service預設返回100行結果,您也可以使用LIMIT子句指定返回結果的行數。更多資訊,請參見LIMIT子句

    powerSql

    Boolean

    true

    是否使用SQL獨享版。更多資訊,請參見開啟SQL獨享版

    • true:使用SQL獨享版。

    • false(預設值):使用SQL普通版。

  • ExecuteProjectSql介面

    調用ExecuteProjectSql介面使用SQL獨享版,格式為ProjectSqlResponse 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語句中。

    Log Service預設返回100行結果,您也可以使用LIMIT子句指定返回結果的行數。更多資訊,請參見LIMIT子句

    powerSql

    Boolean

    true

    是否使用SQL獨享版。更多資訊,請參見開啟SQL獨享版

    • true:使用SQL獨享版。

    • false(預設值):使用SQL普通版。