【script】python 调用阿里云解析 DNS API 实现 DDNS(动态域名解析)

一、前情提要

由于当前IPv4公网地址匮乏，一般来说，即便你是电信或联通的宽带，运营商默认也是不会给你分配公网 IP 的，需要向运营商提出申请，根据地区不同，申请难易程度不同。少数地区可以通过公众号或装维师父直接联系申请，大部分地区需要拨打人工客服（电信 10000，联通 10010）以“家中要安装家庭网络摄像头”为理由申请动态公网 IP（千万不能说是服务器或其他设备），少数地区可能一次无法申请成功（很多客服不清楚动态公网 IP，所以可以尝试多换几个客服），申请成功后重启光猫即可。不过运营商提供的公网IP地址是动态的，一段时间后或光猫/路由器重启，公网IP地址就发生变化。这就导致我们不能直接把得到的公网IP绑定到自己的域名上，每次IP地址发生变化，域名就无法访问了。于是就需要用到DDNS服务。DDNS(动态域名解析)是把互联网域名指向可变IP地址的系统。DNS只是提供了域名和IP地址之间的静态对应关系，当IP地址发生变化时，DNS无法动态的更新域名和IP地址之间的对应关系，从而导致访问失败。但是DDNS系统是将用户的动态IP地址映射到一个固定的域名解析服务上，用户每次连接网络时，客户端程序通过信息传递把该主机的动态IP地址传送给位于服务商主机上的服务器程序，实现动态域名解析。

官方文档可参考阿里云 DNS API 快速入门。

注：现在不少路由器都带有DDNS服务，不过提供的服务商有限仅支持花生壳、公云等。要想使用自己手头的阿里域名就需要自己来解决了。

二、准备

前期准备

1、公网IP（向运营商申请的动态IP）

2、域名（通过阿里云购买的域名）

3、可以运行python程序的服务器（路由器/电脑/树莓派）

4、安装两个Python-SDK库

# 核心库
pip install aliyun-python-sdk-core
# 域名库
pip install aliyun-python-sdk-alidns

aliyunsdkcore.acs_exception.exceptions.ClientException

如果出现该报错：aliyunsdkcore.acs_exception.exceptions.ClientException: SDK.HttpError (‘Connection aborted.’, ConnectionResetError(104, ‘Connection reset by peer’))

安装另一个核心库即可，安装代码如下：

pip install aliyun-python-sdk-core-v3

三、获取 AccessKey

通过阿里云控制台进入RAM访问控制页面新建子用户，获取 AccessKey ID 和 AccessKey Secret

四、实现逻辑

1、获取当前IP

2、存储获取到的IP

3、比对IP（因为阿里云不允许修改相同的解析，所以需要比对IP是否有变化）

4、获取解析记录列表

#!/usr/bin/env python
#coding=utf-8from aliyunsdkcore.client import AcsClient
from aliyunsdkcore.acs_exception.exceptions import ClientException
from aliyunsdkcore.acs_exception.exceptions import ServerException
from aliyunsdkalidns.request.v20150109.DescribeDomainRecordsRequest import DescribeDomainRecordsRequestclient = AcsClient('', '', 'cn-hangzhou')request = DescribeDomainRecordsRequest()
request.set_accept_format('json')request.set_DomainName("xx.com")response = client.do_action_with_exception(request)

5、添加解析记录

#!/usr/bin/env python
#coding=utf-8from aliyunsdkcore.client import AcsClient
from aliyunsdkcore.acs_exception.exceptions import ClientException
from aliyunsdkcore.acs_exception.exceptions import ServerException
from aliyunsdkalidns.request.v20150109.AddDomainRecordRequest import AddDomainRecordRequestclient = AcsClient('', '', 'cn-hangzhou')request = AddDomainRecordRequest()
request.set_accept_format('json')request.set_DomainName("xx.com")
request.set_RR("@")
request.set_Type("A")
request.set_Value("60")response = client.do_action_with_exception(request)

6、修改解析记录

#!/usr/bin/env python
#coding=utf-8from aliyunsdkcore.client import AcsClient
from aliyunsdkcore.acs_exception.exceptions import ClientException
from aliyunsdkcore.acs_exception.exceptions import ServerException
from aliyunsdkalidns.request.v20150109.UpdateDomainRecordRequest import UpdateDomainRecordRequestclient = AcsClient('', '', 'cn-hangzhou')request = UpdateDomainRecordRequest()
request.set_accept_format('json')request.set_RecordId("xx.com")
request.set_RR("@")
request.set_Type("A")
request.set_Value("60")response = client.do_action_with_exception(request)

五、源代码

github地址：https://github.com/a-00/AliyunDDNS

DDNS.py

