#
# AWS
#
from vcpsdk.plugins.spec import VcpSpecResource
import vcplib.occtr # VcNodeの型チェックのため
CCI_VERSION = "1.2"
BUILD_VERSION = "20191001"
[ドキュメント]
class VcpSpecResourceAws(VcpSpecResource):
"""
サンプルコード
.. code-block:: python
spec = sdk.get_spec("aws", "small")
#
# 変更できること
#
# spec.num_nodes = 1
# spec.params_v = ['/opt:/opt']
# spec.params_e = ['USER_NAME=test']
# spec.ip_addresses = ['起動するnodeの静的なIPアドレス']
# aws依存パラメータ
# https://www.terraform.io/docs/providers/aws/index.html
# spec.instance_type = 'm4.large'
# spec.volume_size = 40
# spec.volume_type = "standard" # standard|io1|gp2|sc1|st1
# 追加で使用するVolume
# spec.disks = ['vol-08cbb04b35c8c9545'] # volume_id 指定
# or
# my_disks = disk_unit.find_nodes()
# spec.disks = [my_disks[0]] # VC disk指定
# cloud上のタグ設定
# spec.set_tag('key1', 'value1')
# spec.set_tag('key2', 'value2')
# cloud上のAMIイメージ設定
# spec.cloud_image = 'niivcp-20170616'
# 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__("aws_cci_", None)
# credentail情報は、vcp_config から設定
self.aws_cci_ = {"cci_version": CCI_VERSION}
self.aws_cci_["access_key"] = self.vcp_config_["aws"]["access_key"]
self.aws_cci_["secret_key"] = self.vcp_config_["aws"]["secret_key"]
self.unit_cci_["private_network"] = self.vcp_config_["aws"][
"private_network"
] # VPNネットワーク名
# flavorから初期化
self.aws_cci_["instance_type"] = self.flavor_["instance_type"]
self.aws_cci_["volume_size"] = self.flavor_["volume_size"]
self.aws_cci_["volume_type"] = self.flavor_["volume_type"]
self.aws_cci_["cloud_image"] = "default"
# 初期化
self.aws_cci_["ip_address_list"] = []
self.aws_cci_["volume_id"] = []
def __str__(self):
text = """
========================
{provider_name}
------------------------
{unit_info}""".format(
provider_name=self.unit_cci_["cloud_provider"], unit_info=super().__str__()
)
text += """
instance_type: {instance_type}
volume_size: {volume_size}
volume_type: {volume_type}
volume_id: {volume_id}
cloud_image: {cloud_image}
ip_address_list: {ip_address_list}""".format_map(
self.aws_cci_
)
text += """
tags: {}
========================""".format(
self.tags_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.aws_cci_, "aws")
# cloud_params
my_cci += """
cloud_provider: aws
cloud_params:
cci_version: "{cci_version}"
instance_type: {instance_type}
volume_size: {volume_size}
volume_type: {volume_type}
cloud_image: {cloud_image}
ip_address_list: {ip_address_list}
access_key: {access_key}
volume_id: {volume_id}
secret_key: {secret_key}""".format_map(
self.aws_cci_
)
# cloud tagのcci文字列生成
my_cci += self.cci_tags()
return my_cci
# property: instance_type
@property
def instance_type(self):
"""
AWSに依存するinstance_type
.. note::
* VCP SDK flavorで設定可能
"""
return self.aws_cci_["instance_type"]
@instance_type.setter
def instance_type(self, v):
self.aws_cci_["instance_type"] = v
# property: volume_size
@property
def volume_size(self):
"""
AWSに依存するvolume_size (単位:GB)
.. note::
* VCP SDK flavorで設定可能
"""
return self.aws_cci_["volume_size"]
@volume_size.setter
def volume_size(self, v):
self.aws_cci_["volume_size"] = v
# property: volume_type
@property
def volume_type(self):
"""
AWSに依存するvolume_type
.. note::
* VCP SDK flavorで設定可能
"""
return self.aws_cci_["volume_type"]
@volume_type.setter
def volume_type(self, v):
self.aws_cci_["volume_type"] = v
# property: disks
@property
def disks(self):
"""
AWSに依存するEBS volume id
"""
return self.aws_cci_["volume_id"]
@disks.setter
def disks(self, v):
# volume_id は、vol-xxxxxxx 形式 と VcNode の2種類がある
volumes = []
for volume in v:
if isinstance(volume, vcplib.occtr.VcNode):
# VcNode 指定
volume_id = "vcp:{vc_id}:{unit_name}:{disk_id}".format(
vc_id=volume.vc.vcid, unit_name=volume.unit.name, disk_id=volume.id
)
else:
volume_id = volume # vol-xxxxxx指定
volumes.append(volume_id)
self.aws_cci_["volume_id"] = volumes
# property: ip_addresses
@property
def ip_addresses(self):
"""
AWSのVPC上の静的ip_address_list
"""
return self.aws_cci_["ip_address_list"]
@ip_addresses.setter
def ip_addresses(self, v):
"""
AWSのVPC上の静的ip_address_list
.. note::
`num_nodes` と `ip_addresses` は最後にセットされたほうが有効になる。
"""
if 0 < len(v):
self.unit_cci_["num_nodes"] = len(v)
self.aws_cci_["ip_address_list"] = v
# property: cloud_image
@property
def cloud_image(self):
"""
AWSに依存するAMIのイメージ名
"""
return self.aws_cci_["cloud_image"]
@cloud_image.setter
def cloud_image(self, v):
self.aws_cci_["cloud_image"] = v
@VcpSpecResource.num_nodes.setter
def num_nodes(self, v):
"""
起動するnodeの個数
.. note::
`num_nodes` と `ip_addresses` は最後にセットされたほうが有効になる。
"""
self.unit_cci_["num_nodes"] = v
self.aws_cci_["ip_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)