基础环境

python 脚本文件头建议加入“ #encoding:utf-8”避免编码错误；测试脚本代码用python3命令执行与测试；在linux系统中安装Python3 并安装request等依赖包

配置：有一台搭建好的open stack平台

           导入python源等依赖包 

在controller节点/root/目录下编写api_image_manager.py脚本

要求：1.创建镜像（创建之前删除同名镜像）

           2.查询镜像

#获取token值
import requests
import json
import time
import argparse
try:
    url = "http://192.168.1.101:5000/v3/auth/tokens"
    body = {
        "auth": {"identity":{"methods":["password"],"password":{
            "user":{"domain":{"name":"demo"},"name":"admin","password":"000000"}}},
                 "scope":{"project":{"domain":{"name":"demo"},"name":"admin"}}}}
    headers= {
        "Content-Type":"application/json"
    }
    token = requests.post(url,data=json.dumps(body),headers=headers).headers['X-Subject-Token']
    headers={"X-Auth-Token":token}
    print(token)

except Exception as e:
    print(f"debeat{str(e)}")
    exit(0)


#定义class类
class create_glance:
    def __init__(self,headers,url):
        self.headers=headers
        self.url=url

    def delete_images(self,image_name):
        result = json.loads(requests.get(self.url,headers=self.headers).text)
        for i in result['images']:
            if i['name'] == image_name:
                
      requests.delete(f"http://192.168.1.101:9292/v2/images/{i['id']}",headers=self.headers)
    def create_glance(self,image_name:str,container_format="bare",disk_format="qcow2"):
        body = {
            "name": image_name,
            "container_format": container_format,
            "disk_foramt": disk_format
        }
        status_code = requests.post(self.url,data=json.dumps(body),headers=self.headers)
        print(status_code.json['names'])
    def get_image_id(self,image_name):
        result = json.loads(requests.get(self.url, headers=self.headers).text)
        for i in result['images']:
            if i['name'] == image_name:
                return i['id']

    def updata_glance(self,image_name:str,file_path=''):
        self.url=self.url+"/"+self.get_image_id(image_name)+'/file'
        self.headers['Content-Type'] = 'application/octet-stream'
        status_code = requests.put(self.url,data=open(file_path,'rb').read(),headers=self.headers)
    def show_image(self,image_name):
        result = json.loads(requests.get(self.url, headers=self.headers).text)
        for i in result['images']:
            if i['name'] == image_name:
                return i['id']
create_glance=create_glance(headers,"http://192.168.1.101:9292/v2/images")
create_glance.delete_images("giant fox")
create_glance.create_glance("giant fox")
print(create_glance.show_image("giant fox"))
create_glance.updata_glance('giant fox',file_path="./CentOS_7.5_x86_64_XD.qcow2")

创建镜像时 可能会出现一直排队的情况 在创建虚拟机时可以使用已经在运行的镜像

 +--------------------------------------+-----------+--------+
| ID                                   | Name      | Status |
+--------------------------------------+-----------+--------+
| 0eede4fd-be01-4508-9f21-7089bc166a26 | centos    | active |
| 36fc6cfc-9ad1-4189-9522-d8addccafa60 | giant fox | queued |
+--------------------------------------+-----------+--------+

 创建一台云主机镜像已经创建好，其他的自行创建

import json
import requests
import time

try:
    url = "http://192.168.1.101:5000/v3/auth/tokens"
    body = {"auth":{"identity":{"methods":["password"],"password":{
            "user":{"domain":{"name":"demo"},"name":"admin","password":"000000"}}},
                "scope":{"project":{"domain":{"name":"demo"},"name":"admin"}}}}
    headers = {"Content-Type":"application/json"}
    Token = requests.post(url,json.dumps(body),headers=headers).headers["X-Subject-Token"]
    headers = {"X-Auth-Token":Token}
    print(Token)
except Exception as e:
    print(f"失败信息如下：{str(e)}")
    exit(0)


class create_vm:
    def __init__(self,headers):
        self.headers=headers

    def delete_vm(self):
        result = requests.get("http://192.168.1.101:8774/v2.1/servers",headers=self.headers)
        for i in result.json()['servers']:
            if i['name'] == 'test_vm':
                requests.delete(f"http://192.168.1.101:8774/v2.1/servers/{i['id']}",headers=self.headers)

    def get_image_id(self):
        result = requests.get("http://192.168.1.101:9292/v2/images",headers=self.headers)
        for i in result.json()['images']:
            if i['name'] == "giant fox":
                self.image_id=i['id']

    def get_network_id(self):
        result = requests.get("http://192.168.1.101:9696/v2.0/networks",headers=self.headers)
        for i in result.json()['networks']:
            if i['name'] == 'network':
                self.network_id=i['id']

    def get_flavor_id(self):
        result = requests.get("http://192.168.1.101:8774/v2.1/flavors",headers=self.headers)
        for i in result.json()['flavors']:
            if i['names'] == '4g4u100g':
                self.flavor_id=i['id']

    def create_vm(self):
        self.delete_vm()
        self.get_flavor_id()
        self.get_image_id()
        self.get_network_id()
        data = {
            "server": {
                "name": "test_vm",
                "imageRef": self.image_id,
                "flavorRef": self.flavor_id,
                "networks": [{'uuid':self.network_id}]
            }
        }
        status_code = requests.post("http://192.168.1.101:8774/v2.1/servers",headers=self.headers,data=json.dumps(data))
        print(status_code.json())


create_vm=create_vm(headers=headers)
create_vm.create_vm()

创建成功

+--------------------------------------+---------+--------+----------------------+--------+----------+
| ID                                   | Name    | Status | Networks             | Image  | Flavor   |
+--------------------------------------+---------+--------+----------------------+--------+----------+
| f2d7a396-9bec-4074-9e35-c39e4d556756 | test_vm | ACTIVE | network=192.168.1.7  | centos | 4g4u100g