#!/usr/bin/env python
# coding=utf-8"""
新增域名解析记录，参数说明如下：
：填写自己的accessKey，建议使用RAM角色管理的Key：填写自己的accessSecret，建议使用RAM角色管理的Secret
"""import os
import time
from aliyunsdkcore.client import AcsClient
from cxxh_function import wirte_to_file
from cxxh_function import add_record
from cxxh_function import update_record
from cxxh_function import Describe_Domain_Records
from cxxh_function import get_internet_ipwhile True:# 判断存放IP的文件是否存在，不存在则创建if os.path.exists("./ip"):passelse:wirte_to_file("./ip", "0.0.0.0")client = AcsClient('LTAI4G3PiidWoszTkEpC9DL8', '7Dx8BPqiy0Tyq822mPDMYEKmrT7SOt', 'cn-hangzhou')try:# 通过函数获取外网ipip = get_internet_ip()# print(ip)except Exception as e:print(e)pass# 下面开始对比ip，如果ip与之前记录的ip一致，则不执行任何操作，如果ip有变化，则会更新本地存储文件和更新域名解析with open("./ip", 'r') as f:old_ip = f.read()if ip == old_ip:print("本地记录未更新"+"\nnew_ip:"+ip+"\nold_ip:"+old_ip)else:des_relsult = Describe_Domain_Records(client, "A", "cccc.com")# 判断域名解析记录查询结果，TotalCount为0表示不存在这个域名的解析记录，需要新增一个if des_relsult["TotalCount"] == 0:add_relsult = add_record(client, "5", "600", "A", ip, "@", "cccc.com")record_id = add_relsult["RecordId"]print("域名解析新增成功！")wirte_to_file("./ip", ip)print("本地记录已更新"+"\nnew_ip:"+ip+"\nold_ip:"+old_ip)# 判断域名解析记录查询结果，TotalCount为1表示存在这个域名的解析记录，需要更新解析记录，更新记录需要用到RecordId，这个在查询函数中有返回des_relsult["DomainRecords"]["Record"][0]["RecordId"]elif des_relsult["TotalCount"] == 1:record_id = des_relsult["DomainRecords"]["Record"][0]["RecordId"]update_record(client, "5", "600", "A", ip, "@", record_id)print("域名解析更新成功！")wirte_to_file("./ip", ip)print("本地记录已更新"+"\nnew_ip:"+ip+"\nold_ip:"+old_ip)else:TotalCount = des_relsult["TotalCount"]print("存在%d个域名解析记录值，请核查删除后再操作！" % TotalCount)time.sleep(120)

cxxh_function.py

from aliyunsdkcore.client import AcsClient
from aliyunsdkcore.acs_exception.exceptions import ClientException
from aliyunsdkcore.acs_exception.exceptions import ServerException
from aliyunsdkalidns.request.v20150109.DescribeDomainRecordsRequest import DescribeDomainRecordsRequest
from aliyunsdkalidns.request.v20150109.AddDomainRecordRequest import AddDomainRecordRequest
from aliyunsdkalidns.request.v20150109.UpdateDomainRecordRequest import UpdateDomainRecordRequest
from aliyunsdkalidns.request.v20150109.DescribeSubDomainRecordsRequest import DescribeSubDomainRecordsRequest
import urllib.request
import json
import re# 写入文件
def wirte_to_file(path, content):with open(path, 'w') as f:f_name = open(path, 'w')f_name.write(content)# 新增解析记录，返回json格式的数据
def add_record(client, priority, ttl, record_type, value, rr, domainname):request = AddDomainRecordRequest()request.set_accept_format('json')request.set_Priority(priority)request.set_TTL(ttl)request.set_Value(value)request.set_Type(record_type)request.set_RR(rr)request.set_DomainName(domainname)response = client.do_action_with_exception(request)response = str(response, encoding='utf-8')relsult = json.loads(response)return relsult# 更新解析记录
def update_record(client, priority, ttl, record_type, value, rr, record_id):request = UpdateDomainRecordRequest()request.set_accept_format('json')request.set_Priority(priority)request.set_TTL(ttl)request.set_Value(value)request.set_Type(record_type)request.set_RR(rr)request.set_RecordId(record_id)response = client.do_action_with_exception(request)response = str(response, encoding='utf-8')return response# 获取解析记录列表
def Describe_Domain_Records(client, record_type, domainname):request = DescribeDomainRecordsRequest()request.set_accept_format('json')request.set_Type(record_type)request.set_DomainName(domainname)response = client.do_action_with_exception(request)response = str(response, encoding='utf-8')relsult = json.loads(response)return relsult# 获取外网地址
def get_internet_ip():url1 = 'https://ip.cn/api/index?ip=&type=0'url2 = 'http://www.3322.org/dyndns/getip'headers = {'User-Agent':'Mozilla/5.0 (Windows NT 6.1; WOW64; rv:23.0) Gecko/20100101 Firefox/23.0'}req = urllib.request.Request(url=url1, headers=headers)  with urllib.request.urlopen(req) as response:html = response.read().decode('utf-8')ip = re.findall('\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}', html)[0]return ip

六、参考链接

使用Python调用阿里云解析DNS API实现DDNS(动态域名解析)