手机网站制作公司 广州,杭州装饰网站建设,php企业网站开发实验总结,山东外贸公司排名容器实例管理python sdk封装
测试结果 说明
这是根据我的需求写的#xff0c;所以有些参数是写死的#xff0c;比如cpu核数和内存#xff0c;你可以根据你的需要自行修改。前置条件#xff1a; 当前环境已安装python3.8以上版本和azure cli并且已经登陆到你的账户
依赖安…容器实例管理python sdk封装
测试结果 说明
这是根据我的需求写的所以有些参数是写死的比如cpu核数和内存你可以根据你的需要自行修改。前置条件 当前环境已安装python3.8以上版本和azure cli并且已经登陆到你的账户
依赖安装
requirments.txt
azure-mgmt-resource
azure-identity
azure-mgmt-containerinstancepip install -r requirments.txtPS: 安装不上就多安几次或使用魔法 containerhelpor.py
from azure.identity import DefaultAzureCredential
from azure.mgmt.containerinstance import ContainerInstanceManagementClient
from azure.mgmt.containerinstance.models import ContainerGroup, Container, ContainerPort, IpAddress, ResourceRequests, ResourceRequirementsclass ContainerHelpor:def create(subscription_id:str, resource_group:str, location:str, container_name:str, container_image:str, no_port:int, protocol: strTCP):# 使用默认 Azure 凭据进行验证credentials DefaultAzureCredential()# 创建容器实例管理客户端实例container_client ContainerInstanceManagementClient(credentials, subscription_id)# 容器端口和 IP 地址配置port1 ContainerPort(portno_port, protocolprotocol)ports [port1]# port2 ContainerPort(portno_port 1, protocolprotocol)# ports [port1, port2]ip_address IpAddress(portsports, typePublic)# 容器资源请求requests ResourceRequests(memory_in_gb1.0, cpu1.0)requirements ResourceRequirements(requestsrequests)# 创建容器container Container(namecontainer_name,imagecontainer_image,resourcesrequirements,portsports)# 容器组容器实例container_group ContainerGroup(locationlocation,containers[container],os_typeLinux,ip_addressip_address)# 创建容器实例container_group_result container_client.container_groups.begin_create_or_update(resource_group, container_name, container_group)print(fContainer instance {container_name} created successfully.)return container_group_resultdef stop(subscription_id:str, resource_group:str, container_name:str):# 使用默认凭证进行身份验证credential DefaultAzureCredential()# 创建容器实例管理客户端client ContainerInstanceManagementClient(credential, subscription_id)# 停止容器实例client.container_groups.stop(resource_group, container_name)print(fContainer instance {container_name} stoped successfully.)def start(subscription_id:str, resource_group:str, container_name:str):# 使用默认凭证进行身份验证credential DefaultAzureCredential()# 创建容器实例管理客户端client ContainerInstanceManagementClient(credential, subscription_id)# 停止容器实例client.container_groups.begin_start(resource_group, container_name)print(fContainer instance {container_name} started successfully.)def remove(subscription_id:str, resource_group:str, container_name:str):# 创建 Azure 认证凭证credentials DefaultAzureCredential()# 创建 ContainerInstanceManagementClientcontainer_client ContainerInstanceManagementClient(credentials, subscription_id)# 删除容器实例container_client.container_groups.begin_delete(resource_group, container_name)print(fContainer instance {container_name} deleted successfully.)def query_ip(subscription_id:str, resource_group:str, container_name:str):credential DefaultAzureCredential()client ContainerInstanceManagementClient(credential, subscription_id)container_group client.container_groups.get(resource_group, container_name)return container_group.ip_address测试代码
import sys
import os
import time# 此处根据你的项目选择包含目录以及导入导出模块
current_dir os.path.dirname(os.path.abspath(__file__))
parent_dir os.path.dirname(current_dir)
sys.path.append(parent_dir)
from core.containerhelpor import ContainerHelpordef main():print(containerhelpor test begin)# 这里填你的订阅idsub_id xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxxcontainer_name test # 你的容器名称resource_group jp # 你的资源组组名print(ContainerHelpor.create begin)ContainerHelpor.create(subscription_idsub_id,no_port8080,resource_groupresource_group,location Japan West,container_name container_name,# 镜像名称以及tag默认指向dockerhub的latsetcontainer_image )print(ContainerHelpor.stop begin)ContainerHelpor.stop(sub_id,resource_group,container_name)print(ContainerHelpor.start begin)is_not_start Trueretry_cnt 0while is_not_start:try:ContainerHelpor.start(sub_id,resource_group,container_name)is_not_start Falseexcept Exception as e: time.sleep(2)retry_cnt 1if retry_cnt 3:print(e)ContainerHelpor.remove(sub_id,resource_group,container_name)print(containerhelpor test failed)returnprint(ContainerHelpor.query_ip begin)retry_cnt 0ip Nonewhile ip is None:ipaddr ContainerHelpor.query_ip(sub_id,resource_group,container_name)ip ipaddr.iptime.sleep(2)retry_cnt 1if retry_cnt 10:print(query_ip failed, try it later)breakprint(ip)print(ContainerHelpor.remove begin)ContainerHelpor.remove(sub_id,resource_group,container_name)print(containerhelpor test pass)
if __name__ __main__:main()
