Simple Log Service:Uso de la función Dedicated SQL con Simple Log Service SDK for PHP

Simple Log Service proporciona las siguientes operaciones para la función Dedicated SQL:

• Aliyun_Log_Models_LogStoreSqlRequest: ejecuta consultas de Dedicated SQL en un logstore específico. Esta operación admite la sintaxis estándar SQL-92. La instrucción de consulta utiliza el formato Search statement|Analytic statement, donde la instrucción analítica sigue la sintaxis estándar SQL-92.

• Aliyun_Log_Models_ProjectSqlRequest: ejecuta consultas de Dedicated SQL en un proyecto específico. Esta operación admite la sintaxis estándar SQL-92. Debe especificar una condición de filtro y un intervalo de tiempo en la cláusula WHERE de la instrucción SQL.

<?PHP
require_once realpath(dirname(__FILE__) . './aliyun-log-php-sdk-master/Log_Autoload.php');
class test
{

    public static function main()
    {
        // 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 = 'cn-hangzhou.log.aliyuncs.com';
        // In this example, the AccessKey ID and AccessKey secret are obtained from environment variables.
        $accessKeyId = getenv('ALIBABA_CLOUD_ACCESS_KEY_ID');
        $accessKey = getenv('ALIBABA_CLOUD_ACCESS_KEY_SECRET');
        // The name of the project. 
        $project = 'aliyun-test-project';
        // The name of the Logstore. 
        $logstore = 'aliyun-test-logstore';
        // The Security Token Service (STS) token. 
        $token = '';
        // Create a Simple Log Service client. 
        $client = new Aliyun_Log_Client($endpoint, $accessKeyId, $accessKey, $token);

        // Execute an SQL statement in the specified Logstore.  
        $from = time() - 3600;
        $to = time();
        $query = "* | select count(0)";
        $topic = "";
        $request = new Aliyun_Log_Models_LogStoreSqlRequest($project, $logstore, $from, $to, $query, true);
        try {
            $response = $client->executeLogStoreSql($request);
            foreach ($response->getLogs() as $log) {
                print $log->getTime() . "\t";
                foreach ($log->getContents() as $key => $value) {
                    print $key . ":" . $value . "\t";
                }
                print "\n";
            }
            // Display the statistics about the analysis results. 
            // The number of lines of log data that is processed. 
            print "proccesedRows:" . $response->getProcessedRows() . "\n";
            // The time that is required to execute the SQL statement. 
            print "elapsedMilli:" . $response->getElapsedMilli() . "\n";
            // 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.
            print "cpuSec:" . $response->getCpuSec() . "\n";
            // The number of CPU cores that are used to execute the SQL statement after the Dedicated SQL feature is enabled.
            print "cpuCores:" . $response->getCpuCores() . "\n";

        } catch (Aliyun_Log_Exception $ex) {
            logVarDump($ex);
        } catch (Exception $ex) {
            logVarDump($ex);
        }

        // Execute an SQL statement in the specified project. 
        $query = "select count(0) from gs-api where __time__ > to_unixtime(now()) - 300 and __time__ < to_unixtime(now())";
        $request = new Aliyun_Log_Models_ProjectSqlRequest($project, $query, True);
        try {
            $response = $client->executeProjectSql($request);
            #$response = $client->getProjectLogs($request);
            foreach ($response->getLogs() as $log) {
                print $log->getTime() . "\t";
                foreach ($log->getContents() as $key => $value) {
                    print $key . ":" . $value . "\t";
                }
                print "\n";
            }
            // Display the statistics about the analysis results. 
            // The number of lines of log data that is processed.
            print "proccesedRows:" . $response->getProcessedRows() . "\n";
            // The time that is required to execute the SQL statement. 
            print "elapsedMilli:" . $response->getElapsedMilli() . "\n";
            // 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.
            print "cpuSec:" . $response->getCpuSec() . "\n";
            // The number of CPU cores that are used to execute the SQL statement after the Dedicated SQL feature is enabled.
            print "cpuCores:" . $response->getCpuCores() . "\n";
            print "requestId:" . $response->getRequestId() . "\n";

        } catch (Aliyun_Log_Exception $ex) {
            logVarDump($ex);
        } catch (Exception $ex) {
            logVarDump($ex);
        }
    }
}
test::main();