通过Python SDK使用SQL独享版

使用SQL独享版的代码示例

代码示例如下，更多信息，请参见Aliyun Log Python SDK。

# encoding: utf-8
from __future__ import print_function

import time

from aliyun.log import *


def main():
    #日志服务的服务入口。更多信息，请参见服务入口。此处以杭州为例，其它地域请根据实际情况填写。
    endpoint = 'cn-hangzhou.log.aliyuncs.com'
    #阿里云访问密钥AccessKey。更多信息，请参见访问密钥。阿里云账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维。
    access_key_id = 'your_access_id'
    access_key = 'your_access_key'
    #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()

• 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普通版。

创建、更新和获取SQL Instance的代码示例

开启SQL独享版后，您还可以创建SQL Instance，用于指定SQL独享版CU数。日志服务通过SQL独享版的CU数来控制SQL独享版的费用。代码示例如下，更多信息，请参见Aliyun Log Python SDK。

# encoding: utf-8
from __future__ import print_function

import time

from aliyun.log import *

def main():
    #日志服务的服务入口。更多信息，请参见服务入口。此处以杭州为例，其它地域请根据实际情况填写。
    endpoint = 'cn-hangzhou.log.aliyuncs.com'
    #阿里云访问密钥AccessKey。更多信息，请参见访问密钥。阿里云账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维。
    access_key_id = 'your_access_id'
    access_key = 'your_access_key'
    #Project名称。
    project_name = 'aliyun-test-project'
    #Logstore名称。
    logstore_name = 'aliyun-test-logstore'

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

    #创建SQL Instance配置，支持配置SQL独享版CU数。CU数的取值范围为0~1000。
    print("===sample_create_sql_instance===")
    res = client.create_sql_instance(project_name, 500)
    res.log_print()

    #更新SQL Instance配置，支持更新SQL独享版CU数。CU数的取值范围为0~1000。
    print("===sample_update_sql_instance===")
    res = client.update_sql_instance(project_name, 800)
    res.log_print()

    #获取SQL Instance配置。
    print("===sample_list_sql_instance===")
    res = client.list_sql_instance(project_name)
    res.log_print()


if __name__ == '__main__':
    main()