1.准备工作
首先得有一个阿里云的域名
- 安装阿里云SDK和其他第三方库
pip install aliyun-python-sdk-core-v3
pip install aliyun-python-sdk-domain
pip install aliyun-python-sdk-alidns
pip install requests获取accessKeyId和accessSecret
- 可以在阿里云控制台个人中心直接获取，但是一般建议使用RAM角色来进行权限控制，这样这个accessKey和accessSecret就只能操作域名，不能操作其他的资源，相对会比较安全。关于RAM快速入门：https://help.aliyun.com/document_detail/28637.html
2.代码实现
2.1 ali-dns-helper.py`
from aliyunsdkcore.client import AcsClient
from aliyunsdkcore.acs_exception.exceptions import ClientException
from aliyunsdkcore.acs_exception.exceptions import ServerException
from aliyunsdkalidns.request.v20150109.DescribeSubDomainRecordsRequest import DescribeSubDomainRecordsRequest
from aliyunsdkalidns.request.v20150109.DescribeDomainRecordsRequest import DescribeDomainRecordsRequest
import requests
from urllib.request import urlopen
import json
class AliyunDNSHelper:
def __init__(self,accessKeyId = "LTAI4GHqgJgbzPfNnkwyGqks",accessSecret = "CzXkUS8BWcjJ7qEbKrqg6qxUOdnW6M",domain = "4v7p.top"):
"""
阿里云DNS助手初始化
需要传入自己的accessKeyId、accessSecret、domain
"""
self.client = AcsClient(accessKeyId, accessSecret, 'cn-hangzhou')
self.domain = domain
def update(self,RecordId, RR, Type, Value):
"""
修改域名解析记录方法
参数列表：
+ RecordId：调用查询方法时候查到对应的记录会返回
+ RR：记录名即子域名
+ Type：记录类型包括CNAME、A、AAAA等
+ Value：记录值
"""
from aliyunsdkalidns.request.v20150109.UpdateDomainRecordRequest import UpdateDomainRecordRequest
request = UpdateDomainRecordRequest()
request.set_accept_format('json')
request.set_RecordId(RecordId)
request.set_RR(RR)
request.set_Type(Type)
request.set_Value(Value)
response = self.client.do_action_with_exception(request)
def add(self,DomainName, RR, Type, Value):
"""
添加新的域名解析记录方法
参数列表：
+ DomainName：待修改的主域名
+ RR：记录名即子域名
+ Type：记录类型包括CNAME、A、AAAA等
+ Value：记录值
"""
from aliyunsdkalidns.request.v20150109.AddDomainRecordRequest import AddDomainRecordRequest
request = AddDomainRecordRequest()
request.set_accept_format('json')
request.set_DomainName(DomainName)
request.set_RR(RR) # https://blog.zeruns.tech
request.set_Type(Type)
request.set_Value(Value)
response = self.client.do_action_with_exception(request)
def select(self,subDomian):
"""
查询子域域名解析记录
参数列表：
+ subDomian：子域名
"""
request = DescribeSubDomainRecordsRequest()
request.set_accept_format('json')
request.set_DomainName(self.domain)
request.set_SubDomain(subDomian + '.' + self.domain)
response = self.client.do_action_with_exception(request) # 获取域名解析记录列表
domain_list = json.loads(response) # 将返回的JSON数据转化为Python能识别的
if domain_list["TotalCount"]==0:
return None
return domain_list["DomainRecords"]["Record"][0]
def action(self,subDomian,Value,Type="A"):
"""
执行用户关于DNS操作的的行为
参数列表：
+ action_type操作类型，包括add,update
+ subDomian：记录名即子域名
+ Type：记录类型包括CNAME、A、AAAA等
+ Value：记录值
"""
print("待处理的记录为 %s:%s-->Domain:%s" % (Type,Value,subDomian + '.' + self.domain))
subDomian_record = self.select(subDomian)
if subDomian_record:
RecordId,RecordValue = subDomian_record["RecordId"],subDomian_record["Value"]
if Value==RecordValue:
print("该域名解析记录已存在，跳过")
else:
self.update(RecordId, subDomian, Type, Value)
print("修改域名解析成功")
else:
self.add(self.domain, subDomian, Type, Value)
print("新建域名解析成功")
dnsHelper = AliyunDNSHelper(accessKeyId = "LTAI4GHqgJgbzPfNnkwyGqks",accessSecret = "CzXkUS8BWcjJ7qEbKrqg6qxUOdnW6M",domain = "4v7p.top")
sub_domain = input("SubDomian:")
value = input("value:")
sub_domain_type = input("Type:")
dnsHelper.action(sub_domain,value,sub_domain_type)2.2 ali-ddns-ipv6.py：实现ipv6 DDNS功能（ipv4同理）
2.2.1 获取本机公网ipv6地址
- 方法1：通过http接口获取(推荐)
def getIPv6Address():
text = requests.get('https://v6.ident.me').text
return text
getIPv6Address()'2001:da8:a012:2da:2f0:d2ff:fed0:d0d2'- 方法2：python执行shell命令--其中的shell命令需要根据实际情况进行修改
def get_local_ipv6():
"""
获取本机ipv6地址，其中的shell命令需要根据实际情况进行修改
"""
import os;
cmd_get_ipv6 = "ifconfig enp1s0 | awk '{if(NR==3){print $3}}'" # 获取本机ipv6的shell命令，需要根据实际情况进行修改
ipv6 = os.popen(cmd_get_ipv6).readlines()[0]
if "/" in ipv6:
ipv6 = ipv6.split("/")[0]
return ipv6
get_local_ipv6()'2001:da8:a012:2da:2f0:d2ff:fed0:d0d2'2.2.2 配合time.sleep完成DDNS功能
from aliyunsdkcore.client import AcsClient
from aliyunsdkcore.acs_exception.exceptions import ClientException
from aliyunsdkcore.acs_exception.exceptions import ServerException
from aliyunsdkalidns.request.v20150109.DescribeSubDomainRecordsRequest import DescribeSubDomainRecordsRequest
from aliyunsdkalidns.request.v20150109.DescribeDomainRecordsRequest import DescribeDomainRecordsRequest
import requests
from urllib.request import urlopen
import json
import time
class AliyunDNSHelper:
def __init__(self,accessKeyId = "LTAI4GHqgJgbzPfNnkwyGqks",accessSecret = "CzXkUS8BWcjJ7qEbKrqg6qxUOdnW6M",domain = "4v7p.top"):
"""
阿里云DNS助手初始化
需要传入自己的accessKeyId、accessSecret、domain
"""
self.client = AcsClient(accessKeyId, accessSecret, 'cn-hangzhou')
self.domain = domain
def update(self,RecordId, RR, Type, Value):
"""
修改域名解析记录方法
参数列表：
+ RecordId：调用查询方法时候查到对应的记录会返回
+ RR：记录名即子域名
+ Type：记录类型包括CNAME、A、AAAA等
+ Value：记录值
"""
from aliyunsdkalidns.request.v20150109.UpdateDomainRecordRequest import UpdateDomainRecordRequest
request = UpdateDomainRecordRequest()
request.set_accept_format('json')
request.set_RecordId(RecordId)
request.set_RR(RR)
request.set_Type(Type)
request.set_Value(Value)
response = self.client.do_action_with_exception(request)
def add(self,DomainName, RR, Type, Value):
"""
添加新的域名解析记录方法
参数列表：
+ DomainName：待修改的主域名
+ RR：记录名即子域名
+ Type：记录类型包括CNAME、A、AAAA等
+ Value：记录值
"""
from aliyunsdkalidns.request.v20150109.AddDomainRecordRequest import AddDomainRecordRequest
request = AddDomainRecordRequest()
request.set_accept_format('json')
request.set_DomainName(DomainName)
request.set_RR(RR) # https://blog.zeruns.tech
request.set_Type(Type)
request.set_Value(Value)
response = self.client.do_action_with_exception(request)
def select(self,subDomian):
"""
查询子域域名解析记录
参数列表：
+ subDomian：子域名
"""
request = DescribeSubDomainRecordsRequest()
request.set_accept_format('json')
request.set_DomainName(self.domain)
request.set_SubDomain(subDomian + '.' + self.domain)
response = self.client.do_action_with_exception(request) # 获取域名解析记录列表
domain_list = json.loads(response) # 将返回的JSON数据转化为Python能识别的
if domain_list["TotalCount"]==0:
return None
return domain_list["DomainRecords"]["Record"][0]
def action(self,subDomian,Value,Type="A"):
"""
执行用户关于DNS操作的的行为
参数列表：
+ action_type操作类型，包括add,update
+ subDomian：记录名即子域名
+ Type：记录类型包括CNAME、A、AAAA等
+ Value：记录值
"""
print("待处理的记录为 %s:%s-->Domain:%s" % (Type,Value,subDomian + '.' + self.domain))
subDomian_record = self.select(subDomian)
if subDomian_record:
RecordId,RecordValue = subDomian_record["RecordId"],subDomian_record["Value"]
if Value==RecordValue:
print("该域名解析记录已存在，跳过")
else:
self.update(RecordId, subDomian, Type, Value)
print("修改域名解析成功")
else:
self.add(self.domain, subDomian, Type, Value)
print("新建域名解析成功")
def getIPv6Address():
text = requests.get('https://v6.ident.me').text # 接口失效后需要及时进行修改
return text
dnsHelper = AliyunDNSHelper(accessKeyId = "LTAI4GHqgJgbzPfNnkwyGqks",accessSecret = "CzXkUS8BWcjJ7qEbKrqg6qxUOdnW6M",domain = "4v7p.top")
sub_domain = "d2550-ipv6"
sub_domain_type = "AAAA"
while True:
print("当前时间:",time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()))
value = getIPv6Address()
dnsHelper.action(sub_domain,value,sub_domain_type)
time.sleep(2*3600) # 每隔2个小时执行1次然后配合screen命令或者去掉无限循环使用定时任务进行执行即可完成ipv6的DDNS的功能
评论 (0)