【转载】阿里云DDNS动态域名解析，无需SDK

tryhi

找了半天的阿里云解析，论坛也有一篇，但是缺太多代码了，实在不知道怎么改，这个直接填入自己的AccessKeyID, AccessKeySecret，还有要解析的域名就可以直接用，什么都不用改，转载一下，也作为自己一个收藏
代码转自52论坛的 https://www.52pojie.cn/forum.php?mod=viewthread&tid=1296738

1. import re, json, time, uuid, random, chardet
   
2. import hmac, base64, hashlib
   
3. import requests
   
4. import urllib.parse, urllib.request
   
5. 
   
6. # 轮询时间间隔
   
7. TIME_INTERVAL = 5
   
8. 
   
9. 
   
10. class PublicIP(object):
    
11.     def __init__(self):
    
12.         self.user_agent = ('Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) '
    
13.                            'Chrome/70.0.3538.25 Safari/537.36 Core/1.70.3776.400 QQBrowser/10.6.4212.400')
    
14.         self.api_list = [
    
15.             'https://202020.ip138.com/',
    
16.             'https://www.ip.cn/api/index?ip=&type=0',
    
17.             'http://ip.webmasterhome.cn/',
    
18.             'http://ip.yqie.com/clientip.aspx',
    
19.             'https://www.123cha.com/ip/',
    
20.             'http://ip.chacuo.net/',
    
21.         ]
    
22. 
    
23.     def ip_query(self):
    
24.         while True:
    
25.             url = random.sample(self.api_list, 1)[0]
    
26.             try:
    
27.                 res = requests.get(url, headers={'User-Agent': self.user_agent}, timeout=5)
    
28.                 encoding = chardet.detect(res.content)['encoding']
    
29.                 html = res.content.decode(encoding)
    
30.                 out = re.findall(r'\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}', html)
    
31.                 if out != []: return out[0]
    
32.             except Exception as e:
    
33.                 continue
    
34. 
    
35. 
    
36. class AscSigner(object):
    
37.     def __init__(self, AccessKeyId, AccessKeySecret):
    
38.         self.AccessKeyId = AccessKeyId
    
39.         self.AccessKeySecret = AccessKeySecret
    
40. 
    
41.     def _utc(self):
    
42.         return time.strftime("%Y-%m-%dT%H:%M:%SZ", time.gmtime())
    
43. 
    
44.     def _uuid(self):
    
45.         return str(uuid.uuid4())
    
46. 
    
47.     def _pop_standard_urlencode(self, query):
    
48.         ret = query.replace('+', '%20')
    
49.         ret = ret.replace('*', '%2A')
    
50.         ret = ret.replace('%7E', '~')
    
51.         return ret
    
52. 
    
53.     def _common_param(self):
    
54.         return {
    
55.             'Format': 'JSON',
    
56.             'Version': '2015-01-09',
    
57.             'SignatureMethod': 'HMAC-SHA1',
    
58.             'SignatureNonce': self._uuid(),
    
59.             'SignatureVersion': '1.0',
    
60.             'AccessKeyId': self.AccessKeyId,
    
61.             'Timestamp': self._utc(),
    
62.         }
    
63. 
    
64.     def _string_to_sign(self, param):
    
65.         sorted_parameters = sorted(list(param.items()), key=lambda param: param[0])
    
66.         sorted_query_string = self._pop_standard_urlencode(urllib.parse.urlencode(sorted_parameters))
    
67.         canonicalized_query_string = self._pop_standard_urlencode(urllib.request.pathname2url(sorted_query_string))
    
68.         string_to_sign = "GET&%2F&" + canonicalized_query_string
    
69.         return string_to_sign
    
70. 
    
71.     def _sign(self, string_to_sign):
    
72.         param_encode = bytes(string_to_sign, 'utf-8')
    
73.         key = bytes(self.AccessKeySecret + '&', 'utf-8')
    
74.         h = hmac.new(key, param_encode, hashlib.sha1)
    
75.         return str(base64.encodebytes(h.digest()).strip(), "utf-8")
    
76. 
    
77.     def get_param_and_sign(self, action_param):
    
78.         common_param = self._common_param()
    
79.         param = dict(common_param, **action_param)
    
80.         string_to_sign = self._string_to_sign(param)
    
81.         signature = self._sign(string_to_sign)
    
82.         param['Signature'] = signature
    
83.         url = '?' + self._pop_standard_urlencode(urllib.parse.urlencode(param))
    
84.         return url
    
85. 
    
86. 
    
87. class AscRequestParam(object):
    
88.     def __init__(self, AccessKeyId, AccessKeySecret):
    
89.         self.signer = AscSigner(AccessKeyId, AccessKeySecret)
    
