-
Notifications
You must be signed in to change notification settings - Fork 641
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
89 changed files
with
8,991 additions
and
1,283 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,3 +1,3 @@ | ||
| #!/bin/bash | ||
|
|
||
| python3 manage.py runserver 0.0.0.0:9123 | ||
| python3 manage.py runserver 0.0.0.0:9123 --insecure |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,4 +1,19 @@ | ||
| certifi==2017.7.27.1 | ||
| chardet==3.0.4 | ||
| crypto==1.4.1 | ||
| Django==1.8.17 | ||
| django-auth-ldap==1.3.0 | ||
| django-admin-bootstrapped==2.5.7 | ||
| idna==2.6 | ||
| Naked==0.1.31 | ||
| pycrypto==2.6.1 | ||
| PyMySQL==0.7.11 | ||
| PyYAML==3.12 | ||
| requests==2.18.4 | ||
| shellescape==3.4.1 | ||
| simplejson==3.13.2 | ||
| urllib3==1.22 | ||
| django-admin-bootstrapped==2.5.7 | ||
| gunicorn==19.7.1 | ||
| django-auth-ldap==1.3.0 | ||
| aliyun-python-sdk-core==2.3.5 | ||
| aliyun-python-sdk-core-v3==2.5.3 | ||
| aliyun-python-sdk-rds==2.1.1 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,83 @@ | ||
| # -*- coding: UTF-8 -*- | ||
| import datetime | ||
| from aliyunsdkcore import client | ||
| from aliyunsdkrds.request.v20140815 import DescribeSlowLogsRequest, DescribeSlowLogRecordsRequest, \ | ||
| RequestServiceOfCloudDBARequest | ||
| import simplejson as json | ||
| from .models import AliyunAccessKey | ||
| from .aes_decryptor import Prpcrypt | ||
|
|
||
|
|
||
| class Aliyun(object): | ||
| def __init__(self): | ||
| prpCryptor = Prpcrypt() | ||
| auth = AliyunAccessKey.objects.filter(is_enable=1) | ||
| try: | ||
| ak = prpCryptor.decrypt(auth[0].ak) | ||
| secret = prpCryptor.decrypt(auth[0].secret) | ||
| except Exception: | ||
| ak = '' | ||
| secret = '' | ||
| self.clt = client.AcsClient( | ||
| ak=ak, | ||
| secret=secret) | ||
|
|
||
| def request_api(self, request, *values): | ||
| if values: | ||
| for value in values: | ||
| for k, v in value.items(): | ||
| request.add_query_param(k, v) | ||
| request.set_accept_format('json') | ||
| result = self.clt.do_action_with_exception(request) | ||
| return json.dumps(json.loads(result.decode('utf-8')), indent=4, sort_keys=False, ensure_ascii=False) | ||
|
|
||
| # 阿里云2017-12-10T16:00:00Z时间加上8小时时区显示 | ||
| def aliyun_time_format(self, str_time): | ||
| if 'T' in str_time: | ||
| Ymd = str_time.split('T')[0] | ||
| HMS = str_time.split('T')[1].split('Z')[0] | ||
| str_time = '%s %s' % (Ymd, HMS) | ||
| time = datetime.datetime.strptime(str_time, "%Y-%m-%d %H:%M:%S") | ||
| format_time = time + datetime.timedelta(hours=8) | ||
| elif 'Z' in str_time: | ||
| Ymd = str_time.split('Z')[0] | ||
| format_time = '%s' % Ymd | ||
| else: | ||
| format_time = str_time | ||
| return format_time | ||
|
|
||
| def DescribeSlowLogs(self, DBInstanceId, StartTime, EndTime, **kwargs): | ||
| '''获取集群慢日志列表 | ||
| DBName,SortKey、PageSize、PageNumber''' | ||
| request = DescribeSlowLogsRequest.DescribeSlowLogsRequest() | ||
| values = {"action_name": "DescribeSlowLogs", "DBInstanceId": DBInstanceId, | ||
| "StartTime": StartTime, "EndTime": EndTime, "SortKey": "TotalExecutionCounts"} | ||
| values = dict(values, **kwargs) | ||
| result = self.request_api(request, values) | ||
| return result | ||
|
|
||
| def DescribeSlowLogRecords(self, DBInstanceId, StartTime, EndTime, **kwargs): | ||
| '''查看慢日志明细 | ||
| SQLId,DBName、PageSize、PageNumber''' | ||
| request = DescribeSlowLogRecordsRequest.DescribeSlowLogRecordsRequest() | ||
| values = {"action_name": "DescribeSlowLogRecords", "DBInstanceId": DBInstanceId, | ||
| "StartTime": StartTime, "EndTime": EndTime} | ||
| values = dict(values, **kwargs) | ||
| result = self.request_api(request, values) | ||
| return result | ||
|
|
||
| def RequestServiceOfCloudDBA(self, DBInstanceId, ServiceRequestType, ServiceRequestParam, **kwargs): | ||
| ''' | ||
| 获取统计信息：'GetTimedMonData',{"Language":"zh","KeyGroup":"mem_cpu_usage","KeyName":"","StartTime":"2018-01-15T04:03:26Z","EndTime":"2018-01-15T05:03:26Z"} | ||
| mem_cpu_usage、iops_usage、detailed_disk_space | ||
| 获取process信息：'ShowProcessList',{"Language":"zh","Command":"Query"} -- Not Sleep , All | ||
| 终止进程：'ConfirmKillSessionRequest',{"Language":"zh","SQLRequestID":75865,"SQLStatement":"kill 34022786;"} | ||
| 获取表空间信息：'GetSpaceStatForTables',{"Language": "zh", "OrderType": "Data"} | ||
| 获取资源利用信息：'GetResourceUsage',{"Language":"zh"} | ||
| ''' | ||
| request = RequestServiceOfCloudDBARequest.RequestServiceOfCloudDBARequest() | ||
| values = {"action_name": "RequestServiceOfCloudDBA", "DBInstanceId": DBInstanceId, | ||
| "ServiceRequestType": ServiceRequestType, "ServiceRequestParam": ServiceRequestParam} | ||
| values = dict(values, **kwargs) | ||
| result = self.request_api(request, values) | ||
| return result |
Oops, something went wrong.