下述代码示例中包含以下操作：
- 创建VBR。
- 创建发起端路由器接口。
- 创建接收端路由器接口。
- 修改发起端路由器接口信息。
- 修改接收端路由器接口信息。
- 查询发起端路由器接口信息。
- 查询接收端路由器接口信息。
- 查询VBR的路由表ID。
- 连接发起端路由器接口和接收端路由器接口。
- 创建下一跳为发起端路由器接口的路由条目。
- 创建下一跳为接收端路由器接口的路由条目。
- 删除下一跳为接收端路由器接口的路由条目。
- 删除下一跳为发起端路由器接口的路由条目。
- 冻结发起端路由器接口。
- 冻结接收端路由器接口。
- 删除发起端路由器接口。
- 删除接收端路由器接口。
- 删除VBR。
#encoding=utf-8
import sys
import json
from aliyunsdkcore.acs_exception.exceptions import ServerException, ClientException
from aliyunsdkvpc.request.v20160428 import CreateRouterInterfaceRequest
from aliyunsdkvpc.request.v20160428 import DeleteRouterInterfaceRequest
from aliyunsdkvpc.request.v20160428 import DescribeRouterInterfacesRequest
from aliyunsdkvpc.request.v20160428 import ConnectRouterInterfaceRequest
from aliyunsdkvpc.request.v20160428 import DeactivateRouterInterfaceRequest
from aliyunsdkvpc.request.v20160428 import ModifyRouterInterfaceAttributeRequest
from aliyunsdkvpc.request.v20160428 import CreateVirtualBorderRouterRequest
from aliyunsdkvpc.request.v20160428 import DescribeVirtualBorderRoutersRequest
from aliyunsdkvpc.request.v20160428 import DescribeRouteTablesRequest
from aliyunsdkvpc.request.v20160428 import DeleteVirtualBorderRouterRequest
from sdk_lib.sdk_route_entry import RouteEntry
from sdk_lib.exception import ExceptionHandler
from sdk_lib.common_util import CommonUtil
from sdk_lib.check_status import CheckStatus
from sdk_lib.consts import *
client = AcsClient(
'<your-access-key-id>', # 您的AccessKey ID
'<your-access-key-secret>', # 您的AccessKey Secret
'<your-region-id>') # 您的地域ID
class RouterInterface(object):
def __init__(self, client):
self.client = client
def create_router_interface(self, params):
"""
create_router_interface: 创建路由器接口
"""
try:
request = CreateRouterInterfaceRequest.CreateRouterInterfaceRequest()
# 路由器接口的规格
request.set_Spec(params['spec'])
# 路由器接口的角色
request.set_Role(params['role'])
# 路由器接口关联的路由器ID
request.set_RouterId(params['router_id'])
# 路由器接口关联的路由器类型
request.set_RouterType(params['router_type'])
# 连接接收端所在的地域ID
request.set_OppositeRegionId(params['opposite_region_id'])
# 对端路由器接口关联的路由器类型
request.set_OppositeRouterType(params['opposite_router_type'])
# 对端所属的接入点ID
request.set_OppositeAccessPointId(params['opposite_access_point_id'])
# VBR所属的接入点ID
#request.set_AccessPointId(params['access_point_id'])
response = self.client.do_action_with_exception(request)
response_json = json.loads(response)
# 判断路由器接口状态是否可用
if CheckStatus.check_status(TIME_DEFAULT_OUT, DEFAULT_TIME,
self.describe_ri_status,
'Idle', response_json['RouterInterfaceId']):
return response_json
except ServerException as e:
ExceptionHandler.server_exception(e)
except ClientException as e:
ExceptionHandler.client_exception(e)
def create_router_interface_vbr(self, params):
"""
create_router_interface: 创建路由器接口
"""
try:
request = CreateRouterInterfaceRequest.CreateRouterInterfaceRequest()
# 路由器接口的规格
request.set_Spec(params['spec'])
# 路由器接口的角色
request.set_Role(params['role'])
# 路由器接口关联的路由器ID
request.set_RouterId(params['router_id'])
# 路由器接口关联的路由器类型
request.set_RouterType(params['router_type'])
# 连接接收端所在的地域ID
request.set_OppositeRegionId(params['opposite_region_id'])
# 对端路由器接口关联的路由器类型
request.set_OppositeRouterType(params['opposite_router_type'])
# VBR所属的接入点ID
request.set_AccessPointId(params['access_point_id'])
response = self.client.do_action_with_exception(request)
response_json = json.loads(response)
# 判断路由器接口状态是否可用
if CheckStatus.check_status(TIME_DEFAULT_OUT, DEFAULT_TIME,
self.describe_ri_status,
'Idle', response_json['RouterInterfaceId']):
return response_json
except ServerException as e:
ExceptionHandler.server_exception(e)
except ClientException as e:
ExceptionHandler.client_exception(e)
def connect_router_interface(self, params):
"""
connect_router_interface: 由发起端路由器接口向接收端发起连接
"""
try:
request = ConnectRouterInterfaceRequest.ConnectRouterInterfaceRequest()
# 发起端路由器接口的ID
request.set_RouterInterfaceId(params['router_interface_id'])
response = self.client.do_action_with_exception(request)
response_json = json.loads(response)
if CheckStatus.check_status(TIME_DEFAULT_OUT * 5, DEFAULT_TIME * 5,
self.describe_ri_status,
'Active', params['router_interface_id']):
return response_json
except ServerException as e:
ExceptionHandler.server_exception(e)
except ClientException as e:
ExceptionHandler.client_exception(e)
def deactivate_router_interface(self, params):
"""
deactivate_router_interface: 冻结路由器接口
"""
try:
request = DeactivateRouterInterfaceRequest.DeactivateRouterInterfaceRequest()
# 路由器接口的ID
request.set_RouterInterfaceId(params['router_interface_id'])
response = self.client.do_action_with_exception(request)
response_json = json.loads(response)
# 判断路由器接口状态是否可用
if CheckStatus.check_status(TIME_DEFAULT_OUT * 5, DEFAULT_TIME * 5,
self.describe_ri_status,
'Inactive', params['router_interface_id']):
return response_json
except ServerException as e:
ExceptionHandler.server_exception(e)
except ClientException as e:
ExceptionHandler.client_exception(e)
def modify_router_interface_attribute(self, params):
"""
modify_router_interface_attribute: 修改路由器接口的配置
"""
try:
request = ModifyRouterInterfaceAttributeRequest.ModifyRouterInterfaceAttributeRequest()
# 路由器接口的ID
request.set_RouterInterfaceId(params['router_interface_id'])
# 对端路由器接口ID
request.set_OppositeInterfaceId(params['opposite_interface_id'])
# 对端的路由器的ID
request.set_OppositeRouterId(params['opposite_router_id'])
# 对端的路由器的类型
request.set_OppositeRouterType(params['opposite_router_type'])
response = self.client.do_action_with_exception(request)
response_json = json.loads(response)
# 判断路由器接口状态是否可用
if CheckStatus.check_status(TIME_DEFAULT_OUT, DEFAULT_TIME,
self.describe_ri_status,
'Idle', params['router_interface_id']):
return response_json
except ServerException as e:
ExceptionHandler.server_exception(e)
except ClientException as e:
ExceptionHandler.client_exception(e)
def describe_router_interface(self, instance_id):
"""
describe_router_interface: 查询指定地域内的路由器接口
"""
try:
request = DescribeRouterInterfacesRequest.DescribeRouterInterfacesRequest()
# 查询的过滤类型
request.add_query_param('Filter.1.Key', "RouterInterfaceId")
# 查询的实例ID
request.add_query_param('Filter.1.Value.1', instance_id)
response = self.client.do_action_with_exception(request)
response_json = json.loads(response)
return response_json
except ServerException as e:
ExceptionHandler.server_exception(e)
except ClientException as e:
ExceptionHandler.client_exception(e)
def describe_ri_status(self, instance_id):
"""
describe_ri_status: 查询指定地域内的路由器接口状态
"""
response = self.describe_router_interface(instance_id)
if len(response['RouterInterfaceSet']['RouterInterfaceType']) == 0:
return ''
return response['RouterInterfaceSet']['RouterInterfaceType'][0]['Status']
def delete_router_interface(self, params):
"""
delete_router_interface: 删除路由器接口
"""
try:
request = DeleteRouterInterfaceRequest.DeleteRouterInterfaceRequest()
# 路由器接口的ID
request.set_RouterInterfaceId(params['instance_id'])
response = self.client.do_action_with_exception(request)
response_json = json.loads(response)
# 判断路由器接口状态是否可用
if CheckStatus.check_status(TIME_DEFAULT_OUT, DEFAULT_TIME * 5,
self.describe_ri_status,
'', params['instance_id']):
return response_json
except ServerException as e:
ExceptionHandler.server_exception(e)
except ClientException as e:
ExceptionHandler.client_exception(e)
def create_virtual_border_router(self, params):
"""
create_virtual_border_router: 新建VBR
"""
try:
request = CreateVirtualBorderRouterRequest.CreateVirtualBorderRouterRequest()
# 物理专线的ID
request.set_PhysicalConnectionId(params['physical_connection_id'])
# VBR的阿里云侧互联IP
request.set_LocalGatewayIp(params['local_gateway_ip'])
# VBR专线侧接口对端的IP地址
request.set_PeerGatewayIp(params['peer_gateway_ip'])
# VBR的阿里云侧和客户侧互联IP的子网掩码
request.set_PeeringSubnetMask(params['peering_subnet_mask'])
# VBR的VLAN ID
request.set_VlanId(params['vlan_id'])
response = self.client.do_action_with_exception(request)
response_json = json.loads(response)
# 判断VBR状态是否可用
if CheckStatus.check_status(TIME_DEFAULT_OUT, DEFAULT_TIME,
self.describe_vbr_status,
'active', response_json['VbrId']):
return response_json
except ServerException as e:
ExceptionHandler.server_exception(e)
except ClientException as e:
ExceptionHandler.client_exception(e)
def delete_virtual_border_router(self, params):
"""
delete_virtual_border_router: 删除VBR
"""
try:
request = DeleteVirtualBorderRouterRequest.DeleteVirtualBorderRouterRequest()
request.set_VbrId(params['vbr_id'])
response = self.client.do_action_with_exception(request)
response_json = json.loads(response)
if CheckStatus.check_status(TIME_DEFAULT_OUT, DEFAULT_TIME,
self.describe_vbr_status,
'', params['vbr_id']):
return response_json
except ServerException as e:
ExceptionHandler.server_exception(e)
except ClientException as e:
ExceptionHandler.client_exception(e)
def describe_virtual_border_router(self, instance_id):
"""
describe_virtual_border_router: 查询VBR
"""
try:
request = DescribeVirtualBorderRoutersRequest.DescribeVirtualBorderRoutersRequest()
# 查询的过滤类型
request.add_query_param('Filter.1.Key', "VbrId")
# 查询的实例ID
request.add_query_param('Filter.1.Value.1', instance_id)
response = self.client.do_action_with_exception(request)
response_json = json.loads(response)
return response_json
except ServerException as e:
ExceptionHandler.server_exception(e)
except ClientException as e:
ExceptionHandler.client_exception(e)
def describe_vbr_status(self, instance_id):
"""
describe_virtual_border_router: 查询VBR
"""
response = self.describe_virtual_border_router(instance_id)
if len(response['VirtualBorderRouterSet']['VirtualBorderRouterType']) == 0:
return ''
return response['VirtualBorderRouterSet']['VirtualBorderRouterType'][0]['Status']
def describe_route_table(self, params):
"""
describe_route_table: 查询路由表
"""
try:
request = DescribeRouteTablesRequest.DescribeRouteTablesRequest()
# 路由表所属的VPC路由器或VBR的ID
request.set_RouterId(params['router_id'])
# 路由表所属的路由器类型
request.set_RouterType(params['router_type'])
response = self.client.do_action_with_exception(request)
response_json = json.loads(response)
return response_json
except ServerException as e:
ExceptionHandler.server_exception(e)
except ClientException as e:
ExceptionHandler.client_exception(e)
def main():
router_interface = RouterInterface(client)
route_entry = RouteEntry(client)
params = {}
params['spec'] = "Large.2"
params['role'] = "InitiatingSide"
params['router_type'] = "VBR"
params['opposite_region_id'] = "cn-hangzhou"
params['opposite_router_type'] = "VRouter"
params['access_point_id'] = "ap-cn-hangzhou-xx-x"
# 创建VBR
params['physical_connection_id'] = PC_ID
params['local_gateway_ip'] = "116.xx.xx.254"
params['peer_gateway_ip'] = "116.xx.xx.254"
params['peering_subnet_mask'] = "255.255.255.252"
params['vlan_id'] = 30
vbr_json = router_interface.create_virtual_border_router(params)
CommonUtil.log("create_virtual_border_router", vbr_json)
# 创建发起端路由器接口
params['router_id'] = vbr_json['VbrId']
router_interface_json = router_interface.create_router_interface_vbr(params)
CommonUtil.log("create_router_interface", router_interface_json)
# 创建接收端路由器接口
params['router_type'] = "VRouter"
params['spec'] = "Negative"
params['role'] = "AcceptingSide"
params['router_id'] = ROUTER_ID2
params['opposite_router_type'] = 'VBR'
params['opposite_access_point_id'] = params['access_point_id']
router_interface_json2 = router_interface.create_router_interface(params)
CommonUtil.log("create_router_interface", router_interface_json2)
# 修改发起端路由器接口信息
params['router_interface_id'] = router_interface_json['RouterInterfaceId']
params['opposite_interface_id'] = router_interface_json2['RouterInterfaceId']
params['opposite_router_id'] = ROUTER_ID2
params['opposite_router_type'] = "VRouter"
modify_ri_json = router_interface.modify_router_interface_attribute(params)
CommonUtil.log("modify_router_interface_attribute", modify_ri_json)
# 修改接收端路由器接口信息
params['router_interface_id'] = router_interface_json2['RouterInterfaceId']
params['opposite_interface_id'] = router_interface_json['RouterInterfaceId']
params['opposite_router_id'] = vbr_json['VbrId']
params['opposite_router_type'] = "VBR"
modify_ri_json2 = router_interface.modify_router_interface_attribute(params)
CommonUtil.log("modify_router_interface_attribute", modify_ri_json2)
# 查询发起端路由器接口信息
describe_ri_json = router_interface.describe_router_interface(router_interface_json['RouterInterfaceId'])
CommonUtil.log("describe_router_interface", describe_ri_json)
# 查询接收端路由器接口信息
describe_ri_json2 = router_interface.describe_router_interface(router_interface_json2['RouterInterfaceId'])
CommonUtil.log("describe_router_interface", describe_ri_json2)
# 查询VBR的路由表ID
params['router_id'] = vbr_json['VbrId']
params['router_type'] = 'VBR'
route_table_json = router_interface.describe_route_table(params)
CommonUtil.log("describe_route_table", route_table_json)
# 发起连接
params['router_interface_id'] = router_interface_json['RouterInterfaceId']
connect_ri_json = router_interface.connect_router_interface(params)
CommonUtil.log("connect_router_interface", connect_ri_json)
# 创建下一跳为发起端路由器接口的路由条目
params['route_table_id'] = route_table_json["RouteTables"]["RouteTable"][0]["RouteTableId"]
params['destination_cidr_block'] = "0.0.0.0/0"
params['nexthop_type'] = 'RouterInterface'
params['nexthop_id'] = router_interface_json['RouterInterfaceId']
route_entry_json = route_entry.create_route_entry(params)
CommonUtil.log("create_route_entry", route_entry_json)
# 创建下一跳为接收端路由器接口的路由条目
params['route_table_id'] = TABLE_ID2
params['destination_cidr_block'] = "0.0.0.0/0"
params['nexthop_type'] = 'RouterInterface'
params['nexthop_id'] = router_interface_json2['RouterInterfaceId']
route_entry_json2 = route_entry.create_route_entry(params)
CommonUtil.log("create_route_entry", route_entry_json2)
# 删除下一跳为接收端路由器接口的路由条目
route_entry_json = route_entry.delete_route_entry(params)
CommonUtil.log("delete_route_entry", route_entry_json)
# 删除下一跳为发起端路由器接口的路由条目
params['route_table_id'] = route_table_json["RouteTables"]["RouteTable"][0]["RouteTableId"]
params['nexthop_id'] = router_interface_json['RouterInterfaceId']
route_entry_json = route_entry.delete_route_entry(params)
CommonUtil.log("delete_route_entry", route_entry_json)
# 冻结发起端路由器接口
params['router_interface_id'] = router_interface_json['RouterInterfaceId']
deactivate_ri_json = router_interface.deactivate_router_interface(params)
CommonUtil.log("deactivate_router_interface", deactivate_ri_json)
# 冻结接收端路由器接口
params['router_interface_id'] = router_interface_json2['RouterInterfaceId']
deactivate_ri_json2 = router_interface.deactivate_router_interface(params)
CommonUtil.log("deactivate_router_interface", deactivate_ri_json2)
# 删除发起端路由器接口
params['instance_id'] = router_interface_json['RouterInterfaceId']
router_interface_json = router_interface.delete_router_interface(params)
CommonUtil.log("delete_router_interface", router_interface_json)
# 删除接收端路由器接口
params['instance_id'] = router_interface_json2['RouterInterfaceId']
router_interface_json2 = router_interface.delete_router_interface(params)
CommonUtil.log("delete_router_interface", router_interface_json2)
# 删除VBR
params['vbr_id'] = vbr_json['VbrId']
vbr_json = router_interface.delete_virtual_border_router(params)
CommonUtil.log("delete_virtual_border_router", vbr_json)
if __name__ == '__main__':
sys.exit(main())