90. 
    
91.     # 获取域名列表
    
92.     def get_domains_params(self):
    
93.         action_param = {
    
94.             'Action': 'DescribeDomains',
    
95.             'PageSize': '100',
    
96.         }
    
97.         return self.signer.get_param_and_sign(action_param)
    
98. 
    
99.     # 获取解析记录
    
100.     def get_domain_records_params(self, domain_name):
     
101.         action_param = {
     
102.             'Action': 'DescribeDomainRecords',
     
103.             'DomainName': domain_name,
     
104.             'PageSize': '100',
     
105.         }
     
106.         return self.signer.get_param_and_sign(action_param)
     
107. 
     
108.     # 修改解析记录
     
109.     def update_domain_record_params(self, data):
     
110.         action_param = {
     
111.             'Action': 'UpdateDomainRecord',
     
112.             'RR': data['RR'],
     
113.             'RecordId': data['RecordId'],
     
114.             'Type': data['Type'],
     
115.             'Value': data['Value'],
     
116.         }
     
117.         return self.signer.get_param_and_sign(action_param)
     
118. 
     
119.     # 获取解析记录信息
     
120.     def get_domain_record_info_params(self, RecordId):
     
121.         action_param = {
     
122.             'Action': 'DescribeDomainRecordInfo',
     
123.             'RecordId': RecordId,
     
124.         }
     
125.         return self.signer.get_param_and_sign(action_param)
     
126. 
     
127. 
     
128. class AscClient(object):
     
129.     def __init__(self, AccessKeyId, AccessKeySecret):
     
130.         self.ip = PublicIP()
     
131.         self.client = AscRequestParam(AccessKeyId, AccessKeySecret)
     
132.         self.api = 'https://alidns.aliyuncs.com/'
     
133. 
     
134.     def _request(self, params):
     
135.         res = requests.get(self.api + params)
     
136.         return json.loads(res.content.decode('utf-8'))
     
137. 
     
138.     def _wait(self):
     
139.         timecount = TIME_INTERVAL
     
140.         while timecount >= 0:
     
141.             print(f"\r再次检测倒计时：{timecount}秒...", end="", flush=True)
     
142.             timecount = timecount - 1
     
143.             time.sleep(1)
     
144.         print('\n\n', end="", flush=True)
     
145. 
     
146.     def update_domain_record(self, record):
     
147.         ip = self.ip.ip_query()
     
148.         print(f'公网IP:{ip},')
     
149.         if ip == record['Value']:
     
150.             print('公网IP和解析IP相同，无需更新')
     
151.             return
     
152.         record['Value'] = ip
     
153.         params = self.client.update_domain_record_params(record)
     
154.         self._request(params)
     
155.         print('解析完成')
     
156. 
     
157.     def get_domain_records(self, RR, domain_name):
     
158.         params = self.client.get_domain_records_params(domain_name)
     
159.         res = self._request(params)
     
160.         TotalCount = int(res['TotalCount'])
     
161.         for i in res['DomainRecords']['Record']:
     
162.             if i['RR'] == RR:
     
163.                 return i
     
164.         return None
     
165. 
     
166.     def get_domains(self):
     
167.         params = self.client.get_domains_params()
     
168.         res = self._request(params)
     
169.         domain_list = []
     
170.         for i in res['Domains']['Domain']:
     
171.             domain_list.append(i['DomainName'])
     
172.         return int(res['TotalCount']), domain_list
     
173. 
     
174.     def start(self, RR, domain_name):
     
175.         while True:
     
176.             count, domains = self.get_domains()
     
177.             if count <= 0 or not domain_name in domains:
     
178.                 print('没有此域名')
     
179.                 return
     
180.             record = self.get_domain_records(RR, domain_name)
     
181.             if not record:
     
182.                 print(f'没有找到{RR}的解析记录')
     
183.                 return
     
184.             if not record['Type'] == 'A':
     
185.                 print('暂时只支持解析A记录')
     
186.                 return
     
187.             if record['Status'] == 'DISABLE':
     
188.                 print('此记录已被禁用，请启用后再试')
     
189.                 return
     
190.             self.update_domain_record(record)
     
191.             self._wait()
     
192. 
     
193. 
     
194. if __name__ == '__main__':
     
195.     # 换成你自己的AccessKeyID, AccessKeySecret
     
196.     a = AscClient('**********', '**********************')
     
197. 
     
198.     # 如果需要解析 www.baidu.com，填入 www 和 baidu.com
     
199.     # 如果需要解析 baidu.com  填入 @ 和 baidu.com
     
200.     a.start('test', 'mydomain.net')

复制代码

qq1151985918

66666666666666666666666