This topic describes how to use the SDK for Python that is provided by Database Autonomy Service to query slow query logs of an ApsaraDB for Redis instance.

Call an API operation by using the SDK for Python

import json

from alibabacloud_r_kvstore20150101 import models as r_kvstore_20150101_models
from alibabacloud_r_kvstore20150101.client import Client as R_kvstore20150101Client
from alibabacloud_tea_openapi import models as open_api_models
from aliyunsdkcore.client import AcsClient
from aliyunsdkcore.request import CommonRequest
from django.conf import settings

class RedisClient:
def __init__(
access_key_id: str = settings.ALIYUN['ACCESS_KEY_ID'],
access_key_secret: str = settings.ALIYUN['ACCESS_KEY_SECRET'],
region_id: str = settings.ALIYUN['REGION_ID']
self.region_id = region_id
config = open_api_models.Config(
# Specifies the AccessKey ID of your Alibaba Cloud account.
# Specifies the AccessKey secret of your Alibaba Cloud account.
# Specifies the endpoint that is used to connect to your ApsaraDB for Redis instance.
config.endpoint = ''
self.client = R_kvstore20150101Client(config)

def get_hot_big_keys(
self, instance_id
) -> dict:
Queries hot keys and big keys in real time.
client = AcsClient(settings.ALIYUN['ACCESS_KEY_ID'], settings.ALIYUN['ACCESS_KEY_SECRET'], 'cn-shanghai')
request = CommonRequest()
request.add_query_param('InstanceId', instance_id)
response = client.do_action_with_exception(request)
data = {}
if response:
data = json.loads(response).get('Data', {})
except (Exception, ):
return {}
return data
return data

def describe_slow_log_records(
self, instance_id, start_time: str = '', end_time: str = '',
page_size: int = 100, page_number: int = 1
) -> dict:
Queries slow query logs of the ApsaraDB for Redis instance.
client = self.client
describe_available_slow_record_request = r_kvstore_20150101_models.DescribeSlowLogRecordsRequest(
start_time=start_time, end_time=end_time, instance_id=instance_id, page_size=page_size,
data = client.describe_slow_log_records(describe_available_slow_record_request)
data = data.to_map()
return data.get('body', {})