Simple Log Service:Dedicated SQL com o SDK para C++

O Simple Log Service fornece as operações ExecuteLogStoreSql e ExecuteProjectSql para o Dedicated SQL.

• ExecuteLogStoreSql: executa uma consulta Dedicated SQL em um Logstore específico. Esta operação aceita sintaxe de consulta e análise compatível com o padrão SQL-92. O formato é search statement|analytic statement, em que a instrução analítica segue a sintaxe padrão SQL-92.

• ExecuteProjectSql: executa uma consulta Dedicated SQL em um projeto específico. Esta operação aceita a sintaxe SQL-92. Especifique uma condição de filtro e um intervalo de tempo na cláusula WHERE da instrução SQL.

#include <cstdlib>

// Simple Log Service endpoint. Replace with your actual endpoint.
std::string endpoint = "cn-hangzhou.log.aliyuncs.com";
// Retrieve the AccessKey ID and AccessKey Secret from environment variables.
string accessId = (string)getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
string accessKey = (string)getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");
// Project name.
std::string project = "your_project_name";
// Logstore name.
std::string logStore = "your_logstore";

// Create a Simple Log Service client.
LOGClient client(endpoint, accessId, accessKey);

// Run a SQL query in the specified Logstore.
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);
    // Print the query result statistics.
    std::cout << "Returned sql result:" << std::endl
              << "count:" << logsResponse.result.logline << std::endl          // Number of rows in the result.
              << "processed rows:" << logsResponse.processedRows << std::endl  // Number of log rows processed.
              << "elapsed milli:" << logsResponse.elapsedMilli << std::endl    // SQL query execution duration.
              << "cpu sec:" << logsResponse.cpuSec << std::endl                // CPU time (seconds) for Dedicated SQL. Billing is based on this value. For more information, see billable items.
              << "cpu core:" << logsResponse.cpuCore << std::endl;             // Number of CPU cores used for the Dedicated SQL query.
    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;
}

// Run a SQL query in the specified project.
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);

    // Print the query result statistics.
    std::cout << "Returned sql result:" << std::endl
              << "count:" << logsResponse.result.logline << std::endl          // Number of rows in the result.
              << "processed rows:" << logsResponse.processedRows << std::endl  // Number of log rows processed.
              << "elapsed milli:" << logsResponse.elapsedMilli << std::endl    // SQL query execution duration.
              << "cpu sec:" << logsResponse.cpuSec << std::endl                // CPU time (seconds) for Dedicated SQL. Billing is based on this value. For more information, see billable items.
              << "cpu core:" << logsResponse.cpuCore << std::endl;             // Number of CPU cores used for the Dedicated SQL query.
    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;
}