1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
|
"""
Sample code that invokes SDKAPI.
"""
import os
import time
from zvmconnector import connector
# Guest properties
GUEST_USERID = 'SAMPLE02'
GUEST_PROFILE = 'osdflt'
GUEST_VCPUS = 1
GUEST_MEMORY = 1024 # in megabytes
GUEST_ROOT_DISK_SIZE = 1 # in gigabytes
DISK_POOL = 'ECKD:xcateckd'
# Image properties
IMAGE_PATH = '/root/images/0100.img'
IMAGE_OS_VERSION = 'rhel7'
# Network properties
GUEST_IP_ADDR = '192.168.127.112'
GATEWAY = '192.168.127.1'
CIDR = '192.168.127.0/24'
VSWITCH_NAME = 'xcatvsw2'
sdk_client = connector.ZVMConnector(connection_type='rest', port=8080)
def terminate_guest(userid):
"""Destroy a virtual machine.
Input parameters:
:userid: USERID of the guest, last 8 if length > 8
"""
sdk_client.send_request('guest_delete', userid)
def describe_guest(userid):
"""Get virtual machine basic information.
Input parameters:
:userid: USERID of the guest, last 8 if length > 8
"""
inst_info = sdk_client.send_request('guest_get_info', userid)
return inst_info
def start_guest(userid):
"""Power on a virtual machine.
Input parameters:
:userid: USERID of the guest, last 8 if length > 8
"""
sdk_client.send_request('guest_start', userid)
def stop_guest(userid):
"""Shutdown a virtual machine.
Input parameters:
:userid: USERID of the guest, last 8 if length > 8
"""
sdk_client.send_request('guest_start', userid)
def capture_guest(userid):
"""Caputre a virtual machine image.
Input parameters:
:userid: USERID of the guest, last 8 if length > 8
Output parameters:
:image_name: Image name that captured
"""
# check power state, if down, start it
ret = sdk_client.send_request('guest_get_power_state', userid)
power_status = ret['output']
if power_status == 'off':
sdk_client.send_request('guest_start', userid)
# TODO: how much time?
time.sleep(1)
# do capture
image_name = 'image_captured_%03d' % (time.time() % 1000)
sdk_client.send_request('guest_capture', userid, image_name,
capture_type='rootonly', compress_level=6)
return image_name
def import_image(image_path, os_version):
"""Import image.
Input parameters:
:image_path: Image file path
:os_version: Operating system version. e.g. rhel7.2
"""
image_name = os.path.basename(image_path)
print("Checking if image %s exists or not, import it if not exists" %
image_name)
image_info = sdk_client.send_request('image_query', imagename=image_name)
if 'overallRC' in image_info and image_info['overallRC']:
print("Importing image %s ..." % image_name)
url = 'file://' + image_path
ret = sdk_client.send_request('image_import', image_name, url,
{'os_version': os_version})
else:
print("Image %s already exists" % image_name)
def delete_image(image_name):
"""Delete image.
Input parameters:
:image_name: Image name that defined in xCAT image repo
"""
sdk_client.send_request('image_delete', image_name)
def _run_guest(userid, image_path, os_version, profile,
cpu, memory, network_info, disks_list):
"""Deploy and provision a virtual machine.
Input parameters:
:userid: USERID of the guest, no more than 8.
:image_name: path of the image file
:os_version: os version of the image file
:profile: profile of the userid
:cpu: the number of vcpus
:memory: memory
:network_info: dict of network info.members:
:ip_addr: ip address of vm
:gateway: gateway of net
:vswitch_name: switch name
:cidr: CIDR
:disks_list: list of disks to add.eg:
disks_list = [{'size': '3g',
'is_boot_disk': True,
'disk_pool': 'ECKD:xcateckd'}]
"""
# Import image if not exists
import_image(image_path, os_version)
# Start time
spawn_start = time.time()
# Create userid
print("Creating userid %s ..." % userid)
ret = sdk_client.send_request('guest_create', userid, cpu, memory,
disk_list=disks_list,
user_profile=profile)
if ret['overallRC']:
print 'guest_create error:%s' % ret
return -1
# Deploy image to root disk
image_name = os.path.basename(image_path)
print("Deploying %s to %s ..." % (image_name, userid))
ret = sdk_client.send_request('guest_deploy', userid, image_name)
if ret['overallRC']:
print 'guest_deploy error:%s' % ret
return -2
# Create network device and configure network interface
print("Configuring network interface for %s ..." % userid)
ret = sdk_client.send_request('guest_create_network_interface', userid,
os_version, [network_info])
if ret['overallRC']:
print 'guest_create_network error:%s' % ret
return -3
# Couple to vswitch
ret = sdk_client.send_request('guest_nic_couple_to_vswitch', userid,
'1000', network_info['vswitch_name'])
if ret['overallRC']:
print 'guest_nic_couple error:%s' % ret
return -4
# Grant user
ret = sdk_client.send_request('vswitch_grant_user',
network_info['vswitch_name'],
userid)
if ret['overallRC']:
print 'vswitch_grant_user error:%s' % ret
return -5
# Power on the vm
print("Starting guest %s" % userid)
ret = sdk_client.send_request('guest_start', userid)
if ret['overallRC']:
print 'guest_start error:%s' % ret
return -6
# End time
spawn_time = time.time() - spawn_start
print "Instance-%s pawned succeeded in %s seconds" % (userid, spawn_time)
def run_guest():
""" A sample for quick deploy and start a virtual guest."""
global GUEST_USERID
global GUEST_PROFILE
global GUEST_VCPUS
global GUEST_MEMORY
global GUEST_ROOT_DISK_SIZE
global DISK_POOL
global IMAGE_PATH
global IMAGE_OS_VERSION
global GUEST_IP_ADDR
global GATEWAY
global CIDR
global VSWITCH_NAME
network_info = {'ip_addr': GUEST_IP_ADDR,
'gateway_addr': GATEWAY,
'cidr': CIDR,
'vswitch_name': VSWITCH_NAME}
disks_list = [{'size': '%ig' % GUEST_ROOT_DISK_SIZE,
'is_boot_disk': True,
'disk_pool': DISK_POOL}]
_run_guest(GUEST_USERID, IMAGE_PATH, IMAGE_OS_VERSION, GUEST_PROFILE,
GUEST_VCPUS, GUEST_MEMORY, network_info, disks_list)
|
