#
# OracleCloud
#
from vcpsdk.plugins.spec import VcpSpecResource
import vcplib.occtr # VcNodeの型チェックのため
CCI_VERSION = "1.0"
BUILD_VERSION = "20200331"
[ドキュメント]
class VcpSpecResourceOracle(VcpSpecResource):
"""
サンプルコード
.. code-block:: python
spec = sdk.get_spec("oracle", "small")
#
# 変更できること
#
# spec.num_nodes = 1
# spec.params_v = ['/opt:/opt']
# spec.params_e = ['USER_NAME=test']
# spec.ip_addresses = ['起動するnodeの静的なIPアドレス']
# OracleCloud依存
# https://docs.oracle.com/cd/E97706_01/Content/Compute/References/computeshapes.htm
# spec.shape = 'VM.Standard.E2.1.Micro'
# spec.image = "vcp/base:1.6.1"
# spec.boot_volume_size_in_gbs = 100
# 追加で使用するVolume
# spec.disks = ['ocid1.volume.oc1.ap-tokyo-1.ab...'] # volume_id 指定
# or
# my_disks = disk_unit.find_nodes()
# spec.disks = [my_disks[0]] # VC disk指定
# cloud上のVMイメージ設定
# spec.cloud_image = 'niivcp-20170616'
# cloud上のタグ設定
# spec.set_tag('key1', 'value1')
# spec.set_tag('key2', 'value2')
# 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__("oracle_cci_", None)
# credentail情報は、vcp_config から設定
self.oracle_cci_ = {"cci_version": CCI_VERSION}
self.oracle_cci_["user_ocid"] = self.vcp_config_["oracle"]["user_ocid"]
self.oracle_cci_["fingerprint"] = self.vcp_config_["oracle"]["fingerprint"]
self.oracle_cci_["private_key"] = self.vcp_config_["oracle"]["private_key"]
self.unit_cci_["private_network"] = self.vcp_config_["oracle"][
"private_network"
] # VPNネットワーク名
# flavorから初期化
self.oracle_cci_["shape"] = self.flavor_["shape"]
self.oracle_cci_["boot_volume_size_in_gbs"] = self.flavor_[
"boot_volume_size_in_gbs"
]
self.oracle_cci_["cloud_image"] = "default"
self.oracle_cci_["ip_address_list"] = []
self.oracle_cci_["volume_id"] = []
def __str__(self):
text = """
========================
{provider_name}
------------------------
{unit_info}
""".format(
provider_name=self.unit_cci_["cloud_provider"], unit_info=super().__str__()
)
text += """
cci_version: "{cci_version}"
shape: {shape}
boot_volume_size_in_gbs: {boot_volume_size_in_gbs}
disks: {volume_id}
cloud_image: {cloud_image}
ip_address_list: {ip_address_list}
volume_id: {volume_id}
========================""".format_map(
self.oracle_cci_
)
text += """
tags: {}
========================""".format(
self.tags_cci_
)
return text
# buid cci from property
[ドキュメント]
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.oracle_cci_, "oracle")
my_cci = super().cci(name)
my_cci += """
cloud_provider: oracle
cloud_params:
cci_version: "{cci_version}"
shape: {shape}
boot_volume_size_in_gbs: {boot_volume_size_in_gbs}
ip_address_list: {ip_address_list}
volume_id: {volume_id}
cloud_image: {cloud_image}
user_ocid: {user_ocid}
fingerprint: {fingerprint}
private_key: {private_key}""".format_map(
self.oracle_cci_
)
# cloud tagのcci文字列生成
my_cci += self.cci_tags()
return my_cci
# property: shape
@property
def shape(self):
"""
OracleCloudに依存する shape
.. note::
* VCP SDK flavorで設定可能
"""
return self.oracle_cci_["shape"]
@shape.setter
def shape(self, v):
self.oracle_cci_["shape"] = v
# property: boot_volume_size_in_gbs
@property
def boot_volume_size_in_gbs(self):
"""
OracleCloudに依存する boot_volume_size_in_gbs (単位:GB)
.. note::
* VCP SDK flavorで設定可能
"""
return self.oracle_cci_["boot_volume_size_in_gbs"]
@boot_volume_size_in_gbs.setter
def boot_volume_size_in_gbs(self, v):
self.oracle_cci_["boot_volume_size_in_gbs"] = v
# property: disks
@property
def disks(self):
"""
Oracleに依存するBlock Volume のOCID
"""
return self.oracle_cci_["volume_id"]
@disks.setter
def disks(self, v):
# volume_id は、ocid1.volume.oc1.ap-tokyo-1.abx.. 形式 と 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 # OCID固定
volumes.append(volume_id)
self.oracle_cci_["volume_id"] = volumes
# property: ip_addresses
@property
def ip_addresses(self):
"""
OracleCloudのVPC上の静的ip_address_list
"""
return self.oracle_cci_["ip_address_list"]
@ip_addresses.setter
def ip_addresses(self, v):
"""
OracleのVPC上の静的ip_address_list
.. note::
`num_nodes` と `ip_addresses` は最後にセットされたほうが有効になる。
"""
if 0 < len(v):
self.unit_cci_["num_nodes"] = len(v)
self.oracle_cci_["ip_address_list"] = v
# property: cloud_image
@property
def cloud_image(self):
"""
OracleCloudに依存するcloud_image
"""
return self.oracle_cci_["cloud_image"]
@cloud_image.setter
def cloud_image(self, v):
self.oracle_cci_["cloud_image"] = v
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)