本文介紹通過PHP SDK使用SQL獨享版的代碼示例。
前提條件
已創建RAM用戶并完成授權。具體操作,請參見創建RAM用戶并完成授權。
已配置環境變量ALIBABA_CLOUD_ACCESS_KEY_ID和ALIBABA_CLOUD_ACCESS_KEY_SECRET。具體操作,請參見在Linux、macOS和Windows系統配置環境變量。
重要阿里云賬號的AccessKey擁有所有API的訪問權限,建議您使用RAM用戶的AccessKey進行API訪問或日常運維。
強烈建議不要把AccessKey ID和AccessKey Secret保存到工程代碼里,否則可能導致AccessKey泄露,威脅您賬號下所有資源的安全。
已完成PHP SDK安裝。更多信息,請參見安裝PHP SDK。
背景信息
日志服務提供SQL獨享版,用于增強SQL分析能力,支持千億行數據的計算。更多信息,請參見開啟SQL獨享版。
日志服務提供Aliyun_Log_Models_LogStoreSqlRequest接口和Aliyun_Log_Models_ProjectSqlRequest接口,幫助您更簡單的使用SQL獨享版。
Aliyun_Log_Models_LogStoreSqlRequest接口:在指定Logstore中使用SQL獨享版。該接口支持的查詢和分析語法兼容標準的SQL92語法,格式為
查詢語句|分析語句
,其中分析語句采用標準的SQL92語法。Aliyun_Log_Models_ProjectSqlRequest接口:在指定Project中使用SQL獨享版。該接口支持的查詢和分析語法為標準的SQL92語法,即您的過濾條件和查詢時間要寫在SQL分析語句的WHERE語句中。
如果您執行分析操作時,需要先過濾一部分數據再分析,建議您使用查詢語句|分析語句
語法,效率更高,即推薦使用Aliyun_Log_Models_LogStoreSqlRequest接口。
代碼示例
代碼示例如下,更多信息,請參見Aliyun Log PHP SDK。
<?PHP
require_once realpath(dirname(__FILE__) . './aliyun-log-php-sdk-master/Log_Autoload.php');
class test
{
public static function main()
{
// 日志服務的服務入口。此處以杭州為例,其它地域請根據實際情況填寫。
$endpoint = 'cn-hangzhou.log.aliyuncs.com';
// 本示例從環境變量中獲取AccessKey ID和AccessKey Secret。
$accessKeyId = getenv('ALIBABA_CLOUD_ACCESS_KEY_ID');
$accessKey = getenv('ALIBABA_CLOUD_ACCESS_KEY_SECRET');
// Project名稱。
$project = 'aliyun-test-project';
// Logstore名稱。
$logstore = 'aliyun-test-logstore';
// STS token。
$token = '';
// 創建日志服務Client。
$client = new Aliyun_Log_Client($endpoint, $accessKeyId, $accessKey, $token);
// 在指定的Logstore內執行SQL分析。
$from = time() - 3600;
$to = time();
$query = "* | select count(0)";
$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";
}
// 打印計算結果的統計信息。
// 處理的日志行數。
print "proccesedRows:" . $response->getProcessedRows() . "\n";
// SQL分析執行的時長。
print "elapsedMilli:" . $response->getElapsedMilli() . "\n";
// 開啟SQL獨享版后,執行SQL分析所花費的CPU時間,單位為秒。SQL獨享版按照CPU時間計費,更多信息,請參見計費項。
print "cpuSec:" . $response->getCpuSec() . "\n";
// 開啟SQL獨享版后,執行SQL分析所使用的CPU核數。
print "cpuCores:" . $response->getCpuCores() . "\n";
} catch (Aliyun_Log_Exception $ex) {
logVarDump($ex);
} catch (Exception $ex) {
logVarDump($ex);
}
// 在指定的Project內執行SQL分析。
$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";
}
// 打印計算結果的統計信息。
// 處理的日志行數。
print "proccesedRows:" . $response->getProcessedRows() . "\n";
// SQL分析執行的時長。
print "elapsedMilli:" . $response->getElapsedMilli() . "\n";
// 開啟SQL獨享版后,執行SQL分析所花費的CPU時間,單位為秒。SQL獨享版按照CPU時間計費,更多信息,請參見計費項。
print "cpuSec:" . $response->getCpuSec() . "\n";
// 開啟SQL獨享版后,執行SQL分析所使用的CPU核數。
print "cpuCores:" . $response->getCpuCores() . "\n";
print "requestId:" . $response->getRequestId() . "\n";
} catch (Aliyun_Log_Exception $ex) {
logVarDump($ex);
} catch (Exception $ex) {
logVarDump($ex);
}
}
}
test::main();
Aliyun_Log_Models_LogStoreSqlRequest接口
調用Aliyun_Log_Models_LogStoreSqlRequest接口使用SQL獨享版,接口格式為:
$from = time()-3600; $to = time(); $query = "* | select count(0)"; $request = new Aliyun_Log_Models_LogStoreSqlRequest($project,$logstore,$from,$to,$query,$powerSql);
各個參數說明如下表所示。
參數名稱
類型
是否必選
示例
說明
$project
String
是
不涉及
Project名稱。
在創建Client時,已定義$project,此處無需配置。
$logstore
String
是
不涉及
Logstore名稱。
在創建Client時,已定義$logstore,此處無需配置。
$from
Long
是
time()-3600
查詢起始時間。Unix時間戳格式,表示從1970-1-1 00:00:00 UTC計算起的秒數。
$to
Long
是
time()
查詢結束時間點。Unix時間戳格式,表示從1970-1-1 00:00:00 UTC計算起的秒數。
$query
String
是
"* | select count(method)"
日志服務查詢和分析語句,格式為
查詢語句|分析語句
。更多信息,請參見基礎語法。日志服務默認返回100行結果,您也可以使用LIMIT子句指定返回結果的行數。更多信息,請參見LIMIT子句。
$powerSql
Boolean
否
true
是否使用SQL獨享版。更多信息,請參見開啟SQL獨享版。
true:使用SQL獨享版。
false(默認值):使用SQL普通版。
Aliyun_Log_Models_ProjectSqlRequest接口
調用Aliyun_Log_Models_ProjectSqlRequest接口使用SQL獨享版,接口格式如下:
$query = "select count(0) from sls_operation_log where __time__ > to_unixtime(now()) - 300 and __time__ < to_unixtime(now())"; $request = new Aliyun_Log_Models_ProjectSqlRequest($project,$query,$powerSql);
各個參數說明如下表所示。
參數名稱
類型
是否必選
示例
說明
$project
String
是
不涉及
Project名稱。
在創建Client時,已定義$project,此處無需配置。
$query
String
是
" select count(method) from sls_operation_log where __time__ > to_unixtime(now()) - 300 and __time__ < to_unixtime(now())"
標準的SQL語句,即您的過濾條件和查詢時間要寫在SQL分析語句的WHERE語句中。
日志服務默認返回100行結果,您也可以使用LIMIT子句指定返回結果的行數。更多信息,請參見LIMIT子句。
$powerSql
Boolean
否
true
是否使用SQL獨享版。更多信息,請參見開啟SQL獨享版。
true:使用SQL獨享版。
false(默認值):使用SQL普通版。