#
# VMware
#
from vcpsdk.plugins.spec import VcpSpecResource
CCI_VERSION = "1.1"
BUILD_VERSION = "20191001"
[ドキュメント]
class VcpSpecResourceVmware(VcpSpecResource):
"""
サンプルコード
.. code-block:: python
spec = sdk.get_spec("vmware", "small")
#
# 変更できること
#
# spec.num_nodes = 1
# spec.params_v = ['/opt:/opt']
# spec.params_e = ['USER_NAME=test']
# spec.ip_addresses = ['起動するnodeの静的なIPアドレス']
# VMware 依存
# https://www.terraform.io/docs/providers/vsphere/index.html
# spec.num_cpus = 4
# spec.memory = 1024 # MB
# spec.disk_size = 40
# クラウドイメージ(テンプレートとするVMWareの仮想マシンの名前)
# spec.cloud_image = 'niivcp-20181216'
# base containerにssh loginするためのssh公開鍵情報を設定
spec.set_ssh_pubkey('tmp/id_rsa.pub')
"""
version = CCI_VERSION + "+" + BUILD_VERSION
def __init__(self, provider_name, flavor, config_dir):
# flavor から spec を設定
super().__init__(provider_name, flavor, config_dir)
# spec attributes名の設定チェックの回避
super().__setattr__("vmware_cci_", None)
# credentail情報は、vcp_config から設定
self.vmware_cci_ = {"cci_version": CCI_VERSION}
self.vmware_cci_["user"] = self.vcp_config_["vmware"]["user"]
self.vmware_cci_["password"] = self.vcp_config_["vmware"]["password"]
self.unit_cci_["private_network"] = self.vcp_config_["vmware"][
"private_network"
] # VPNネットワーク名
# flavorから初期化
self.vmware_cci_["num_cpus"] = self.flavor_["num_cpus"]
self.vmware_cci_["memory"] = self.flavor_["memory"]
self.vmware_cci_["disk_size"] = self.flavor_["disk_size"]
self.vmware_cci_["cloud_image"] = "default"
# 初期化
self.vmware_cci_["ip_address_list"] = []
self.vmware_cci_["mac_address_list"] = []
def __str__(self):
text = """
========================
{provider_name}
------------------------
{unit_info}""".format(
provider_name=self.unit_cci_["cloud_provider"], unit_info=super().__str__()
)
text += """
num_cpus: {num_cpus}
memory: {memory}
disk_size: {disk_size}
cloud_image: {cloud_image}""".format_map(
self.vmware_cci_
)
return text
[ドキュメント]
def cci(self, name):
"""
CCI生成
:param name: unit名
:return: CCI文字列
"""
# cloud parameter 情報
my_cci = super().cci(name)
# yaml schema check
self.cci_schema_.validate(self.vmware_cci_, "vmware")
# cloud_params
my_cci += """
cloud_provider: vmware
cloud_params:
cci_version: "{cci_version}"
num_cpus: {num_cpus}
disk_size: {disk_size}
memory: {memory}
cloud_image: {cloud_image}
ip_address_list: {ip_address_list}
mac_address_list: {mac_address_list}
user: "{user}"
password: "{password}"
""".format_map(
self.vmware_cci_
)
return my_cci
# property: num_cpus
@property
def num_cpus(self):
"""
VMwareに依存するnum_cpus
.. note::
* VCP SDK flavorで設定可能
"""
return self.vmware_cci_["num_cpus"]
@num_cpus.setter
def num_cpus(self, v):
self.vmware_cci_["num_cpus"] = v
# property: memory
@property
def memory(self):
"""
VMwareに依存するmemory
.. note::
* VCP SDK flavorで設定可能
"""
return self.vmware_cci_["memory"]
@memory.setter
def memory(self, v):
self.vmware_cci_["memory"] = v
# property: disk_size
@property
def disk_size(self):
"""
VMwareに依存するdisk_size (単位:GB)
.. note::
* VCP SDK flavorで設定可能
"""
return self.vmware_cci_["disk_size"]
@disk_size.setter
def disk_size(self, v):
self.vmware_cci_["disk_size"] = v
# property: ip_addresses
@property
def ip_addresses(self):
"""
VMwareのVPC上の静的ip_address_list
"""
return self.vmware_cci_["ip_address_list"]
@ip_addresses.setter
def ip_addresses(self, v):
"""
VMwareのVPC上の静的ip_address_list
.. note::
`num_nodes` と `ip_addresses` は最後にセットされたほうが有効になる。
"""
if 0 < len(v):
# TODO; mac_addressesが指定されている場合は長さが同じことをチェックする(がここではない)
# TODO: ip_addresses, mac_addressesを同時セットできるわけではないのでspecを送るときにチェック
self.unit_cci_["num_nodes"] = len(v)
self.vmware_cci_["ip_address_list"] = v
# property: mac_addresses
@property
def mac_addresses(self):
"""
VMwareのmac_address_list
"""
return self.vmware_cci_["mac_address_list"]
@mac_addresses.setter
def mac_addresses(self, v):
"""
VMwareのmac_address_list
"""
if 0 < len(v):
# TODO; ip_addressesが指定されている場合は長さが同じことをチェックする(がここではない)
# TODO: ip_addresses, mac_addressesを同時セットできるわけではないのでspecを送るときにチェック
self.unit_cci_["num_nodes"] = len(v)
self.vmware_cci_["mac_address_list"] = v
# property: cloud_image
@property
def cloud_image(self):
"""
VMwareに依存するクラウドイメージ(テンプレートとするVMWareの仮想マシンの名前)
"""
return self.vmware_cci_["cloud_image"]
@cloud_image.setter
def cloud_image(self, v):
self.vmware_cci_["cloud_image"] = v
@VcpSpecResource.num_nodes.setter
def num_nodes(self, v):
"""
起動するnodeの個数
.. note::
`num_nodes` と `ip_addresses` は最後にセットされたほうが有効になる。
"""
# num_nodes: ipアドレス、macアドレス指定無しで台数を指定して起動
# ip_addresses, mac_address 値ともに台数もしていているのでnum_nodesは長さにセット
self.unit_cci_["num_nodes"] = v
self.vmware_cci_["ip_address_list"] = []
self.vmware_cci_["mac_address_list"] = []
def __setattr__(self, name, value):
"""
spec の attributes に不正な値を設定した場合に例外を発生
:param name: attributes名
:param value: 設定値
"""
if not hasattr(self, name):
raise AttributeError("spec resource has no attributes!! [{}]".format(name))
super().__setattr__(name, value)