代碼示例

代碼示例如下，更多信息，請參見Aliyun Log C++ SDK。

#include <cstdlib>

// 日志服務的服務接入點。此處以杭州為例，其它地域請根據實際情況填寫。
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";

// 創建日志服務Client。
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(*)"	日志服務查詢和分析語句，格式為查詢語句|分析語句。更多信息，請參見基礎語法。 日志服務默認返回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語句中。 日志服務默認返回100行結果，您也可以使用LIMIT子句指定返回結果的行數。更多信息，請參見LIMIT子句。
  powerSql	Boolean	否	true	是否使用SQL獨享版。更多信息，請參見開啟SQL獨享版。 true：使用SQL獨享版。 false（默認值）：使用SQL普通版。