通过Python SDK使用SQL独享版

接口说明

• execute_logstore_sql接口

  调用execute_logstore_sql接口使用SQL独享版，格式为res = client.execute_logstore_sql(project, logstoreName, from, to, query, powerSql)，各个参数说明如下表所示。

  参数名称	类型	是否必选	示例	说明
  project_name	String	是	不涉及	Project名称。 在创建Client时，已定义project_name，此处无需配置。
  logstore_name	String	是	不涉及	Logstore名称。 在创建Client时，已定义logstore_name，此处无需配置。
  from	Long	是	int(time.time() - 60)	查询起始时间。Unix时间戳格式，表示从1970-1-1 00:00:00 UTC计算起的秒数。
  to	Long	是	int(time.time())	查询结束时间点。Unix时间戳格式，表示从1970-1-1 00:00:00 UTC计算起的秒数。
  query	String	是	"* | select count(1) as cnt"	日志服务查询和分析语句，格式为查询语句|分析语句。更多信息，请参见基本语法。 日志服务默认返回100行结果，您也可以使用LIMIT子句指定返回结果的行数。更多信息，请参见LIMIT子句。
  powerSql	Boolean	否	True	是否使用SQL独享版。更多信息，请参见开启SQL独享版。 True：使用SQL独享版。 False（默认值）：使用SQL普通版。

• execute_project_sql接口

  调用execute_project_sql接口使用SQL独享版，格式为res = client.execute_project_sql(project, query, powerSql)，各个参数说明如下表所示。

  参数名称	类型	是否必选	示例	说明
  project_name	String	是	aliyun-test-project	Project名称。 在创建Client时，已定义project_name，此处无需配置。
  query	String	是	"select count(1) as cnt from %s where __time__ > %s" % (logstore_name, int(time.time() - 60))	标准的SQL语句，即您的查询语句要写在SQL分析语句的WHERE子句中。 日志服务默认返回100行结果，您也可以使用LIMIT子句指定返回结果的行数。更多信息，请参见LIMIT子句。
  powerSql	Boolean	否	True	是否使用SQL独享版。更多信息，请参见开启SQL独享版。 True：使用SQL独享版。 False（默认值）：使用SQL普通版。

代码示例

更多信息，请参见Aliyun Log Python SDK。

# encoding: utf-8
from __future__ import print_function

import time
import os
from aliyun.log import *


def main():
    # 日志服务的服务接入点。此处以杭州为例，其它地域请根据实际情况填写。
    endpoint = 'cn-hangzhou.log.aliyuncs.com'
    # 本示例从环境变量中获取AccessKey ID和AccessKey Secret。
    access_key_id = os.environ.get('ALIBABA_CLOUD_ACCESS_KEY_ID', '')
    access_key = os.environ.get('ALIBABA_CLOUD_ACCESS_KEY_SECRET', '')
    # Project名称。
    project_name = 'aliyun-test-project'
    # Logstore名称。
    logstore_name = 'aliyun-test-logstore'

    # 创建日志服务Client。
    client = LogClient(endpoint, access_key_id, access_key)

    # 在指定的Logstore内执行SQL分析。
    print("===sample_execute_logstore_sql===")
    res = client.execute_logstore_sql(project_name, logstore_name,
                                      int(time.time() - 60),int(time.time()),
                                      "* | select count(1) as cnt",True)
    # 打印计算结果的统计信息。
    res.log_print()
    # 处理的日志行数。
    print("processed_rows: %s" % res.get_processed_rows())
    # SQL分析执行的时长。
    print("elapsed_mills: %s" % res.get_elapsed_mills())
    # 是否使用了SQL语句。
    print("has_sql: %s" % res.get_has_sql())
    # 竖线（|）前的WHERE语句。
    print("where_query: %s" % res.get_where_query())
    # 竖线（|）后的SELECT聚合计算语句。
    print("agg_query: %s" % res.get_agg_query())
    # 开启SQL独享版后，执行SQL分析所花费的CPU时间，单位为秒。SQL独享版按照CPU时间计费，更多信息，请参见计费项。
    print("cpu_sec: %s" % res.get_cpu_sec())
    # 开启SQL独享版后，执行SQL分析所使用的CPU核数。
    print("cpu_cores: %s" % res.get_cpu_cores())


    # 在指定的Project内执行SQL分析。
    print("===sample_execute_project_sql===")
    res = client.execute_project_sql(project_name,"select count(1) as cnt from %s where __time__ > %s"
                                     % (logstore_name, int(time.time() - 60)),True)
    # 打印计算结果的统计信息。
    res.log_print()
    # 处理的日志行数。
    print("processed_rows: %s" % res.get_processed_rows())
    # SQL分析执行的时长。
    print("elapsed_mills: %s" % res.get_elapsed_mills())
    # 是否使用了SQL语句。
    print("has_sql: %s" % res.get_has_sql())
    # 竖线（|）前的WHERE语句。
    print("where_query: %s" % res.get_where_query())
    # 竖线（|）后的SELECT聚合计算语句。
    print("agg_query: %s" % res.get_agg_query())
    # 开启SQL独享版后，执行SQL分析所花费的CPU时间，单位为秒。SQL独享版按照CPU时间计费，更多信息，请参见计费项。
    print("cpu_sec: %s" % res.get_cpu_sec())
    # 开启SQL独享版后，执行SQL分析所使用的CPU核数。
    print("cpu_cores: %s" % res.get_cpu_cores())


if __name__ == '__main__':
    main()