openstack/tacker
Code Issues Proposed changes

Sample script of pod-affinity in kubernetes cluster

Browse Source 
This patch support pods to be scheduled on the different
physical Compute server. Through the policy attribute of
the VDU, the Worker node can be instantiated on different
Compute server. Then we can obtain the Compute information
where the worker node is located, and use it as the label
of the Worker node. Finally, pod will be deployed on
different Worker nodes based on labels.

Implements: blueprint hardware-aware-pod-affinity
Change-Id: I71dc5bed94654c19bace77c11fe1202ccdc549c9
This commit is contained in:
LiangLu 2021-04-21 19:27:23 +09:00 committed by ueha.ayumu
parent f24afcf705
commit f7796901ea
11 changed files with 1325 additions and 128 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

725
doc/source/user/mgmt_driver_deploy_k8s_usage_guide.rst
View File

@ -15,6 +15,13 @@ customizations are specified by "interface" definition in
This user guide aims to deploy Kubernetes cluster via This user guide aims to deploy Kubernetes cluster via
Mgmt Driver which is customized by user. Mgmt Driver which is customized by user.
If you want to deploy Pods on different physical compute server,
this user guide provide a way to support it. Tacker can deploy
worker nodes of Kubernetes cluster on different physical compute
server, and then deploy Pods with anti-affinity rule on this cluster.
You can refer to chapter
`Hardware-aware Affinity For Pods on Kubernetes Cluster`_ for details.
2. Use Cases 2. Use Cases
^^^^^^^^^^^^ ^^^^^^^^^^^^
In the present user guide, two cases are supported with the sample Mgmt Driver In the present user guide, two cases are supported with the sample Mgmt Driver
@ -22,7 +29,7 @@ and VNF Package providing two deployment flavours in VNFD:
* simple: Deploy one master node with worker nodes. In this * simple: Deploy one master node with worker nodes. In this
case, it supports to scale worker node and heal worker node. case, it supports to scale worker node and heal worker node.
* complex: Deploy three(or more) master nodes with worker nodes. In * complex: Deploy three (or more) master nodes with worker nodes. In
this case, it supports to scale worker node and heal worker this case, it supports to scale worker node and heal worker
node and master node. node and master node.
@ -60,12 +67,12 @@ simple Kubernetes cluster architecture:
| | | |
+-------------------------------+ +-------------------------------+
2. Complex : High Availability(HA) Configuration 2. Complex : High Availability (HA) Configuration
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
Kubernetes is known for its resilience and reliability. This is possible Kubernetes is known for its resilience and reliability. This is possible
by ensuring that the cluster does not have any single points of failure. by ensuring that the cluster does not have any single points of failure.
Because of this, to have a highly availability(HA) cluster, you need to have Because of this, to have a highly availability (HA) cluster, you need to have
multiple master nodes. We provide the sample script which can be used to multiple master nodes. We provide the sample script which can be used to
deploy an HA Kubernetes cluster. The diagram below shows HA Kubernetes deploy an HA Kubernetes cluster. The diagram below shows HA Kubernetes
cluster architecture: cluster architecture:
@ -73,7 +80,7 @@ cluster architecture:
.. code-block:: console .. code-block:: console
+-----------------------------------------------------------+ +-----------------------------------------------------------+
| High availability(HA) Kubernetes cluster | | High availability (HA) Kubernetes cluster |
| +-------------------------------------+ | | +-------------------------------------+ |
| | | | | | | |
| | +---------------+ +---------+ | | | | +---------------+ +---------+ | |
@ -123,7 +130,7 @@ cluster architecture:
Mgmt Driver supports the construction of an HA master node through the Mgmt Driver supports the construction of an HA master node through the
``instantiate_end`` process as follows: ``instantiate_end`` process as follows:
1. Identify the VMs created by OpenStackInfraDriver(which is 1. Identify the VMs created by OpenStackInfraDriver (which is
used to create OpenStack resources). used to create OpenStack resources).
2. Invoke the script to configure for HAProxy_ (a reliable solution 2. Invoke the script to configure for HAProxy_ (a reliable solution
offering high availability, load balancing, and proxying for offering high availability, load balancing, and proxying for
@ -135,7 +142,7 @@ Mgmt Driver supports the construction of an HA master node through the
Preparations Preparations
------------ ------------
If you use the sample script to deploy your Kubernetes cluster, you need If you use the sample script to deploy your Kubernetes cluster, you need
to ensure that the virtual machine(VM) you created on the OpenStack can to ensure that the virtual machine (VM) you created on the OpenStack can
access the external network. If you installed the tacker access the external network. If you installed the tacker
service through ``devstack``, the following is an optional way to set the service through ``devstack``, the following is an optional way to set the
network configuration. network configuration.
@ -255,7 +262,7 @@ cli command:
- get the nfv project's default security group id - get the nfv project's default security group id
.. code-block:: console .. code-block:: console
$ auth='--os-username nfv_user --os-project-name nfv --os-password devstack --os-auth-url http://127.0.0.1/identity --os-project-domain-name Default --os-user-domain-name Default' $ auth='--os-username nfv_user --os-project-name nfv --os-password devstack --os-auth-url http://127.0.0.1/identity --os-project-domain-name Default --os-user-domain-name Default'
$ nfv_project_id=`openstack project list $auth | grep -w '| nfv' | awk '{print $2}'` $ nfv_project_id=`openstack project list $auth | grep -w '| nfv' | awk '{print $2}'`
@ -263,7 +270,7 @@ cli command:
- add new security group rule into default security group using the id above - add new security group rule into default security group using the id above
.. code-block:: console .. code-block:: console
#ssh 22 port #ssh 22 port
$ openstack security group rule create --protocol tcp --dst-port 22 $default_id $auth $ openstack security group rule create --protocol tcp --dst-port 22 $default_id $auth
@ -292,7 +299,7 @@ some configurations are required.
1. Download Ubuntu Image 1. Download Ubuntu Image
~~~~~~~~~~~~~~~~~~~~~~~~~~~ ~~~~~~~~~~~~~~~~~~~~~~~~~~~
You can download the ubuntu image(version 20.04) from the official website. You can download the ubuntu image (version 20.04) from the official website.
The command is shown below: The command is shown below:
.. code-block:: console .. code-block:: console
@ -354,7 +361,7 @@ First, copy the sample script that was stored in
You have to register ``kubernetes_mgmt.py`` in the operation environment You have to register ``kubernetes_mgmt.py`` in the operation environment
of the tacker. of the tacker.
The sample script(``kubernetes_mgmt.py``) uses the The sample script (``kubernetes_mgmt.py``) uses the
``mgmt-drivers-kubernetes`` field to register in Mgmt Driver. ``mgmt-drivers-kubernetes`` field to register in Mgmt Driver.
.. code-block:: console .. code-block:: console
@ -561,7 +568,7 @@ You must place the directory corresponding to **deployment_flavour** stored in
the **Definitions/** under the **BaseHOT/** directory, and store the the **Definitions/** under the **BaseHOT/** directory, and store the
Base HOT files in it. Base HOT files in it.
In this guide, there are two cases(simple and complex) in this VNF Package, so In this guide, there are two cases (simple and complex) in this VNF Package, so
there are two directories under **BaseHOT/** directory. The sample files are there are two directories under **BaseHOT/** directory. The sample files are
shown below: shown below:
@ -845,7 +852,7 @@ The KeyValuePairs is shown in table below:
.. code-block:: .. code-block::
## List of additionalParams.k8s_cluster_installation_param(specified by user) ## List of additionalParams.k8s_cluster_installation_param (specified by user)
+------------------+-----------+---------------------------------------------+-------------------+ +------------------+-----------+---------------------------------------------+-------------------+
| parameter | data type | description | required/optional | | parameter | data type | description | required/optional |
+------------------+-----------+---------------------------------------------+-------------------+ +------------------+-----------+---------------------------------------------+-------------------+
@ -876,7 +883,7 @@ The KeyValuePairs is shown in table below:
| | | master node's ssh ip | | | | | master node's ssh ip | |
+------------------+-----------+---------------------------------------------+-------------------+ +------------------+-----------+---------------------------------------------+-------------------+
| nic_cp_name | String | Resource name of port corresponding to the | required | | nic_cp_name | String | Resource name of port corresponding to the | required |
| | | master node's nic ip(which used for | | | | | master node's nic ip (which used for | |
| | | deploying Kubernetes cluster) | | | | | deploying Kubernetes cluster) | |
+------------------+-----------+---------------------------------------------+-------------------+ +------------------+-----------+---------------------------------------------+-------------------+
| username | String | Username for VM access | required | | username | String | Username for VM access | required |
@ -891,7 +898,7 @@ The KeyValuePairs is shown in table below:
| | | cluster ip | | | | | cluster ip | |
+------------------+-----------+---------------------------------------------+-------------------+ +------------------+-----------+---------------------------------------------+-------------------+
| cluster_fip_name | String | Resource name of the Port corresponding to | optional | | cluster_fip_name | String | Resource name of the Port corresponding to | optional |
| | | cluster ip used for reigstering vim. If you | | | | | cluster ip used for registering vim. If you | |
| | | use floating ip as ssh ip, it must be set | | | | | use floating ip as ssh ip, it must be set | |
+------------------+-----------+---------------------------------------------+-------------------+ +------------------+-----------+---------------------------------------------+-------------------+
@ -907,7 +914,7 @@ The KeyValuePairs is shown in table below:
| | | worker node's ssh ip | | | | | worker node's ssh ip | |
+------------------+-----------+---------------------------------------------+-------------------+ +------------------+-----------+---------------------------------------------+-------------------+
| nic_cp_name | String | Resource name of port corresponding to the | required | | nic_cp_name | String | Resource name of port corresponding to the | required |
| | | worker node's nic ip(which used for | | | | | worker node's nic ip (which used for | |
| | | deploying Kubernetes cluster) | | | | | deploying Kubernetes cluster) | |
+------------------+-----------+---------------------------------------------+-------------------+ +------------------+-----------+---------------------------------------------+-------------------+
| username | String | Username for VM access | required | | username | String | Username for VM access | required |
@ -1833,7 +1840,7 @@ Following are two samples of scaling request body:
} }
.. note:: .. note::
Only the worker node can be scaled out(in). The current function does Only the worker node can be scaled out (in). The current function does
not support scale master node. not support scale master node.
2. Execute the Scale Operations 2. Execute the Scale Operations
@ -1865,21 +1872,23 @@ the number of registered worker nodes in the Kubernetes cluster
should be updated. should be updated.
See `Heat CLI reference`_ for details on Heat CLI commands. See `Heat CLI reference`_ for details on Heat CLI commands.
Stack information before scaling: * Stack information before scaling:
.. code-block:: console .. code-block:: console
$ openstack stack resource list vnf-c5215213-af4b-4080-95ab-377920474e1a -n 2 --filter type=base_hot_nested_worker.yaml -c resource_name -c physical_resource_id -c resource_type -c resource_status $ openstack stack resource list vnf-c5215213-af4b-4080-95ab-377920474e1a -n 2 --filter \
type=complex_nested_worker.yaml -c resource_name -c physical_resource_id -c resource_type \
-c resource_status
+---------------+--------------------------------------+-----------------------------+-----------------+ +---------------+--------------------------------------+-----------------------------+-----------------+
| resource_name | physical_resource_id | resource_type | resource_status | | resource_name | physical_resource_id | resource_type | resource_status |
+---------------+--------------------------------------+-----------------------------+-----------------+ +---------------+--------------------------------------+-----------------------------+-----------------+
| lwljovool2wg | 07b79bbe-d0b2-4df0-8775-6202142b6054 | base_hot_nested_worker.yaml | CREATE_COMPLETE | | lwljovool2wg | 07b79bbe-d0b2-4df0-8775-6202142b6054 | complex_nested_worker.yaml | CREATE_COMPLETE |
| n6nnjta4f4rv | 56c9ec6f-5e52-44db-9d0d-57e3484e763f | base_hot_nested_worker.yaml | CREATE_COMPLETE | | n6nnjta4f4rv | 56c9ec6f-5e52-44db-9d0d-57e3484e763f | complex_nested_worker.yaml | CREATE_COMPLETE |
+---------------+--------------------------------------+-----------------------------+-----------------+ +---------------+--------------------------------------+-----------------------------+-----------------+
worker node in Kubernetes cluster before scaling: * worker node in Kubernetes cluster before scaling:
.. code-block:: console .. code-block:: console
$ ssh ubuntu@10.10.0.80 $ ssh ubuntu@10.10.0.80
$ kubectl get node $ kubectl get node
@ -1890,29 +1899,31 @@ worker node in Kubernetes cluster before scaling:
worker18 Ready <none> 10m v1.20.4 worker18 Ready <none> 10m v1.20.4
worker20 Ready <none> 4m v1.20.4 worker20 Ready <none> 4m v1.20.4
Scaling out execution of the vnf_instance: * Scaling out execution of the vnf_instance:
.. code-block:: console .. code-block:: console
$ openstack vnflcm scale --type "SCALE_OUT" --aspect-id worker_instance --number-of-steps 1 c5215213-af4b-4080-95ab-377920474e1a $ openstack vnflcm scale --type "SCALE_OUT" --aspect-id worker_instance --number-of-steps 1 c5215213-af4b-4080-95ab-377920474e1a
Scale request for VNF Instance c5215213-af4b-4080-95ab-377920474e1a has been accepted. Scale request for VNF Instance c5215213-af4b-4080-95ab-377920474e1a has been accepted.
Stack information after scaling out: * Stack information after scaling out:
.. code-block:: console .. code-block:: console
$ openstack stack resource list vnf-c5215213-af4b-4080-95ab-377920474e1a -n 2 --filter type=base_hot_nested_worker.yaml -c resource_name -c physical_resource_id -c resource_type -c resource_status $ openstack stack resource list vnf-c5215213-af4b-4080-95ab-377920474e1a -n 2 --filter \
type=complex_nested_worker.yaml -c resource_name -c physical_resource_id -c resource_type \
-c resource_status
+---------------+--------------------------------------+-----------------------------+-----------------+ +---------------+--------------------------------------+-----------------------------+-----------------+
| resource_name | physical_resource_id | resource_type | resource_status | | resource_name | physical_resource_id | resource_type | resource_status |
+---------------+--------------------------------------+-----------------------------+-----------------+ +---------------+--------------------------------------+-----------------------------+-----------------+
| lwljovool2wg | 07b79bbe-d0b2-4df0-8775-6202142b6054 | base_hot_nested_worker.yaml | UPDATE_COMPLETE | | lwljovool2wg | 07b79bbe-d0b2-4df0-8775-6202142b6054 | complex_nested_worker.yaml | UPDATE_COMPLETE |
| n6nnjta4f4rv | 56c9ec6f-5e52-44db-9d0d-57e3484e763f | base_hot_nested_worker.yaml | UPDATE_COMPLETE | | n6nnjta4f4rv | 56c9ec6f-5e52-44db-9d0d-57e3484e763f | complex_nested_worker.yaml | UPDATE_COMPLETE |
| z5nky6qcodlq | f9ab73ff-3ad7-40d2-830a-87bd0c45af32 | base_hot_nested_worker.yaml | CREATE_COMPLETE | | z5nky6qcodlq | f9ab73ff-3ad7-40d2-830a-87bd0c45af32 | complex_nested_worker.yaml | CREATE_COMPLETE |
+---------------+--------------------------------------+-----------------------------+-----------------+ +---------------+--------------------------------------+-----------------------------+-----------------+
worker node in Kubernetes cluster after scaling out: * worker node in Kubernetes cluster after scaling out:
.. code-block:: console .. code-block:: console
$ ssh ubuntu@10.10.0.80 $ ssh ubuntu@10.10.0.80
$ kubectl get node $ kubectl get node
@ -1924,31 +1935,31 @@ worker node in Kubernetes cluster after scaling out:
worker20 Ready <none> 14m v1.20.4 worker20 Ready <none> 14m v1.20.4
worker45 Ready <none> 4m v1.20.4 worker45 Ready <none> 4m v1.20.4
Scaling in execution of the vnf_instance: * Scaling in execution of the vnf_instance:
.. code-block:: console .. code-block:: console
$ openstack vnflcm scale --type "SCALE_IN" --aspect-id worker_instance --number-of-steps 1 c5215213-af4b-4080-95ab-377920474e1a $ openstack vnflcm scale --type "SCALE_IN" --aspect-id worker_instance --number-of-steps 1 c5215213-af4b-4080-95ab-377920474e1a
Scale request for VNF Instance c5215213-af4b-4080-95ab-377920474e1a has been accepted. Scale request for VNF Instance c5215213-af4b-4080-95ab-377920474e1a has been accepted.
.. note:: .. note::
This example shows the output of "SCALE_IN" after its "SCALE_OUT" operation. This example shows the output of "SCALE_IN" after its "SCALE_OUT" operation.
Stack information after scaling in: * Stack information after scaling in:
.. code-block:: console .. code-block:: console
$ openstack stack resource list vnf-c5215213-af4b-4080-95ab-377920474e1a -n 2 --filter type=base_hot_nested_worker.yaml -c resource_name -c physical_resource_id -c resource_type -c resource_status $ openstack stack resource list vnf-c5215213-af4b-4080-95ab-377920474e1a -n 2 --filter type=complex_nested_worker.yaml -c resource_name -c physical_resource_id -c resource_type -c resource_status
+---------------+--------------------------------------+-----------------------------+-----------------+ +---------------+--------------------------------------+-----------------------------+-----------------+
| resource_name | physical_resource_id | resource_type | resource_status | | resource_name | physical_resource_id | resource_type | resource_status |
+---------------+--------------------------------------+-----------------------------+-----------------+ +---------------+--------------------------------------+-----------------------------+-----------------+
| n6nnjta4f4rv | 56c9ec6f-5e52-44db-9d0d-57e3484e763f | base_hot_nested_worker.yaml | UPDATE_COMPLETE | | n6nnjta4f4rv | 56c9ec6f-5e52-44db-9d0d-57e3484e763f | complex_nested_worker.yaml | UPDATE_COMPLETE |
| z5nky6qcodlq | f9ab73ff-3ad7-40d2-830a-87bd0c45af32 | base_hot_nested_worker.yaml | UPDATE_COMPLETE | | z5nky6qcodlq | f9ab73ff-3ad7-40d2-830a-87bd0c45af32 | complex_nested_worker.yaml | UPDATE_COMPLETE |
+---------------+--------------------------------------+-----------------------------+-----------------+ +---------------+--------------------------------------+-----------------------------+-----------------+
worker node in Kubernetes cluster after scaling in: * worker node in Kubernetes cluster after scaling in:
.. code-block:: console .. code-block:: console
$ ssh ubuntu@10.10.0.80 $ ssh ubuntu@10.10.0.80
$ kubectl get node $ kubectl get node
@ -2065,9 +2076,9 @@ the age of master node healed should be updated in Kubernetes cluster.
Note that 'vnfc-instance-id' managed by Tacker and Note that 'vnfc-instance-id' managed by Tacker and
'physical-resource-id' managed by Heat are different. 'physical-resource-id' managed by Heat are different.
master node information before healing: * master node information before healing:
.. code-block:: console .. code-block:: console
$ openstack stack resource list vnf-c5215213-af4b-4080-95ab-377920474e1a -n 2 --filter type=OS::Nova::Server -c resource_name -c physical_resource_id -c resource_type -c resource_status $ openstack stack resource list vnf-c5215213-af4b-4080-95ab-377920474e1a -n 2 --filter type=OS::Nova::Server -c resource_name -c physical_resource_id -c resource_type -c resource_status
+---------------+--------------------------------------+------------------+-----------------+ +---------------+--------------------------------------+------------------+-----------------+
@ -2080,9 +2091,9 @@ master node information before healing:
| masterNode | 12708197-9724-41b8-b48c-9eb6862331dc | OS::Nova::Server | CREATE_COMPLETE | | masterNode | 12708197-9724-41b8-b48c-9eb6862331dc | OS::Nova::Server | CREATE_COMPLETE |
+---------------+--------------------------------------+------------------+-----------------+ +---------------+--------------------------------------+------------------+-----------------+
master node in Kubernetes cluster before healing: * master node in Kubernetes cluster before healing:
.. code-block:: console .. code-block:: console
$ ssh ubuntu@10.10.0.80 $ ssh ubuntu@10.10.0.80
$ kubectl get node $ kubectl get node
@ -2097,16 +2108,16 @@ We heal the master node with ``physical_resource_id``
``a0eccaee-ff7b-4c70-8c11-ba79c8d4deb6``, its ``vnfc_instance_id`` ``a0eccaee-ff7b-4c70-8c11-ba79c8d4deb6``, its ``vnfc_instance_id``
is ``bbce9656-f051-434f-8c4a-660ac23e91f6``. is ``bbce9656-f051-434f-8c4a-660ac23e91f6``.
Healing master node execution of the vnf_instance: * Healing master node execution of the vnf_instance:
.. code-block:: console .. code-block:: console
$ openstack vnflcm heal c5215213-af4b-4080-95ab-377920474e1a --vnfc-instance bbce9656-f051-434f-8c4a-660ac23e91f6 $ openstack vnflcm heal c5215213-af4b-4080-95ab-377920474e1a --vnfc-instance bbce9656-f051-434f-8c4a-660ac23e91f6
Heal request for VNF Instance 9e086f34-b3c9-4986-b5e5-609a5ac4c1f9 has been accepted. Heal request for VNF Instance 9e086f34-b3c9-4986-b5e5-609a5ac4c1f9 has been accepted.
master node information after healing: * master node information after healing:
.. code-block:: console .. code-block:: console
$ openstack stack resource list vnf-c5215213-af4b-4080-95ab-377920474e1a -n 2 --filter type=OS::Nova::Server -c resource_name -c physical_resource_id -c resource_type -c resource_status $ openstack stack resource list vnf-c5215213-af4b-4080-95ab-377920474e1a -n 2 --filter type=OS::Nova::Server -c resource_name -c physical_resource_id -c resource_type -c resource_status
+---------------+--------------------------------------+------------------+-----------------+ +---------------+--------------------------------------+------------------+-----------------+
@ -2119,9 +2130,9 @@ master node information after healing:
| masterNode | 12708197-9724-41b8-b48c-9eb6862331dc | OS::Nova::Server | CREATE_COMPLETE | | masterNode | 12708197-9724-41b8-b48c-9eb6862331dc | OS::Nova::Server | CREATE_COMPLETE |
+---------------+--------------------------------------+------------------+-----------------+ +---------------+--------------------------------------+------------------+-----------------+
master node in Kubernetes cluster after healing: * master node in Kubernetes cluster after healing:
.. code-block:: console .. code-block:: console
$ ssh ubuntu@10.10.0.80 $ ssh ubuntu@10.10.0.80
$ kubectl get node $ kubectl get node
@ -2138,9 +2149,9 @@ master node in Kubernetes cluster after healing:
Healing a worker node is the same as Healing a master node. Healing a worker node is the same as Healing a master node.
You just replace the vnfc_instance_id in healing command. You just replace the vnfc_instance_id in healing command.
worker node information before healing: * worker node information before healing:
.. code-block:: console .. code-block:: console
$ openstack stack resource list vnf-c5215213-af4b-4080-95ab-377920474e1a -n 2 --filter type=OS::Nova::Server -c resource_name -c physical_resource_id -c resource_type -c resource_status $ openstack stack resource list vnf-c5215213-af4b-4080-95ab-377920474e1a -n 2 --filter type=OS::Nova::Server -c resource_name -c physical_resource_id -c resource_type -c resource_status
+---------------+--------------------------------------+------------------+-----------------+ +---------------+--------------------------------------+------------------+-----------------+
@ -2153,9 +2164,9 @@ worker node information before healing:
| masterNode | 12708197-9724-41b8-b48c-9eb6862331dc | OS::Nova::Server | CREATE_COMPLETE | | masterNode | 12708197-9724-41b8-b48c-9eb6862331dc | OS::Nova::Server | CREATE_COMPLETE |
+---------------+--------------------------------------+------------------+-----------------+ +---------------+--------------------------------------+------------------+-----------------+
worker node in Kubernetes cluster before healing: * worker node in Kubernetes cluster before healing:
.. code-block:: console .. code-block:: console
$ ssh ubuntu@10.10.0.80 $ ssh ubuntu@10.10.0.80
$ kubectl get node $ kubectl get node
@ -2170,16 +2181,16 @@ We heal the worker node with ``physical_resource_id``
``5b3ff765-7a9f-447a-a06d-444e963b74c9``, its ``vnfc_instance_id`` ``5b3ff765-7a9f-447a-a06d-444e963b74c9``, its ``vnfc_instance_id``
is ``b4af0652-74b8-47bd-bcf6-94769bdbf756``. is ``b4af0652-74b8-47bd-bcf6-94769bdbf756``.
Healing worker node execution of the vnf_instance: * Healing worker node execution of the vnf_instance:
.. code-block:: console .. code-block:: console
$ openstack vnflcm heal c5215213-af4b-4080-95ab-377920474e1a --vnfc-instance b4af0652-74b8-47bd-bcf6-94769bdbf756 $ openstack vnflcm heal c5215213-af4b-4080-95ab-377920474e1a --vnfc-instance b4af0652-74b8-47bd-bcf6-94769bdbf756
Heal request for VNF Instance 9e086f34-b3c9-4986-b5e5-609a5ac4c1f9 has been accepted. Heal request for VNF Instance 9e086f34-b3c9-4986-b5e5-609a5ac4c1f9 has been accepted.
worker node information after healing: * worker node information after healing:
.. code-block:: console .. code-block:: console
$ openstack stack resource list vnf-c5215213-af4b-4080-95ab-377920474e1a -n 2 --filter type=OS::Nova::Server -c resource_name -c physical_resource_id -c resource_type -c resource_status $ openstack stack resource list vnf-c5215213-af4b-4080-95ab-377920474e1a -n 2 --filter type=OS::Nova::Server -c resource_name -c physical_resource_id -c resource_type -c resource_status
+---------------+--------------------------------------+------------------+-----------------+ +---------------+--------------------------------------+------------------+-----------------+
@ -2192,9 +2203,9 @@ worker node information after healing:
| masterNode | 12708197-9724-41b8-b48c-9eb6862331dc | OS::Nova::Server | CREATE_COMPLETE | | masterNode | 12708197-9724-41b8-b48c-9eb6862331dc | OS::Nova::Server | CREATE_COMPLETE |
+---------------+--------------------------------------+------------------+-----------------+ +---------------+--------------------------------------+------------------+-----------------+
worker node in Kubernetes cluster after healing: * worker node in Kubernetes cluster after healing:
.. code-block:: console .. code-block:: console
$ ssh ubuntu@10.10.0.80 $ ssh ubuntu@10.10.0.80
$ kubectl get node $ kubectl get node
@ -2223,9 +2234,9 @@ changed.
This is to confirm that stack 'ID' has changed This is to confirm that stack 'ID' has changed
before and after healing. before and after healing.
Stack information before healing: * Stack information before healing:
.. code-block:: console .. code-block:: console
$ openstack stack list -c 'ID' -c 'Stack Name' -c 'Stack Status' $ openstack stack list -c 'ID' -c 'Stack Name' -c 'Stack Status'
+--------------------------------------+------------------------------------------+-----------------+ +--------------------------------------+------------------------------------------+-----------------+
@ -2234,9 +2245,9 @@ Stack information before healing:
| f485f3f2-8181-4ed5-b927-e582b5aa9b14 | vnf-c5215213-af4b-4080-95ab-377920474e1a | CREATE_COMPLETE | | f485f3f2-8181-4ed5-b927-e582b5aa9b14 | vnf-c5215213-af4b-4080-95ab-377920474e1a | CREATE_COMPLETE |
+--------------------------------------+------------------------------------------+-----------------+ +--------------------------------------+------------------------------------------+-----------------+
Kubernetes cluster information before healing: * Kubernetes cluster information before healing:
.. code-block:: console .. code-block:: console
$ ssh ubuntu@10.10.0.80 $ ssh ubuntu@10.10.0.80
$ kubectl get node $ kubectl get node
@ -2247,16 +2258,16 @@ Kubernetes cluster information before healing:
worker20 Ready <none> 17m v1.20.4 worker20 Ready <none> 17m v1.20.4
worker45 Ready <none> 7m v1.20.4 worker45 Ready <none> 7m v1.20.4
Healing execution of the entire VNF: * Healing execution of the entire VNF:
.. code-block:: console .. code-block:: console
$ openstack vnflcm heal c5215213-af4b-4080-95ab-377920474e1a $ openstack vnflcm heal c5215213-af4b-4080-95ab-377920474e1a
Heal request for VNF Instance c5215213-af4b-4080-95ab-377920474e1a has been accepted. Heal request for VNF Instance c5215213-af4b-4080-95ab-377920474e1a has been accepted.
Stack information after healing: * Stack information after healing:
.. code-block:: console .. code-block:: console
$ openstack stack list -c 'ID' -c 'Stack Name' -c 'Stack Status' $ openstack stack list -c 'ID' -c 'Stack Name' -c 'Stack Status'
+--------------------------------------+------------------------------------------+-----------------+ +--------------------------------------+------------------------------------------+-----------------+
@ -2265,9 +2276,9 @@ Stack information after healing:
| 03aaadbe-bf5a-44a0-84b0-8f2a18f8a844 | vnf-c5215213-af4b-4080-95ab-377920474e1a | CREATE_COMPLETE | | 03aaadbe-bf5a-44a0-84b0-8f2a18f8a844 | vnf-c5215213-af4b-4080-95ab-377920474e1a | CREATE_COMPLETE |
+--------------------------------------+------------------------------------------+-----------------+ +--------------------------------------+------------------------------------------+-----------------+
Kubernetes cluster information after healing: * Kubernetes cluster information after healing:
.. code-block:: console .. code-block:: console
$ ssh ubuntu@10.10.0.93 $ ssh ubuntu@10.10.0.93
$ kubectl get node $ kubectl get node
@ -2278,6 +2289,560 @@ Kubernetes cluster information after healing:
worker101 Ready <none> 10m v1.20.4 worker101 Ready <none> 10m v1.20.4
worker214 Ready <none> 4m v1.20.4 worker214 Ready <none> 4m v1.20.4
Hardware-aware Affinity For Pods on Kubernetes Cluster
------------------------------------------------------
In the two cases (simple and complex) mentioned above, if you deploy
a Container Network Function on the VNF of a Kubernetes cluster,
the Pods may be scheduled on the same physical compute server
while they are labeled with anti-affinity rules. The anti-affinity
rule can deploy the Pods on different worker nodes, but the worker
nodes may be in the same server. In this chapter, we provide a way
to support the hardware-aware affinity for Pods.
This case will create a Kubernetes cluster with 3 master nodes and
2 worker nodes. When Tacker deploys worker nodes, an 'anti-affinity'
rule will be added to their "scheduler_hints" property (a property can
control which compute server the VM will deploy on), so that the worker
node will be deployed on the different server. After the worker node has
joined into the Kubernetes cluster, a label (whose type is 'topologyKey', key
is 'CIS-node' and value is which server the worker node deployed on)
will be added to the worker node.
Then, when deploying Pods in this Kubernetes cluster, if the Pods
have an 'anti-affinity' rule based on the'CIS-node' label, the
Pods will be scheduled on worker nodes with different values
of this label, so the Pods will be deployed on different servers.
At the same time, if you use Grant to deploy your VM, you can
specify the Availability Zone (AZ) of the VM. In this case, your
worker node will be added a label (whose type is 'topologyKey', key
is 'kubernetes.io/zone' and value is which AZ the worker node deployed on).
When you specify the zone label in pod-affinity, your pod will be
deployed to a different AZ.
1. VNF Package Introduction
^^^^^^^^^^^^^^^^^^^^^^^^^^^
The VNF Package of Hardware-aware Affinity (hereinafter referred to as
pod-affinity) is similar to the above two case packages. You only need
to append definition files of pod-affinity in the ``Definitions`` and
``BaseHOT`` directories.
Definitions
~~~~~~~~~~~
The files ``deployment_flavour`` should be different from the above two
cases. The sample file is shown below:
* `sample_kubernetes_df_podaffinity.yaml`_
BaseHOT
~~~~~~~
The BaseHOT requires the configuration of a ``srvgroup`` that contains policy
definitions for the anti-affinity. The directory structure is shown below:
.. code-block:: console
!----BaseHOT
!---- podaffinity
!---- nested
!---- podaffinity_nested_master.yaml
!---- podaffinity_nested_worker.yaml
!---- podaffinity_hot_top.yaml
The sample files are shown below:
* `nested/podaffinity_nested_master.yaml`_
* `nested/podaffinity_nested_worker.yaml`_
* `podaffinity_hot_top.yaml`_
2. Instantiate Kubernetes Cluster with Pod-affinity
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
The operation steps and methods of instantiating with pod-affinity are
the same as those in ``Deploy Kubernetes Cluster``. The difference
is that ``flavourId`` in parameter file used in instantiate needs
to be modified to the one of pod-affinity. In this use case, ``flavourId``
is ``podaffinity``.
``podaffinity_kubernetes_param_file.json`` is shown below.
podaffinity_kubernetes_param_file.json
.. code-block::
{
"flavourId": "podaffinity",
"vimConnectionInfo": [{
"id": "3cc2c4ff-525c-48b4-94c9-29247223322f",
"vimId": "05ef7ca5-7e32-4a6b-a03d-52f811f04496", #Set the uuid of the VIM to use
"vimType": "openstack"
}],
"additionalParams": {
"k8s_cluster_installation_param": {
"script_path": "Scripts/install_k8s_cluster.sh",
"vim_name": "kubernetes_vim_podaffinity",
"master_node": {
"aspect_id": "master_instance",
"ssh_cp_name": "masterNode_CP1",
"nic_cp_name": "masterNode_CP1",
"username": "ubuntu",
"password": "ubuntu",
"pod_cidr": "192.168.0.0/16",
"cluster_cidr": "10.199.187.0/24",
"cluster_cp_name": "vip_CP"
},
"worker_node": {
"aspect_id": "worker_instance",
"ssh_cp_name": "workerNode_CP2",
"nic_cp_name": "workerNode_CP2",
"username": "ubuntu",
"password": "ubuntu"
},
"proxy": {
"http_proxy": "http://user1:password1@host1:port1",
"https_proxy": "https://user2:password2@host2:port2",
"no_proxy": "192.168.246.0/24,10.0.0.1",
"k8s_node_cidr": "10.10.0.0/24"
}
},
"lcm-operation-user-data": "./UserData/k8s_cluster_user_data.py",
"lcm-operation-user-data-class": "KubernetesClusterUserData"
},
"extVirtualLinks": [{
"id": "net0_master",
"resourceId": "71a3fbd1-f31e-4c2c-b0e2-26267d64a9ee", #Set the uuid of the network to use
"extCps": [{
"cpdId": "masterNode_CP1",
"cpConfig": [{
"cpProtocolData": [{
"layerProtocol": "IP_OVER_ETHERNET"
}]
}]
}]
}, {
"id": "net0_worker",
"resourceId": "71a3fbd1-f31e-4c2c-b0e2-26267d64a9ee", #Set the uuid of the network to use
"extCps": [{
"cpdId": "workerNode_CP2",
"cpConfig": [{
"cpProtocolData": [{
"layerProtocol": "IP_OVER_ETHERNET"
}]
}]
}]
}]
}
Confirm the Instantiate Operation is Successful on OpenStack
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
You can use Heat CLI to confirm that instantiating Kubernetes
cluster with pod-affinity successfully. The confirmation points are
shown below.
1. Confirm that the value of policy attribute in "OS::Nova::ServerGroup"
resource created by tacker is 'anti-affinity'.
2. Confirm that the members attribute in "OS::Nova::ServerGroup"
resource created by tacker are the physical_resource_id of worker node VMs.
3. Confirm that the value of server_groups attribute in worker node VM
created by tacker is the physical_resource_id of "OS::Nova::ServerGroup"
resource.
After instantiating, the following command can check confirmation
points 1 and 2.
* "OS::Nova::ServerGroup" resource information of pod-affinity:
.. code-block:: console
$ openstack stack resource show vnf-2456188c-d882-4de2-8cd0-54a7a2ea4e6a srvgroup --fit
+------------------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| Field | Value |
+------------------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| attributes | {'id': '46186a58-5cac-4dd6-a516-d6deb1461f8a', 'name': 'ServerGroup', 'policy': 'anti-affinity', 'rules': {}, 'members': ['51826868-74d6-4ce1-9b0b-157efdfc9490', 'e4bef063-30f9-4f26-b5fc-75d99e46db1e'], 'project_id': |
| | 'ff61312f72f94c7da3d0c3c4578ad121', 'user_id': '4751fbe7b18a4469bedf89ba0cc09616'} |
| creation_time | 2021-04-22T02:47:22Z |
| description | |
| links | [{'href': 'http://192.168.10.115/heat-api/v1/ff61312f72f94c7da3d0c3c4578ad121/stacks/vnf-2456188c-d882-4de2-8cd0-54a7a2ea4e6a/4dfd5d41-77c9-4e72-b30f-d06f0ca79ebf/resources/srvgroup', 'rel': 'self'}, {'href': |
| | 'http://192.168.10.115/heat-api/v1/ff61312f72f94c7da3d0c3c4578ad121/stacks/vnf-2456188c-d882-4de2-8cd0-54a7a2ea4e6a/4dfd5d41-77c9-4e72-b30f-d06f0ca79ebf', 'rel': 'stack'}] |
| logical_resource_id | srvgroup |
| physical_resource_id | 46186a58-5cac-4dd6-a516-d6deb1461f8a |
| required_by | ['worker_instance'] |
| resource_name | srvgroup |
| resource_status | CREATE_COMPLETE |
| resource_status_reason | state changed |
| resource_type | OS::Nova::ServerGroup |
| updated_time | 2021-04-22T02:47:22Z |
+------------------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
$ openstack stack resource list vnf-2456188c-d882-4de2-8cd0-54a7a2ea4e6a -n 2 --filter type=OS::Nova::Server -c resource_name -c physical_resource_id -c resource_type -c resource_status
+---------------+--------------------------------------+------------------+-----------------+
| resource_name | physical_resource_id | resource_type | resource_status |
+---------------+--------------------------------------+------------------+-----------------+
| workerNode | 51826868-74d6-4ce1-9b0b-157efdfc9490 | OS::Nova::Server | CREATE_COMPLETE |
| workerNode | e4bef063-30f9-4f26-b5fc-75d99e46db1e | OS::Nova::Server | CREATE_COMPLETE |
| masterNode | d4578afd-9eb6-2ca0-1932-ccd69d763b6b | OS::Nova::Server | CREATE_COMPLETE |
| masterNode | 42904925-7d05-e311-3953-dc92c88428b0 | OS::Nova::Server | CREATE_COMPLETE |
| masterNode | 282a9ba5-fcbc-3f4b-6ca3-71d383e26134 | OS::Nova::Server | CREATE_COMPLETE |
+---------------+--------------------------------------+------------------+-----------------+
The following command can check confirmation point 3.
* "worker node VM" information of pod-affinity:
.. code-block:: console
$ openstack stack resource list vnf-2456188c-d882-4de2-8cd0-54a7a2ea4e6a -n 2 --filter type=podaffinity_nested_worker.yaml -c resource_name -c physical_resource_id -c resource_type -c resource_status
+---------------+--------------------------------------+--------------------------------+-----------------+
| resource_name | physical_resource_id | resource_type | resource_status |
+---------------+--------------------------------------+--------------------------------+-----------------+
| kxogpuzgdcvi | 3b11dba8-2dab-4ad4-8241-09a0501cab47 | podaffinity_nested_worker.yaml | CREATE_COMPLETE |
| n5s7ycewii5s | 4b2ac686-e6ff-4397-88dd-cbba7d2e7a34 | podaffinity_nested_worker.yaml | CREATE_COMPLETE |
+---------------+--------------------------------------+--------------------------------+-----------------+
$ openstack stack resource show 3b11dba8-2dab-4ad4-8241-09a0501cab47 workerNode --fit
+------------------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| Field | Value |
+------------------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| attributes | {'id': '51826868-74d6-4ce1-9b0b-157efdfc9490', 'name': 'workerNode', 'status': 'ACTIVE', 'tenant_id': 'ff61312f72f94c7da3d0c3c4578ad121', 'user_id': '4751fbe7b18a4469bedf89ba0cc09616', 'metadata': {}, 'hostId': |
| | 'bdd83b04143e4048e93141cfb5600c39571a94e501564cf7a1380073', 'image': {'id': '959c1e45-e140-407d-aaaf-bb5eea93a828', 'links': [{'rel': 'bookmark', 'href': 'http://192.168.10.115/compute/images/959c1e45-e140-407d-aaaf- |
| | bb5eea93a828'}]}, 'flavor': {'vcpus': 2, 'ram': 4096, 'disk': 40, 'ephemeral': 0, 'swap': 0, 'original_name': 'm1.medium', 'extra_specs': {'hw_rng:allowed': 'True'}}, 'created': '2021-04-22T02:47:27Z', 'updated': |
| | '2021-04-22T02:47:36Z', 'addresses': {'net0': [{'version': 4, 'addr': '10.10.0.52', 'OS-EXT-IPS:type': 'fixed', 'OS-EXT-IPS-MAC:mac_addr': 'fa:16:3e:09:34:5f'}]}, 'accessIPv4': '', 'accessIPv6': '', 'links': [{'rel': 'self', |
| | 'href': 'http://192.168.10.115/compute/v2.1/servers/51826868-74d6-4ce1-9b0b-157efdfc9490'}, {'rel': 'bookmark', 'href': 'http://192.168.10.115/compute/servers/51826868-74d6-4ce1-9b0b-157efdfc9490'}], 'OS-DCF:diskConfig': |
| | 'MANUAL', 'progress': 0, 'OS-EXT-AZ:availability_zone': 'nova', 'config_drive': '', 'key_name': None, 'OS-SRV-USG:launched_at': '2021-04-22T02:47:30.000000', 'OS-SRV-USG:terminated_at': None, 'security_groups': [{'name': |
| | 'default'}], 'OS-EXT-SRV-ATTR:host': 'compute03', 'OS-EXT-SRV-ATTR:instance_name': 'instance-000003de', 'OS-EXT-SRV-ATTR:hypervisor_hostname': 'compute03', 'OS-EXT-SRV-ATTR:reservation_id': 'r-3wox5r91', 'OS-EXT-SRV- |
| | ATTR:launch_index': 0, 'OS-EXT-SRV-ATTR:hostname': 'workernode', 'OS-EXT-SRV-ATTR:kernel_id': '', 'OS-EXT-SRV-ATTR:ramdisk_id': '', 'OS-EXT-SRV-ATTR:root_device_name': '/dev/vda', 'OS-EXT-SRV-ATTR:user_data': 'Q29udGVudC1UeX |
| | BlOiBtdWx0aXBhcnQvbWl4ZWQ7IGJvdW5kYXJ5PSI9PT09PT09PT09PT09PT0wMDA5NDg1OTI5MTU3NzU5MzA2PT0iCk1JTUUtVmVyc2lvbjogMS4wCgotLT09PT09PT09PT09PT09PTAwMDk0ODU5MjkxNTc3NTkzMDY9PQpDb250ZW50LVR5cGU6IHRleHQvY2xvdWQtY29uZmlnOyBjaGFyc2V0PS |
| | J1cy1hc2NpaSIKTUlNRS1WZXJzaW9uOiAxLjAKQ29udGVudC1UcmFuc2Zlci1FbmNvZGluZzogN2JpdApDb250ZW50LURpc3Bvc2l0aW9uOiBhdHRhY2htZW50OyBmaWxlbmFtZT0iY2xvdWQtY29uZmlnIgoKCgojIENhcHR1cmUgYWxsIHN1YnByb2Nlc3Mgb3V0cHV0IGludG8gYSBsb2dmaWxlCi |
| | MgVXNlZnVsIGZvciB0cm91Ymxlc2hvb3RpbmcgY2xvdWQtaW5pdCBpc3N1ZXMKb3V0cHV0OiB7YWxsOiAnfCB0ZWUgLWEgL3Zhci9sb2cvY2xvdWQtaW5pdC1vdXRwdXQubG9nJ30KCi==', 'OS-EXT-STS:task_state': None, 'OS-EXT-STS:vm_state': 'active', 'OS-EXT- |
| | STS:power_state': 1, 'os-extended-volumes:volumes_attached': [], 'host_status': 'UP', 'locked': False, 'locked_reason': None, 'description': None, 'tags': [], 'trusted_image_certificates': None, 'server_groups': |
| | ['46186a58-5cac-4dd6-a516-d6deb1461f8a'], 'os_collect_config': {}} |
| creation_time | 2021-04-22T02:47:24Z |
| description | |
| links | [{'href': 'http://192.168.10.115/heat-api/v1/ff61312f72f94c7da3d0c3c4578ad121/stacks/vnf-2456188c-d882-4de2-8cd0-54a7a2ea4e6a-worker_instance-6wyaj6mgtjlt-kxogpuzgdcvi- |
| | eutiueiy6e7n/3b11dba8-2dab-4ad4-8241-09a0501cab47/resources/workerNode', 'rel': 'self'}, {'href': 'http://192.168.10.115/heat- |
| | api/v1/ff61312f72f94c7da3d0c3c4578ad121/stacks/vnf-2456188c-d882-4de2-8cd0-54a7a2ea4e6a-worker_instance-6wyaj6mgtjlt-kxogpuzgdcvi-eutiueiy6e7n/3b11dba8-2dab-4ad4-8241-09a0501cab47', 'rel': 'stack'}] |
| logical_resource_id | workerNode |
| parent_resource | kxogpuzgdcvi |
| physical_resource_id | 51826868-74d6-4ce1-9b0b-157efdfc9490 |
| required_by | [] |
| resource_name | workerNode |
| resource_status | CREATE_COMPLETE |
| resource_status_reason | state changed |
| resource_type | OS::Nova::Server |
| updated_time | 2021-04-22T02:47:24Z |
+------------------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
Confirm the Instantiate Operation is Successful on Kubernetes
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
To confirm that the 'CIS-node' label has been added to worker node
successfully, you should login to one of the master nodes via ssh
in Kubernetes cluster, and use Kubernetes CLI. The confirmation
points are shown below.
1. Confirm that 'CIS-node' label is in the worker node's
labels.
2. Confirm that 'CIS-node' label's value is the Compute Server's name which
the worker node deployed on. The key of this value is
'OS-EXT-SRV-ATTR:host' in "worker node VM" information.
After instantiating, the following command can check
these confirmation points.
* worker node information in Kubernetes cluster
.. code-block:: console
$ kubectl get node --show-labels
NAME STATUS ROLES AGE VERSION LABELS
master110 Ready control-plane,master 5h34m v1.21.0 beta.kubernetes.io/arch=amd64,beta.kubernetes.io/os=linux,kubernetes.io/arch=amd64,kubernetes.io/hostname=master110,kubernetes.io/os=linux,node-role.kubernetes.io/control-plane=,node-role.kubernetes.io/master=,node.kubernetes.io/exclude-from-external-load-balancers=
master13 Ready control-plane,master 5h21m v1.21.0 beta.kubernetes.io/arch=amd64,beta.kubernetes.io/os=linux,kubernetes.io/arch=amd64,kubernetes.io/hostname=master13,kubernetes.io/os=linux,node-role.kubernetes.io/control-plane=,node-role.kubernetes.io/master=,node.kubernetes.io/exclude-from-external-load-balancers=
master159 Ready control-plane,master 5h48m v1.21.0 beta.kubernetes.io/arch=amd64,beta.kubernetes.io/os=linux,kubernetes.io/arch=amd64,kubernetes.io/hostname=master159,kubernetes.io/os=linux,node-role.kubernetes.io/control-plane=,node-role.kubernetes.io/master=,node.kubernetes.io/exclude-from-external-load-balancers=
worker52 Ready <none> 5h15m v1.21.0 CIS-node=compute03,beta.kubernetes.io/arch=amd64,beta.kubernetes.io/os=linux,kubernetes.io/arch=amd64,kubernetes.io/hostname=worker52,kubernetes.io/os=linux
worker88 Ready <none> 5h10m v1.21.0 CIS-node=compute01,beta.kubernetes.io/arch=amd64,beta.kubernetes.io/os=linux,kubernetes.io/arch=amd64,kubernetes.io/hostname=worker88,kubernetes.io/os=linux
3. Scale out Worker Node with Pod-affinity
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
The operation steps and methods of scaling out worker node with
pod-affinity are the same as those in ``Scale Kubernetes Worker Nodes``.
Confirm the Scaling out Operation is Successful on OpenStack
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
You can use Heat CLI to confirm that scaling out worker node
with pod-affinity has been finished successfully. The confirmation points are
shown below.
1. Confirm that ``physical_resource_id`` of scaled-out worker
node has been added to ``members`` attribute in "OS::Nova::ServerGroup"
resource.
2. Confirm that the value of ``server_groups`` attribute in worker node
VM scaled out is ``physical_resource_id`` of "OS::Nova::ServerGroup"
resource.
After scaling out worker node, the following command can check
confirmation point 1.
* "OS::Nova::ServerGroup" resource information of pod-affinity
.. code-block:: console
$ openstack stack resource show vnf-2456188c-d882-4de2-8cd0-54a7a2ea4e6a srvgroup --fit
+------------------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| Field | Value |
+------------------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| attributes | {'id': '46186a58-5cac-4dd6-a516-d6deb1461f8a', 'name': 'ServerGroup', 'policy': 'anti-affinity', 'rules': {}, 'members': ['51826868-74d6-4ce1-9b0b-157efdfc9490', 'e4bef063-30f9-4f26-b5fc-75d99e46db1e', |
| | 'a576d70c-d299-cf83-745a-63a1f49da7d3'], 'project_id': 'ff61312f72f94c7da3d0c3c4578ad121', 'user_id': '4751fbe7b18a4469bedf89ba0cc09616'} | |
| creation_time | 2021-04-22T02:47:22Z |
| description | |
| links | [{'href': 'http://192.168.10.115/heat-api/v1/ff61312f72f94c7da3d0c3c4578ad121/stacks/vnf-2456188c-d882-4de2-8cd0-54a7a2ea4e6a/4dfd5d41-77c9-4e72-b30f-d06f0ca79ebf/resources/srvgroup', 'rel': 'self'}, {'href': |
| | 'http://192.168.10.115/heat-api/v1/ff61312f72f94c7da3d0c3c4578ad121/stacks/vnf-2456188c-d882-4de2-8cd0-54a7a2ea4e6a/4dfd5d41-77c9-4e72-b30f-d06f0ca79ebf', 'rel': 'stack'}] |
| logical_resource_id | srvgroup |
| physical_resource_id | 46186a58-5cac-4dd6-a516-d6deb1461f8a |
| required_by | ['worker_instance'] |
| resource_name | srvgroup |
| resource_status | UPDATE_COMPLETE |
| resource_status_reason | state changed |
| resource_type | OS::Nova::ServerGroup |
| updated_time | 2021-04-22T03:47:22Z |
+------------------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
$ openstack stack resource list vnf-2456188c-d882-4de2-8cd0-54a7a2ea4e6a -n 2 --filter type=OS::Nova::Server -c resource_name -c physical_resource_id -c resource_type -c resource_status
+---------------+--------------------------------------+------------------+-----------------+
| resource_name | physical_resource_id | resource_type | resource_status |
+---------------+--------------------------------------+------------------+-----------------+
| workerNode | 51826868-74d6-4ce1-9b0b-157efdfc9490 | OS::Nova::Server | CREATE_COMPLETE |
| workerNode | e4bef063-30f9-4f26-b5fc-75d99e46db1e | OS::Nova::Server | CREATE_COMPLETE |
| workerNode | a576d70c-d299-cf83-745a-63a1f49da7d3 | OS::Nova::Server | CREATE_COMPLETE |
| masterNode | d4578afd-9eb6-2ca0-1932-ccd69d763b6b | OS::Nova::Server | CREATE_COMPLETE |
| masterNode | 42904925-7d05-e311-3953-dc92c88428b0 | OS::Nova::Server | CREATE_COMPLETE |
| masterNode | 282a9ba5-fcbc-3f4b-6ca3-71d383e26134 | OS::Nova::Server | CREATE_COMPLETE |
+---------------+--------------------------------------+------------------+-----------------+
The following command can check confirmation point 2. The resource
with 'plkz6sfomuhx' resource_name is the one scaled out.
* "worker node VM" information of pod-affinity
.. code-block:: console
$ openstack stack resource list vnf-2456188c-d882-4de2-8cd0-54a7a2ea4e6a -n 2 --filter type=podaffinity_nested_worker.yaml -c resource_name -c physical_resource_id -c resource_type -c resource_status
+---------------+--------------------------------------+--------------------------------+------------------+
| resource_name | physical_resource_id | resource_type | resource_status |
+---------------+--------------------------------------+--------------------------------+------------------+
| kxogpuzgdcvi | 3b11dba8-2dab-4ad4-8241-09a0501cab47 | podaffinity_nested_worker.yaml | UPDATE_COMPLETE |
| n5s7ycewii5s | 4b2ac686-e6ff-4397-88dd-cbba7d2e7a34 | podaffinity_nested_worker.yaml | UPDATE_COMPLETE |
| plkz6sfomuhx | 24d0076c-672a-e52d-1947-ec8495708b5d | podaffinity_nested_worker.yaml | CREATE_COMPLETE |
+---------------+--------------------------------------+--------------------------------+------------------+
$ openstack stack resource show 24d0076c-672a-e52d-1947-ec8495708b5d workerNode --fit
+------------------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| Field | Value |
+------------------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| attributes | {'id': 'a576d70c-d299-cf83-745a-63a1f49da7d3', 'name': 'workerNode', 'status': 'ACTIVE', 'tenant_id': 'ff61312f72f94c7da3d0c3c4578ad121', 'user_id': '4751fbe7b18a4469bedf89ba0cc09616', 'metadata': {}, 'hostId': |
| | 'bdd83b04143e4048e93141cfb5600c39571a94e501564cf7a1380073', 'image': {'id': '959c1e45-e140-407d-aaaf-bb5eea93a828', 'links': [{'rel': 'bookmark', 'href': 'http://192.168.10.115/compute/images/959c1e45-e140-407d-aaaf- |
| | bb5eea93a828'}]}, 'flavor': {'vcpus': 2, 'ram': 4096, 'disk': 40, 'ephemeral': 0, 'swap': 0, 'original_name': 'm1.medium', 'extra_specs': {'hw_rng:allowed': 'True'}}, 'created': '2021-04-22T02:47:26Z', 'updated': |
| | '2021-04-22T02:47:34Z', 'addresses': {'net0': [{'version': 4, 'addr': '10.10.0.46', 'OS-EXT-IPS:type': 'fixed', 'OS-EXT-IPS-MAC:mac_addr': 'fa:16:3e:28:fc:7a'}]}, 'accessIPv4': '', 'accessIPv6': '', 'links': [{'rel': 'self', |
| | 'href': 'http://192.168.10.115/compute/v2.1/servers/a576d70c-d299-cf83-745a-63a1f49da7d3'}, {'rel': 'bookmark', 'href': 'http://192.168.10.115/compute/servers/a576d70c-d299-cf83-745a-63a1f49da7d3'}], 'OS-DCF:diskConfig': |
| | 'MANUAL', 'progress': 0, 'OS-EXT-AZ:availability_zone': 'nova', 'config_drive': '', 'key_name': None, 'OS-SRV-USG:launched_at': '2021-04-22T02:47:28.000000', 'OS-SRV-USG:terminated_at': None, 'security_groups': [{'name': |
| | 'default'}], 'OS-EXT-SRV-ATTR:host': 'compute02', 'OS-EXT-SRV-ATTR:instance_name': 'instance-000003dd', 'OS-EXT-SRV-ATTR:hypervisor_hostname': 'compute02', 'OS-EXT-SRV-ATTR:reservation_id': 'r-lvg9ate8', 'OS-EXT-SRV- |
| | ATTR:launch_index': 0, 'OS-EXT-SRV-ATTR:hostname': 'workernode', 'OS-EXT-SRV-ATTR:kernel_id': '', 'OS-EXT-SRV-ATTR:ramdisk_id': '', 'OS-EXT-SRV-ATTR:root_device_name': '/dev/vda', 'OS-EXT-SRV-ATTR:user_data': 'Q29udGVudC1UeX |
| | BlOiBtdWx0aXBhcnQvbWl4ZWQ7IGJvdW5kYXJ5PSI9PT09PT09PT09PT09PT0wMDA5NDg1OTI5MTU3NzU5MzA2PT0iCk1JTUUtVmVyc2lvbjogMS4wCgotLT09PT09PT09PT09PT09PTAwMDk0ODU5MjkxNTc3NTkzMDY9PQpDb250ZW50LVR5cGU6IHRleHQvY2xvdWQtY29uZmlnOyBjaGFyc2V0PS |
| | J1cy1hc2NpaSIKTUlNRS1WZXJzaW9uOiAxLjAKQ29udGVudC1UcmFuc2Zlci1FbmNvZGluZzogN2JpdApDb250ZW50LURpc3Bvc2l0aW9uOiBhdHRhY2htZW50OyBmaWxlbmFtZT0iY2xvdWQtY29uZmlnIgoKCgojIENhcHR1cmUgYWxsIHN1YnByb2Nlc3Mgb3V0cHV0IGludG8gYSBsb2dmaWxlCi |
| | MgVXNlZnVsIGZvciB0cm91Ymxlc2hvb3RpbmcgY2xvdWQtaW5pdCBpc3N1ZXMKb3V0cHV0OiB7YWxsOiAnfCB0ZWUgLWEgL3Zhci9sb2cvY2xvdWQtaW5pdC1vdXRwdXQubG9nJ30KCi==', 'OS-EXT-STS:task_state': None, 'OS-EXT-STS:vm_state': 'active', 'OS-EXT- |
| | STS:power_state': 1, 'os-extended-volumes:volumes_attached': [], 'host_status': 'UP', 'locked': False, 'locked_reason': None, 'description': None, 'tags': [], 'trusted_image_certificates': None, 'server_groups': |
| | ['46186a58-5cac-4dd6-a516-d6deb1461f8a'], 'os_collect_config': {}} |
| creation_time | 2021-04-22T02:47:23Z |
| description | |
| links | [{'href': 'http://192.168.10.115/heat-api/v1/ff61312f72f94c7da3d0c3c4578ad121/stacks/vnf-2456188c-d882-4de2-8cd0-54a7a2ea4e6a-worker_instance-6wyaj6mgtjlt-plkz6sfomuhx-tvegcyfieq7m/24d0076c-672a-e52d-1947- |
| | ec8495708b5d/resources/workerNode', 'rel': 'self'}, {'href': 'http://192.168.10.115/heat- |
| | api/v1/ff61312f72f94c7da3d0c3c4578ad121/stacks/vnf-2456188c-d882-4de2-8cd0-54a7a2ea4e6a-worker_instance-6wyaj6mgtjlt-plkz6sfomuhx-tvegcyfieq7m/24d0076c-672a-e52d-1947-ec8495708b5d', 'rel': 'stack'}] |
| logical_resource_id | workerNode |
| parent_resource | plkz6sfomuhx |
| physical_resource_id | a576d70c-d299-cf83-745a-63a1f49da7d3 |
| required_by | [] |
| resource_name | workerNode |
| resource_status | CREATE_COMPLETE |
| resource_status_reason | state changed |
| resource_type | OS::Nova::Server |
| updated_time | 2021-04-22T03:47:23Z |
+------------------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
Confirm the Scaling out Operation is Successful on Kubernetes
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
To confirm that the 'CIS-node' label has been added to worker node scaled out
successfully, you should login to one of the master nodes via ssh
in Kubernetes cluster, and use Kubernetes CLI. The confirmation
points are shown below.
1. Confirm that 'CIS-node' label is in the scaled out worker node's
labels.
2. Confirm that 'CIS-node' label's value is the Compute Server's name which
the worker node deployed on. The key of this value is
'OS-EXT-SRV-ATTR:host' in "worker node VM" information.
After scaling out, the following command can check
these confirmation points. The worker46 is the
scaled out worker node.
* worker node information in Kubernetes cluster
.. code-block:: console
$ kubectl get node --show-labels
NAME STATUS ROLES AGE VERSION LABELS
master110 Ready control-plane,master 5h34m v1.21.0 beta.kubernetes.io/arch=amd64,beta.kubernetes.io/os=linux,kubernetes.io/arch=amd64,kubernetes.io/hostname=master110,kubernetes.io/os=linux,node-role.kubernetes.io/control-plane=,node-role.kubernetes.io/master=,node.kubernetes.io/exclude-from-external-load-balancers=
master13 Ready control-plane,master 5h21m v1.21.0 beta.kubernetes.io/arch=amd64,beta.kubernetes.io/os=linux,kubernetes.io/arch=amd64,kubernetes.io/hostname=master13,kubernetes.io/os=linux,node-role.kubernetes.io/control-plane=,node-role.kubernetes.io/master=,node.kubernetes.io/exclude-from-external-load-balancers=
master159 Ready control-plane,master 5h48m v1.21.0 beta.kubernetes.io/arch=amd64,beta.kubernetes.io/os=linux,kubernetes.io/arch=amd64,kubernetes.io/hostname=master159,kubernetes.io/os=linux,node-role.kubernetes.io/control-plane=,node-role.kubernetes.io/master=,node.kubernetes.io/exclude-from-external-load-balancers=
worker52 Ready <none> 5h15m v1.21.0 CIS-node=compute01,beta.kubernetes.io/arch=amd64,beta.kubernetes.io/os=linux,kubernetes.io/arch=amd64,kubernetes.io/hostname=worker52,kubernetes.io/os=linux
worker88 Ready <none> 5h10m v1.21.0 CIS-node=compute03,beta.kubernetes.io/arch=amd64,beta.kubernetes.io/os=linux,kubernetes.io/arch=amd64,kubernetes.io/hostname=worker88,kubernetes.io/os=linux
worker46 Ready <none> 2m17s v1.21.0 CIS-node=compute02,beta.kubernetes.io/arch=amd64,beta.kubernetes.io/os=linux,kubernetes.io/arch=amd64,kubernetes.io/hostname=worker46,kubernetes.io/os=linux
4. Heal Worker Node with Pod-affinity
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
The operation steps and methods of healing worker node with
pod-affinity are the same as those in ``Heal a Worker Node`` of
``Heal Kubernetes Master/Worker Nodes``.
Confirm the Healing Operation is Successful on OpenStack
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
To confirm that healing worker node with pod-affinity
is successful, you can use Heat CLI. The confirmation points are
shown below.
1. Confirm that ``physical_resource_id`` pointing to
the healed worker node has been changed in ``members``
attribute of "OS::Nova::ServerGroup" resource.
2. Confirm that the value of ``server_groups`` attribute in worker node
VM healed is ``physical_resource_id`` of "OS::Nova::ServerGroup"
resource.
After healing worker node, the following command can check
confirmation point 1. ``physical_resource_id`` changed in members
is 'a576d70c-d299-cf83-745a-63a1f49da7d3'.
* "OS::Nova::ServerGroup" resource information of pod-affinity
.. code-block:: console
$ openstack stack resource show vnf-2456188c-d882-4de2-8cd0-54a7a2ea4e6a srvgroup --fit
+------------------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| Field | Value |
+------------------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| attributes | {'id': '46186a58-5cac-4dd6-a516-d6deb1461f8a', 'name': 'ServerGroup', 'policy': 'anti-affinity', 'rules': {}, 'members': ['51826868-74d6-4ce1-9b0b-157efdfc9490', 'e4bef063-30f9-4f26-b5fc-75d99e46db1e', |
| | '4cb1324f-356d-418a-7935-b0b34c3b17ed'], 'project_id': 'ff61312f72f94c7da3d0c3c4578ad121', 'user_id': '4751fbe7b18a4469bedf89ba0cc09616'} | |
| creation_time | 2021-04-22T02:47:22Z |
| description | |
| links | [{'href': 'http://192.168.10.115/heat-api/v1/ff61312f72f94c7da3d0c3c4578ad121/stacks/vnf-2456188c-d882-4de2-8cd0-54a7a2ea4e6a/4dfd5d41-77c9-4e72-b30f-d06f0ca79ebf/resources/srvgroup', 'rel': 'self'}, {'href': |
| | 'http://192.168.10.115/heat-api/v1/ff61312f72f94c7da3d0c3c4578ad121/stacks/vnf-2456188c-d882-4de2-8cd0-54a7a2ea4e6a/4dfd5d41-77c9-4e72-b30f-d06f0ca79ebf', 'rel': 'stack'}] |
| logical_resource_id | srvgroup |
| physical_resource_id | 46186a58-5cac-4dd6-a516-d6deb1461f8a |
| required_by | ['worker_instance'] |
| resource_name | srvgroup |
| resource_status | UPDATE_COMPLETE |
| resource_status_reason | state changed |
| resource_type | OS::Nova::ServerGroup |
| updated_time | 2021-04-22T04:15:22Z |
+------------------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
$ openstack stack resource list vnf-2456188c-d882-4de2-8cd0-54a7a2ea4e6a -n 2 --filter type=OS::Nova::Server -c resource_name -c physical_resource_id -c resource_type -c resource_status
+---------------+--------------------------------------+------------------+-----------------+
| resource_name | physical_resource_id | resource_type | resource_status |
+---------------+--------------------------------------+------------------+-----------------+
| workerNode | 51826868-74d6-4ce1-9b0b-157efdfc9490 | OS::Nova::Server | CREATE_COMPLETE |
| workerNode | e4bef063-30f9-4f26-b5fc-75d99e46db1e | OS::Nova::Server | CREATE_COMPLETE |
| workerNode | 4cb1324f-356d-418a-7935-b0b34c3b17ed | OS::Nova::Server | CREATE_COMPLETE |
| masterNode | d4578afd-9eb6-2ca0-1932-ccd69d763b6b | OS::Nova::Server | CREATE_COMPLETE |
| masterNode | 42904925-7d05-e311-3953-dc92c88428b0 | OS::Nova::Server | CREATE_COMPLETE |
| masterNode | 282a9ba5-fcbc-3f4b-6ca3-71d383e26134 | OS::Nova::Server | CREATE_COMPLETE |
+---------------+--------------------------------------+------------------+-----------------+
The following command can check confirmation point 2. The resource
with name 'workerNode' in resource with 'plkz6sfomuhx' resource_name
is the VM healed.
* "worker node VM" information of pod-affinity
.. code-block:: console
$ openstack stack resource list vnf-2456188c-d882-4de2-8cd0-54a7a2ea4e6a -n 2 --filter type=podaffinity_nested_worker.yaml -c resource_name -c physical_resource_id -c resource_type -c resource_status
+---------------+--------------------------------------+--------------------------------+------------------+
| resource_name | physical_resource_id | resource_type | resource_status |
+---------------+--------------------------------------+--------------------------------+------------------+
| kxogpuzgdcvi | 3b11dba8-2dab-4ad4-8241-09a0501cab47 | podaffinity_nested_worker.yaml | UPDATE_COMPLETE |
| n5s7ycewii5s | 4b2ac686-e6ff-4397-88dd-cbba7d2e7a34 | podaffinity_nested_worker.yaml | UPDATE_COMPLETE |
| plkz6sfomuhx | 24d0076c-672a-e52d-1947-ec8495708b5d | podaffinity_nested_worker.yaml | CREATE_COMPLETE |
+---------------+--------------------------------------+--------------------------------+------------------+
$ openstack stack resource show 24d0076c-672a-e52d-1947-ec8495708b5d workerNode --fit
+------------------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| Field | Value |
+------------------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| attributes | {'id': '4cb1324f-356d-418a-7935-b0b34c3b17ed', 'name': 'workerNode', 'status': 'ACTIVE', 'tenant_id': 'ff61312f72f94c7da3d0c3c4578ad121', 'user_id': '4751fbe7b18a4469bedf89ba0cc09616', 'metadata': {}, 'hostId': |
| | 'bdd83b04143e4048e93141cfb5600c39571a94e501564cf7a1380073', 'image': {'id': '959c1e45-e140-407d-aaaf-bb5eea93a828', 'links': [{'rel': 'bookmark', 'href': 'http://192.168.10.115/compute/images/959c1e45-e140-407d-aaaf- |
| | bb5eea93a828'}]}, 'flavor': {'vcpus': 2, 'ram': 4096, 'disk': 40, 'ephemeral': 0, 'swap': 0, 'original_name': 'm1.medium', 'extra_specs': {'hw_rng:allowed': 'True'}}, 'created': '2021-04-22T02:47:26Z', 'updated': |
| | '2021-04-22T02:47:34Z', 'addresses': {'net0': [{'version': 4, 'addr': '10.10.0.46', 'OS-EXT-IPS:type': 'fixed', 'OS-EXT-IPS-MAC:mac_addr': 'fa:16:3e:28:fc:7a'}]}, 'accessIPv4': '', 'accessIPv6': '', 'links': [{'rel': 'self', |
| | 'href': 'http://192.168.10.115/compute/v2.1/servers/4cb1324f-356d-418a-7935-b0b34c3b17ed'}, {'rel': 'bookmark', 'href': 'http://192.168.10.115/compute/servers/4cb1324f-356d-418a-7935-b0b34c3b17ed'}], 'OS-DCF:diskConfig': |
| | 'MANUAL', 'progress': 0, 'OS-EXT-AZ:availability_zone': 'nova', 'config_drive': '', 'key_name': None, 'OS-SRV-USG:launched_at': '2021-04-22T02:47:28.000000', 'OS-SRV-USG:terminated_at': None, 'security_groups': [{'name': |
| | 'default'}], 'OS-EXT-SRV-ATTR:host': 'compute02', 'OS-EXT-SRV-ATTR:instance_name': 'instance-000003dd', 'OS-EXT-SRV-ATTR:hypervisor_hostname': 'compute02', 'OS-EXT-SRV-ATTR:reservation_id': 'r-lvg9ate8', 'OS-EXT-SRV- |
| | ATTR:launch_index': 0, 'OS-EXT-SRV-ATTR:hostname': 'workernode', 'OS-EXT-SRV-ATTR:kernel_id': '', 'OS-EXT-SRV-ATTR:ramdisk_id': '', 'OS-EXT-SRV-ATTR:root_device_name': '/dev/vda', 'OS-EXT-SRV-ATTR:user_data': 'Q29udGVudC1UeX |
| | BlOiBtdWx0aXBhcnQvbWl4ZWQ7IGJvdW5kYXJ5PSI9PT09PT09PT09PT09PT0wMDA5NDg1OTI5MTU3NzU5MzA2PT0iCk1JTUUtVmVyc2lvbjogMS4wCgotLT09PT09PT09PT09PT09PTAwMDk0ODU5MjkxNTc3NTkzMDY9PQpDb250ZW50LVR5cGU6IHRleHQvY2xvdWQtY29uZmlnOyBjaGFyc2V0PS |
| | J1cy1hc2NpaSIKTUlNRS1WZXJzaW9uOiAxLjAKQ29udGVudC1UcmFuc2Zlci1FbmNvZGluZzogN2JpdApDb250ZW50LURpc3Bvc2l0aW9uOiBhdHRhY2htZW50OyBmaWxlbmFtZT0iY2xvdWQtY29uZmlnIgoKCgojIENhcHR1cmUgYWxsIHN1YnByb2Nlc3Mgb3V0cHV0IGludG8gYSBsb2dmaWxlCi |
| | MgVXNlZnVsIGZvciB0cm91Ymxlc2hvb3RpbmcgY2xvdWQtaW5pdCBpc3N1ZXMKb3V0cHV0OiB7YWxsOiAnfCB0ZWUgLWEgL3Zhci9sb2cvY2xvdWQtaW5pdC1vdXRwdXQubG9nJ30KCi==', 'OS-EXT-STS:task_state': None, 'OS-EXT-STS:vm_state': 'active', 'OS-EXT- |
| | STS:power_state': 1, 'os-extended-volumes:volumes_attached': [], 'host_status': 'UP', 'locked': False, 'locked_reason': None, 'description': None, 'tags': [], 'trusted_image_certificates': None, 'server_groups': |
| | ['46186a58-5cac-4dd6-a516-d6deb1461f8a'], 'os_collect_config': {}} |
| creation_time | 2021-04-22T04:15:23Z |
| description | |
| links | [{'href': 'http://192.168.10.115/heat-api/v1/ff61312f72f94c7da3d0c3c4578ad121/stacks/vnf-2456188c-d882-4de2-8cd0-54a7a2ea4e6a-worker_instance-6wyaj6mgtjlt-plkz6sfomuhx-tvegcyfieq7m/24d0076c-672a-e52d-1947- |
| | ec8495708b5d/resources/workerNode', 'rel': 'self'}, {'href': 'http://192.168.10.115/heat- |
| | api/v1/ff61312f72f94c7da3d0c3c4578ad121/stacks/vnf-2456188c-d882-4de2-8cd0-54a7a2ea4e6a-worker_instance-6wyaj6mgtjlt-plkz6sfomuhx-tvegcyfieq7m/24d0076c-672a-e52d-1947-ec8495708b5d', 'rel': 'stack'}] |
| logical_resource_id | workerNode |
| parent_resource | plkz6sfomuhx |
| physical_resource_id | 4cb1324f-356d-418a-7935-b0b34c3b17ed |
| required_by | [] |
| resource_name | workerNode |
| resource_status | CREATE_COMPLETE |
| resource_status_reason | state changed |
| resource_type | OS::Nova::Server |
| updated_time | 2021-04-22T04:15:23Z |
+------------------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
Confirm the Healing Operation is Successful on Kubernetes
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
To confirm that the 'CIS-node' label has been added to worker node healed
successfully, you should login to one of the master nodes via ssh
in Kubernetes cluster, and use Kubernetes CLI. The confirmation
points are shown below.
1. Confirm that 'CIS-node' label is in the healed worker node's
labels.
2. Confirm that 'CIS-node' label's value is the Compute Server's name which
the worker node deployed on. The key of this value is
'OS-EXT-SRV-ATTR:host' in "worker node VM" information.
After healing, the following command can check
these confirmation points. The worker46 is the
healed worker node.
* worker node information in Kubernetes cluster
.. code-block:: console
$ kubectl get node --show-labels
NAME STATUS ROLES AGE VERSION LABELS
master110 Ready control-plane,master 5h34m v1.21.0 beta.kubernetes.io/arch=amd64,beta.kubernetes.io/os=linux,kubernetes.io/arch=amd64,kubernetes.io/hostname=master110,kubernetes.io/os=linux,node-role.kubernetes.io/control-plane=,node-role.kubernetes.io/master=,node.kubernetes.io/exclude-from-external-load-balancers=
master13 Ready control-plane,master 5h21m v1.21.0 beta.kubernetes.io/arch=amd64,beta.kubernetes.io/os=linux,kubernetes.io/arch=amd64,kubernetes.io/hostname=master13,kubernetes.io/os=linux,node-role.kubernetes.io/control-plane=,node-role.kubernetes.io/master=,node.kubernetes.io/exclude-from-external-load-balancers=
master159 Ready control-plane,master 5h48m v1.21.0 beta.kubernetes.io/arch=amd64,beta.kubernetes.io/os=linux,kubernetes.io/arch=amd64,kubernetes.io/hostname=master159,kubernetes.io/os=linux,node-role.kubernetes.io/control-plane=,node-role.kubernetes.io/master=,node.kubernetes.io/exclude-from-external-load-balancers=
worker52 Ready <none> 5h15m v1.21.0 CIS-node=compute01,beta.kubernetes.io/arch=amd64,beta.kubernetes.io/os=linux,kubernetes.io/arch=amd64,kubernetes.io/hostname=worker52,kubernetes.io/os=linux
worker88 Ready <none> 5h10m v1.21.0 CIS-node=compute03,beta.kubernetes.io/arch=amd64,beta.kubernetes.io/os=linux,kubernetes.io/arch=amd64,kubernetes.io/hostname=worker88,kubernetes.io/os=linux
worker46 Ready <none> 1m33s v1.21.0 CIS-node=compute02,beta.kubernetes.io/arch=amd64,beta.kubernetes.io/os=linux,kubernetes.io/arch=amd64,kubernetes.io/hostname=worker46,kubernetes.io/os=linux
Limitations Limitations
----------- -----------
1. If you deploy a single master node Kubernetes cluster, 1. If you deploy a single master node Kubernetes cluster,
@ -2308,6 +2873,7 @@ Reference
.. _sample_kubernetes_types.yaml: https://opendev.org/openstack/tacker/src/branch/master/samples/mgmt_driver/kubernetes_vnf_package/Definitions/sample_kubernetes_types.yaml .. _sample_kubernetes_types.yaml: https://opendev.org/openstack/tacker/src/branch/master/samples/mgmt_driver/kubernetes_vnf_package/Definitions/sample_kubernetes_types.yaml
.. _sample_kubernetes_df_simple.yaml: https://opendev.org/openstack/tacker/src/branch/master/samples/mgmt_driver/kubernetes_vnf_package/Definitions/sample_kubernetes_df_simple.yaml .. _sample_kubernetes_df_simple.yaml: https://opendev.org/openstack/tacker/src/branch/master/samples/mgmt_driver/kubernetes_vnf_package/Definitions/sample_kubernetes_df_simple.yaml
.. _sample_kubernetes_df_complex.yaml: https://opendev.org/openstack/tacker/src/branch/master/samples/mgmt_driver/kubernetes_vnf_package/Definitions/sample_kubernetes_df_complex.yaml .. _sample_kubernetes_df_complex.yaml: https://opendev.org/openstack/tacker/src/branch/master/samples/mgmt_driver/kubernetes_vnf_package/Definitions/sample_kubernetes_df_complex.yaml
.. _sample_kubernetes_df_podaffinity.yaml: https://opendev.org/openstack/tacker/src/branch/master/samples/mgmt_driver/kubernetes_vnf_package/Definitions/sample_kubernetes_df_podaffinity.yaml
.. _install_k8s_cluster.sh: https://opendev.org/openstack/tacker/src/branch/master/samples/mgmt_driver/install_k8s_cluster.sh .. _install_k8s_cluster.sh: https://opendev.org/openstack/tacker/src/branch/master/samples/mgmt_driver/install_k8s_cluster.sh
.. _kubernetes_mgmt.py: https://opendev.org/openstack/tacker/src/branch/master/samples/mgmt_driver/kubernetes_mgmt.py .. _kubernetes_mgmt.py: https://opendev.org/openstack/tacker/src/branch/master/samples/mgmt_driver/kubernetes_mgmt.py
.. _nested/simple_nested_master.yaml: https://opendev.org/openstack/tacker/src/branch/master/samples/mgmt_driver/kubernetes_vnf_package/BaseHOT/simple/nested/simple_nested_master.yaml .. _nested/simple_nested_master.yaml: https://opendev.org/openstack/tacker/src/branch/master/samples/mgmt_driver/kubernetes_vnf_package/BaseHOT/simple/nested/simple_nested_master.yaml
@ -2316,4 +2882,7 @@ Reference
.. _nested/complex_nested_master.yaml: https://opendev.org/openstack/tacker/src/branch/master/samples/mgmt_driver/kubernetes_vnf_package/BaseHOT/complex/nested/complex_nested_master.yaml .. _nested/complex_nested_master.yaml: https://opendev.org/openstack/tacker/src/branch/master/samples/mgmt_driver/kubernetes_vnf_package/BaseHOT/complex/nested/complex_nested_master.yaml
.. _nested/complex_nested_worker.yaml: https://opendev.org/openstack/tacker/src/branch/master/samples/mgmt_driver/kubernetes_vnf_package/BaseHOT/complex/nested/complex_nested_worker.yaml .. _nested/complex_nested_worker.yaml: https://opendev.org/openstack/tacker/src/branch/master/samples/mgmt_driver/kubernetes_vnf_package/BaseHOT/complex/nested/complex_nested_worker.yaml
.. _complex_hot_top.yaml: https://opendev.org/openstack/tacker/src/branch/master/samples/mgmt_driver/kubernetes_vnf_package/BaseHOT/complex/complex_hot_top.yaml .. _complex_hot_top.yaml: https://opendev.org/openstack/tacker/src/branch/master/samples/mgmt_driver/kubernetes_vnf_package/BaseHOT/complex/complex_hot_top.yaml
.. _nested/podaffinity_nested_master.yaml: https://opendev.org/openstack/tacker/src/branch/master/samples/mgmt_driver/kubernetes_vnf_package/BaseHOT/podaffinity/nested/podaffinity_nested_master.yaml
.. _nested/podaffinity_nested_worker.yaml: https://opendev.org/openstack/tacker/src/branch/master/samples/mgmt_driver/kubernetes_vnf_package/BaseHOT/podaffinity/nested/podaffinity_nested_worker.yaml
.. _podaffinity_hot_top.yaml: https://opendev.org/openstack/tacker/src/branch/master/samples/mgmt_driver/kubernetes_vnf_package/BaseHOT/podaffinity/podaffinity_hot_top.yaml
.. _k8s_cluster_user_data.py: https://opendev.org/openstack/tacker/src/branch/master/samples/mgmt_driver/kubernetes_vnf_package/UserData/k8s_cluster_user_data.py .. _k8s_cluster_user_data.py: https://opendev.org/openstack/tacker/src/branch/master/samples/mgmt_driver/kubernetes_vnf_package/UserData/k8s_cluster_user_data.py

280
samples/mgmt_driver/kubernetes_mgmt.py
View File

@ -41,10 +41,13 @@ HELM_CMD_TIMEOUT = 30
HELM_INSTALL_TIMEOUT = 300 HELM_INSTALL_TIMEOUT = 300
HELM_CHART_DIR = "/var/tacker/helm" HELM_CHART_DIR = "/var/tacker/helm"
HELM_CHART_CMP_PATH = "/tmp/tacker-helm.tgz" HELM_CHART_CMP_PATH = "/tmp/tacker-helm.tgz"
SERVER_WAIT_COMPLETE_TIME = 60
class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver): class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
FLOATING_IP_FLAG = False
def __init__(self):
self._init_flag()
def get_type(self): def get_type(self):
return 'mgmt-drivers-kubernetes' return 'mgmt-drivers-kubernetes'
@ -60,6 +63,11 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
grant_request, **kwargs): grant_request, **kwargs):
pass pass
def _init_flag(self):
self.FLOATING_IP_FLAG = False
self.SET_NODE_LABEL_FLAG = False
self.SET_ZONE_ID_FLAG = False
def _check_is_cidr(self, cidr_str): def _check_is_cidr(self, cidr_str):
# instantiate: check cidr # instantiate: check cidr
try: try:
@ -182,9 +190,6 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
# ha: get group resources list # ha: get group resources list
nest_resources_list = heatclient.resources.list(stack_id=stack_id) nest_resources_list = heatclient.resources.list(stack_id=stack_id)
group_stack_name = node.get("aspect_id") group_stack_name = node.get("aspect_id")
if 'lcm-operation-user-data' in additional_params.keys() and \
'lcm-operation-user-data-class' in additional_params.keys():
group_stack_name = group_stack_name + '_group'
group_stack_id = "" group_stack_id = ""
for nest_resources in nest_resources_list: for nest_resources in nest_resources_list:
if nest_resources.resource_name == group_stack_name: if nest_resources.resource_name == group_stack_name:
@ -225,12 +230,86 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
error_message="Failed to get the cluster ip") error_message="Failed to get the cluster ip")
return cluster_ip return cluster_ip
def _get_zone_id_from_grant(self, vnf_instance, grant, operation_type,
physical_resource_id):
zone_id = ''
for vnfc_resource in \
vnf_instance.instantiated_vnf_info.vnfc_resource_info:
if physical_resource_id == \
vnfc_resource.compute_resource.resource_id:
vnfc_id = vnfc_resource.id
break
if not vnfc_id:
msg = 'Failed to find Vnfc Resource related ' \
'to this physical_resource_id {}.'.format(
physical_resource_id)
LOG.error(msg)
raise exceptions.MgmtDriverOtherError(
error_message=msg)
if operation_type == 'HEAL':
resources = grant.update_resources
else:
resources = grant.add_resources
for resource in resources:
if vnfc_id == resource.resource_definition_id:
add_resource_zone_id = resource.zone_id
break
if not add_resource_zone_id:
msg = 'Failed to find specified zone id' \
' related to Vnfc Resource {} in grant'.format(
vnfc_id)
LOG.warn(msg)
else:
for zone in grant.zones:
if add_resource_zone_id == zone.id:
zone_id = zone.zone_id
break
return zone_id
def _get_pod_affinity_info(self, heatclient, nest_stack_id, stack_id,
vnf_instance, grant):
zone_id = ''
host_compute = ''
nest_resources_list = heatclient.resources.list(
stack_id=nest_stack_id)
for nest_res in nest_resources_list:
if nest_res.resource_type == 'OS::Nova::ServerGroup':
pod_affinity_res_info = heatclient.resources.get(
stack_id=nest_stack_id,
resource_name=nest_res.resource_name)
srv_grp_policies = pod_affinity_res_info.attributes.get(
'policy')
if srv_grp_policies and srv_grp_policies == 'anti-affinity':
srv_grp_phy_res_id = pod_affinity_res_info.\
physical_resource_id
lowest_res_list = heatclient.resources.list(stack_id=stack_id)
for lowest_res in lowest_res_list:
if lowest_res.resource_type == 'OS::Nova::Server':
lowest_res_name = lowest_res.resource_name
worker_node_res_info = heatclient.resources.get(
stack_id=stack_id, resource_name=lowest_res_name)
srv_groups = worker_node_res_info.attributes.get(
'server_groups')
if srv_groups and srv_grp_phy_res_id in srv_groups:
host_compute = worker_node_res_info.attributes.get(
'OS-EXT-SRV-ATTR:host')
if self.SET_ZONE_ID_FLAG:
phy_res_id = worker_node_res_info.physical_resource_id
zone_id = self._get_zone_id_from_grant(
vnf_instance, grant, 'INSTANTIATE', phy_res_id)
return host_compute, zone_id
def _get_install_info_for_k8s_node(self, nest_stack_id, node, def _get_install_info_for_k8s_node(self, nest_stack_id, node,
additional_params, role, additional_params, role,
access_info): access_info, vnf_instance, grant):
# instantiate: get k8s ssh ips # instantiate: get k8s ssh ips
vm_dict_list = [] vm_dict_list = []
stack_id = '' stack_id = ''
zone_id = ''
host_compute = ''
heatclient = hc.HeatClient(access_info) heatclient = hc.HeatClient(access_info)
# get ssh_ip and nic_ip and set ssh's values # get ssh_ip and nic_ip and set ssh's values
@ -278,8 +357,14 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
stack_id=stack_id, stack_id=stack_id,
resource_name=node.get('nic_cp_name')).attributes.get( resource_name=node.get('nic_cp_name')).attributes.get(
'fixed_ips')[0].get('ip_address') 'fixed_ips')[0].get('ip_address')
if role == 'worker':
# get pod_affinity info
host_compute, zone_id = self._get_pod_affinity_info(
heatclient, nest_stack_id, stack_id,
vnf_instance, grant)
vm_dict_list.append({ vm_dict_list.append({
"host_compute": host_compute,
"zone_id": zone_id,
"ssh": { "ssh": {
"username": node.get("username"), "username": node.get("username"),
"password": node.get("password"), "password": node.get("password"),
@ -357,7 +442,7 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
if retry == 0: if retry == 0:
LOG.error(e) LOG.error(e)
raise paramiko.SSHException() raise paramiko.SSHException()
time.sleep(30) time.sleep(SERVER_WAIT_COMPLETE_TIME)
def _get_vm_cidr_list(self, master_ip, proxy): def _get_vm_cidr_list(self, master_ip, proxy):
# ha and scale: get vm cidr list # ha and scale: get vm cidr list
@ -416,6 +501,42 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
self._execute_command( self._execute_command(
commander, ssh_command, HELM_INSTALL_TIMEOUT, 'install', 0) commander, ssh_command, HELM_INSTALL_TIMEOUT, 'install', 0)
def _set_node_label(self, commander, nic_ip, host_compute, zone_id):
"""Set node label function
This function can set a node label to worker node in kubernetes
cluster. After login master node of kubernetes cluster via ssh,
it will execute a cli command of kubectl. This command can update
the labels on a resource.
For example:
If the following command has been executed.
$ kubectl label nodes worker24 CIS-node=compute01
The result is:
$ kubectl get node --show-labels | grep worker24
NAME STATUS ROLES AGE VERSION LABELS
worker46 Ready <none> 1m33s v1.21.0 CIS-node=compute01...
Then when you deploy pods with this label(`CIS-node`) in
pod-affinity rule, the pod will be deployed on different worker nodes.
"""
worker_host_name = 'worker' + nic_ip.split('.')[3]
if host_compute:
ssh_command = "kubectl label nodes {worker_host_name}" \
" CIS-node={host_compute}".format(
worker_host_name=worker_host_name,
host_compute=host_compute)
self._execute_command(
commander, ssh_command, K8S_CMD_TIMEOUT, 'common', 0)
if zone_id:
ssh_command = "kubectl label nodes {worker_host_name}" \
" kubernetes.io/zone={zone_id}".format(
worker_host_name=worker_host_name,
zone_id=zone_id)
self._execute_command(
commander, ssh_command, K8S_CMD_TIMEOUT, 'common', 0)
commander.close_session()
def _install_k8s_cluster(self, context, vnf_instance, def _install_k8s_cluster(self, context, vnf_instance,
proxy, script_path, proxy, script_path,
master_vm_dict_list, worker_vm_dict_list, master_vm_dict_list, worker_vm_dict_list,
@ -650,6 +771,14 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
cluster_ip, kubeadm_token, ssl_ca_cert_hash) cluster_ip, kubeadm_token, ssl_ca_cert_hash)
commander.close_session() commander.close_session()
# set pod_affinity
commander = cmd_executer.RemoteCommandExecutor(
user=active_username, password=active_password,
host=active_host, timeout=K8S_CMD_TIMEOUT)
self._set_node_label(
commander, nic_ip, vm_dict.get('host_compute'),
vm_dict.get('zone_id'))
return (server, bearer_token, ssl_ca_cert, project_name, return (server, bearer_token, ssl_ca_cert, project_name,
masternode_ip_list) masternode_ip_list)
@ -689,6 +818,7 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
def instantiate_end(self, context, vnf_instance, def instantiate_end(self, context, vnf_instance,
instantiate_vnf_request, grant, instantiate_vnf_request, grant,
grant_request, **kwargs): grant_request, **kwargs):
self._init_flag()
# get vim_connect_info # get vim_connect_info
if hasattr(instantiate_vnf_request, 'vim_connection_info'): if hasattr(instantiate_vnf_request, 'vim_connection_info'):
vim_connection_info = self._get_vim_connection_info( vim_connection_info = self._get_vim_connection_info(
@ -735,6 +865,9 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
raise exceptions.MgmtDriverParamInvalid(param='cluster_cidr') raise exceptions.MgmtDriverParamInvalid(param='cluster_cidr')
else: else:
additional_param['master_node']['cluster_cidr'] = '10.96.0.0/12' additional_param['master_node']['cluster_cidr'] = '10.96.0.0/12'
# check grants exists
if grant:
self.SET_ZONE_ID_FLAG = True
# get stack_id # get stack_id
nest_stack_id = vnf_instance.instantiated_vnf_info.instance_id nest_stack_id = vnf_instance.instantiated_vnf_info.instance_id
# set vim_name # set vim_name
@ -747,10 +880,11 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
self._get_install_info_for_k8s_node( self._get_install_info_for_k8s_node(
nest_stack_id, master_node, nest_stack_id, master_node,
instantiate_vnf_request.additional_params, instantiate_vnf_request.additional_params,
'master', access_info) 'master', access_info, vnf_instance, grant)
worker_vm_dict_list = self._get_install_info_for_k8s_node( worker_vm_dict_list = self._get_install_info_for_k8s_node(
nest_stack_id, worker_node, nest_stack_id, worker_node,
instantiate_vnf_request.additional_params, 'worker', access_info) instantiate_vnf_request.additional_params, 'worker',
access_info, vnf_instance, grant)
server, bearer_token, ssl_ca_cert, project_name, masternode_ip_list = \ server, bearer_token, ssl_ca_cert, project_name, masternode_ip_list = \
self._install_k8s_cluster(context, vnf_instance, self._install_k8s_cluster(context, vnf_instance,
proxy, script_path, master_vm_dict_list, proxy, script_path, master_vm_dict_list,
@ -781,6 +915,7 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
def terminate_end(self, context, vnf_instance, def terminate_end(self, context, vnf_instance,
terminate_vnf_request, grant, terminate_vnf_request, grant,
grant_request, **kwargs): grant_request, **kwargs):
self._init_flag()
k8s_params = vnf_instance.instantiated_vnf_info.additional_params.get( k8s_params = vnf_instance.instantiated_vnf_info.additional_params.get(
'k8s_cluster_installation_param', {}) 'k8s_cluster_installation_param', {})
k8s_vim_name = k8s_params.get('vim_name') k8s_vim_name = k8s_params.get('vim_name')
@ -847,10 +982,9 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
# scale: get host resource list # scale: get host resource list
host_ips_list = [] host_ips_list = []
node_resource_name = node.get('aspect_id') node_resource_name = node.get('aspect_id')
node_group_resource_name = node.get('aspect_id') + '_group'
if node_resource_name: if node_resource_name:
resources_list = self._get_resources_list( resources_list = self._get_resources_list(
heatclient, stack_id, node_group_resource_name) heatclient, stack_id, node_resource_name)
for resources in resources_list: for resources in resources_list:
resource_info = heatclient.resource_get( resource_info = heatclient.resource_get(
resources.physical_resource_id, resources.physical_resource_id,
@ -885,7 +1019,7 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
paramiko.ssh_exception.NoValidConnectionsError) as e: paramiko.ssh_exception.NoValidConnectionsError) as e:
LOG.debug(e) LOG.debug(e)
retry -= 1 retry -= 1
time.sleep(30) time.sleep(SERVER_WAIT_COMPLETE_TIME)
if master_ip == master_ip_list[-1]: if master_ip == master_ip_list[-1]:
LOG.error('Failed to execute remote command.') LOG.error('Failed to execute remote command.')
raise exceptions.MgmtDriverRemoteCommandError() raise exceptions.MgmtDriverRemoteCommandError()
@ -927,7 +1061,7 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
scale_name_list = kwargs.get('scale_name_list') scale_name_list = kwargs.get('scale_name_list')
physical_resource_id = heatclient.resource_get( physical_resource_id = heatclient.resource_get(
stack_id, stack_id,
kwargs.get('scale_vnf_request', {}).aspect_id + '_group') \ kwargs.get('scale_vnf_request', {}).aspect_id) \
.physical_resource_id .physical_resource_id
worker_resource_list = heatclient.resource_get_list( worker_resource_list = heatclient.resource_get_list(
physical_resource_id) physical_resource_id)
@ -1006,6 +1140,7 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
def scale_start(self, context, vnf_instance, def scale_start(self, context, vnf_instance,
scale_vnf_request, grant, scale_vnf_request, grant,
grant_request, **kwargs): grant_request, **kwargs):
self._init_flag()
if scale_vnf_request.type == 'SCALE_IN': if scale_vnf_request.type == 'SCALE_IN':
vim_connection_info = \ vim_connection_info = \
self._get_vim_connection_info(context, vnf_instance) self._get_vim_connection_info(context, vnf_instance)
@ -1053,11 +1188,13 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
pass pass
def _get_worker_info(self, worker_node, worker_resource_list, def _get_worker_info(self, worker_node, worker_resource_list,
heatclient, scale_out_id_list): heatclient, scale_out_id_list, vnf_instance, grant):
normal_ssh_worker_ip_list = [] normal_ssh_worker_ip_list = []
normal_nic_worker_ip_list = [] normal_nic_worker_ip_list = []
add_worker_ssh_ip_list = [] add_worker_ssh_ip_list = []
add_worker_nic_ip_list = [] add_worker_nic_ip_list = []
zone_id_dict = {}
host_compute_dict = {}
for worker_resource in worker_resource_list: for worker_resource in worker_resource_list:
if self.FLOATING_IP_FLAG: if self.FLOATING_IP_FLAG:
ssh_ip = heatclient.resources.get( ssh_ip = heatclient.resources.get(
@ -1078,12 +1215,34 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
if worker_resource.physical_resource_id in scale_out_id_list: if worker_resource.physical_resource_id in scale_out_id_list:
add_worker_ssh_ip_list.append(ssh_ip) add_worker_ssh_ip_list.append(ssh_ip)
add_worker_nic_ip_list.append(nic_ip) add_worker_nic_ip_list.append(nic_ip)
if self.SET_NODE_LABEL_FLAG:
lowest_worker_resources_list = heatclient.resources.list(
stack_id=worker_resource.physical_resource_id)
for lowest_resource in lowest_worker_resources_list:
if lowest_resource.resource_type == \
'OS::Nova::Server':
worker_node_resource_info = \
heatclient.resource_get(
worker_resource.physical_resource_id,
lowest_resource.resource_name)
host_compute = worker_node_resource_info.\
attributes.get('OS-EXT-SRV-ATTR:host')
if self.SET_ZONE_ID_FLAG:
physical_resource_id = \
lowest_resource.physical_resource_id
zone_id = self._get_zone_id_from_grant(
vnf_instance, grant, 'SCALE',
physical_resource_id)
zone_id_dict[nic_ip] = zone_id
host_compute_dict[nic_ip] = host_compute
elif worker_resource.physical_resource_id not in \ elif worker_resource.physical_resource_id not in \
scale_out_id_list: scale_out_id_list:
normal_ssh_worker_ip_list.append(ssh_ip) normal_ssh_worker_ip_list.append(ssh_ip)
normal_nic_worker_ip_list.append(nic_ip) normal_nic_worker_ip_list.append(nic_ip)
return (add_worker_ssh_ip_list, add_worker_nic_ip_list, return (add_worker_ssh_ip_list, add_worker_nic_ip_list,
normal_ssh_worker_ip_list, normal_nic_worker_ip_list) normal_ssh_worker_ip_list, normal_nic_worker_ip_list,
host_compute_dict, zone_id_dict)
def _get_master_info( def _get_master_info(
self, master_resource_list, heatclient, master_node): self, master_resource_list, heatclient, master_node):
@ -1108,9 +1267,20 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
master_nic_ip_list.append(master_nic_ip) master_nic_ip_list.append(master_nic_ip)
return master_ssh_ip_list, master_nic_ip_list return master_ssh_ip_list, master_nic_ip_list
def _check_pod_affinity(self, heatclient, nest_stack_id, worker_node):
stack_base_hot_template = heatclient.stacks.template(
stack_id=nest_stack_id)
worker_instance_group_name = worker_node.get('aspect_id')
worker_node_properties = stack_base_hot_template['resources'][
worker_instance_group_name][
'properties']['resource']['properties']
if 'scheduler_hints' in worker_node_properties:
self.SET_NODE_LABEL_FLAG = True
def scale_end(self, context, vnf_instance, def scale_end(self, context, vnf_instance,
scale_vnf_request, grant, scale_vnf_request, grant,
grant_request, **kwargs): grant_request, **kwargs):
self._init_flag()
if scale_vnf_request.type == 'SCALE_OUT': if scale_vnf_request.type == 'SCALE_OUT':
k8s_cluster_installation_param = \ k8s_cluster_installation_param = \
vnf_instance.instantiated_vnf_info. \ vnf_instance.instantiated_vnf_info. \
@ -1118,7 +1288,7 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
vnf_package_path = vnflcm_utils._get_vnf_package_path( vnf_package_path = vnflcm_utils._get_vnf_package_path(
context, vnf_instance.vnfd_id) context, vnf_instance.vnfd_id)
nest_stack_id = vnf_instance.instantiated_vnf_info.instance_id nest_stack_id = vnf_instance.instantiated_vnf_info.instance_id
resource_name = scale_vnf_request.aspect_id + '_group' resource_name = scale_vnf_request.aspect_id
vim_connection_info = \ vim_connection_info = \
self._get_vim_connection_info(context, vnf_instance) self._get_vim_connection_info(context, vnf_instance)
heatclient = hc.HeatClient(vim_connection_info.access_info) heatclient = hc.HeatClient(vim_connection_info.access_info)
@ -1150,7 +1320,7 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
else: else:
master_resource_list = self._get_resources_list( master_resource_list = self._get_resources_list(
heatclient, nest_stack_id, master_node.get( heatclient, nest_stack_id, master_node.get(
'aspect_id') + '_group') 'aspect_id'))
master_ssh_ip_list, master_nic_ip_list = \ master_ssh_ip_list, master_nic_ip_list = \
self._get_master_info(master_resource_list, self._get_master_info(master_resource_list,
heatclient, master_node) heatclient, master_node)
@ -1165,11 +1335,17 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
heatclient, nest_stack_id, resource_name) heatclient, nest_stack_id, resource_name)
worker_node = \ worker_node = \
k8s_cluster_installation_param['worker_node'] k8s_cluster_installation_param['worker_node']
# check pod-affinity flag
if grant:
self.SET_ZONE_ID_FLAG = True
self._check_pod_affinity(heatclient, nest_stack_id, worker_node)
(add_worker_ssh_ip_list, add_worker_nic_ip_list, (add_worker_ssh_ip_list, add_worker_nic_ip_list,
normal_ssh_worker_ip_list, normal_nic_worker_ip_list) = \ normal_ssh_worker_ip_list, normal_nic_worker_ip_list,
host_compute_dict, zone_id_dict) = \
self._get_worker_info( self._get_worker_info(
worker_node, worker_resource_list, worker_node, worker_resource_list,
heatclient, scale_out_id_list) heatclient, scale_out_id_list, vnf_instance, grant)
# get kubeadm_token from one of master node # get kubeadm_token from one of master node
master_username, master_password = self._get_username_pwd( master_username, master_password = self._get_username_pwd(
@ -1242,6 +1418,14 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
commander, proxy, ha_flag, worker_nic_ip, commander, proxy, ha_flag, worker_nic_ip,
cluster_ip, kubeadm_token, ssl_ca_cert_hash) cluster_ip, kubeadm_token, ssl_ca_cert_hash)
commander.close_session() commander.close_session()
if self.SET_NODE_LABEL_FLAG:
commander, _ = self._connect_ssh_scale(
master_ssh_ip_list, master_username,
master_password)
self._set_node_label(
commander, worker_nic_ip,
host_compute_dict.get(worker_nic_ip),
zone_id_dict.get(worker_nic_ip))
hosts_str = '\\n'.join(add_worker_hosts) hosts_str = '\\n'.join(add_worker_hosts)
# set /etc/hosts on master node and normal worker node # set /etc/hosts on master node and normal worker node
@ -1344,7 +1528,7 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
def _get_worker_node_name( def _get_worker_node_name(
self, heatclient, worker_resource_list, self, heatclient, worker_resource_list,
target_physical_resource_ids, worker_node): target_physical_resource_ids, worker_node, vnf_instance, grant):
fixed_worker_infos = {} fixed_worker_infos = {}
not_fixed_worker_infos = {} not_fixed_worker_infos = {}
flag_worker = False flag_worker = False
@ -1376,6 +1560,22 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
get('fixed_ips')[0].get('ip_address') get('fixed_ips')[0].get('ip_address')
worker_name = 'worker' + worker_nic_ip.split('.')[-1] worker_name = 'worker' + worker_nic_ip.split('.')[-1]
fixed_worker_infos[worker_name] = {} fixed_worker_infos[worker_name] = {}
if self.SET_NODE_LABEL_FLAG:
worker_node_resource_info = heatclient.resource_get(
worker_resource.physical_resource_id,
worker_resource_info.resource_name)
host_compute = worker_node_resource_info.attributes.\
get('OS-EXT-SRV-ATTR:host')
fixed_worker_infos[worker_name]['host_compute'] = \
host_compute
if self.SET_ZONE_ID_FLAG:
physical_resource_id = \
worker_resource_info.physical_resource_id
zone_id = self._get_zone_id_from_grant(
vnf_instance, grant, 'HEAL',
physical_resource_id)
fixed_worker_infos[worker_name]['zone_id'] = \
zone_id
fixed_worker_infos[worker_name]['worker_ssh_ip'] = \ fixed_worker_infos[worker_name]['worker_ssh_ip'] = \
worker_ssh_ip worker_ssh_ip
fixed_worker_infos[worker_name]['worker_nic_ip'] = \ fixed_worker_infos[worker_name]['worker_nic_ip'] = \
@ -1598,7 +1798,7 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
self._get_worker_node_name( self._get_worker_node_name(
heatclient, worker_resource_list, heatclient, worker_resource_list,
target_physical_resource_ids, target_physical_resource_ids,
worker_node) worker_node, vnf_instance=None, grant=None)
if flag_master: if flag_master:
self._delete_master_node( self._delete_master_node(
fixed_master_infos, not_fixed_master_infos, fixed_master_infos, not_fixed_master_infos,
@ -1610,16 +1810,10 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
def _get_node_resource_name(self, vnf_additional_params, node): def _get_node_resource_name(self, vnf_additional_params, node):
if node.get('aspect_id'): if node.get('aspect_id'):
# in case of Userdata format # in case of HA master node
if 'lcm-operation-user-data' in vnf_additional_params.keys() and \ resource_name = node.get('aspect_id')
'lcm-operation-user-data-class' in \
vnf_additional_params.keys():
resource_name = node.get('aspect_id') + '_group'
# in case of SOL001 TOSCA-based VNFD with HA master node
else:
resource_name = node.get('aspect_id')
else: else:
# in case of SOL001 TOSCA-based VNFD with single master node # in case of single master node
resource_name = node.get('nic_cp_name') resource_name = node.get('nic_cp_name')
return resource_name return resource_name
@ -1684,6 +1878,7 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
def heal_start(self, context, vnf_instance, def heal_start(self, context, vnf_instance,
heal_vnf_request, grant, heal_vnf_request, grant,
grant_request, **kwargs): grant_request, **kwargs):
self._init_flag()
stack_id = vnf_instance.instantiated_vnf_info.instance_id stack_id = vnf_instance.instantiated_vnf_info.instance_id
vnf_additional_params = \ vnf_additional_params = \
vnf_instance.instantiated_vnf_info.additional_params vnf_instance.instantiated_vnf_info.additional_params
@ -1846,7 +2041,7 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
vnf_additional_params, master_resource_name, master_username, vnf_additional_params, master_resource_name, master_username,
master_password, vnf_package_path, worker_resource_name, master_password, vnf_package_path, worker_resource_name,
worker_username, worker_password, cluster_resource_name, worker_username, worker_password, cluster_resource_name,
master_node, worker_node): master_node, worker_node, vnf_instance, grant):
master_ssh_cp_name = master_node.get('nic_cp_name') master_ssh_cp_name = master_node.get('nic_cp_name')
flag_master = False flag_master = False
flag_worker = False flag_worker = False
@ -1867,12 +2062,18 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
self._get_master_node_name( self._get_master_node_name(
heatclient, master_resource_list, heatclient, master_resource_list,
target_physical_resource_ids, master_node) target_physical_resource_ids, master_node)
# check pod_affinity flag
if grant:
self.SET_ZONE_ID_FLAG = True
self._check_pod_affinity(heatclient, stack_id, worker_node)
worker_resource_list = self._get_resources_list( worker_resource_list = self._get_resources_list(
heatclient, stack_id, worker_resource_name) heatclient, stack_id, worker_resource_name)
flag_worker, fixed_worker_infos, not_fixed_worker_infos = \ flag_worker, fixed_worker_infos, not_fixed_worker_infos = \
self._get_worker_node_name( self._get_worker_node_name(
heatclient, worker_resource_list, heatclient, worker_resource_list,
target_physical_resource_ids, worker_node) target_physical_resource_ids,
worker_node, vnf_instance, grant)
if len(master_resource_list) > 1: if len(master_resource_list) > 1:
cluster_resource = heatclient.resource_get( cluster_resource = heatclient.resource_get(
stack_id, cluster_resource_name) stack_id, cluster_resource_name)
@ -1954,6 +2155,16 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
vnf_package_path, script_path, proxy, cluster_ip, vnf_package_path, script_path, proxy, cluster_ip,
kubeadm_token, ssl_ca_cert_hash, ha_flag) kubeadm_token, ssl_ca_cert_hash, ha_flag)
if self.SET_NODE_LABEL_FLAG:
for fixed_worker_name, fixed_worker in fixed_worker_infos.items():
commander, _ = self._connect_ssh_scale(
not_fixed_master_ssh_ips,
master_username, master_password)
self._set_node_label(
commander, fixed_worker.get('worker_nic_ip'),
fixed_worker.get('host_compute'),
fixed_worker.get('zone_id'))
def _get_all_hosts(self, not_fixed_master_infos, fixed_master_infos, def _get_all_hosts(self, not_fixed_master_infos, fixed_master_infos,
not_fixed_worker_infos, fixed_worker_infos): not_fixed_worker_infos, fixed_worker_infos):
master_hosts = [] master_hosts = []
@ -2003,6 +2214,7 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
def heal_end(self, context, vnf_instance, def heal_end(self, context, vnf_instance,
heal_vnf_request, grant, heal_vnf_request, grant,
grant_request, **kwargs): grant_request, **kwargs):
self._init_flag()
vnf_package_path = vnflcm_utils._get_vnf_package_path( vnf_package_path = vnflcm_utils._get_vnf_package_path(
context, vnf_instance.vnfd_id) context, vnf_instance.vnfd_id)
vnf_additional_params = \ vnf_additional_params = \
@ -2039,12 +2251,14 @@ class KubernetesMgmtDriver(vnflcm_abstract_driver.VnflcmMgmtAbstractDriver):
target_physical_resource_ids = \ target_physical_resource_ids = \
self._get_target_physical_resource_ids( self._get_target_physical_resource_ids(
vnf_instance, heal_vnf_request) vnf_instance, heal_vnf_request)
self._heal_and_join_k8s_node( self._heal_and_join_k8s_node(
heatclient, stack_id, target_physical_resource_ids, heatclient, stack_id, target_physical_resource_ids,
vnf_additional_params, master_resource_name, vnf_additional_params, master_resource_name,
master_username, master_password, vnf_package_path, master_username, master_password, vnf_package_path,
worker_resource_name, worker_username, worker_password, worker_resource_name, worker_username, worker_password,
cluster_resource_name, master_node, worker_node) cluster_resource_name, master_node, worker_node,
vnf_instance, grant)
def change_external_connectivity_start( def change_external_connectivity_start(
self, context, vnf_instance, self, context, vnf_instance,

14
samples/mgmt_driver/kubernetes_vnf_package/BaseHOT/complex/complex_hot_top.yaml
View File

@ -6,7 +6,7 @@ parameters:
type: json type: json
resources: resources:
master_instance_group: master_instance:
type: OS::Heat::AutoScalingGroup type: OS::Heat::AutoScalingGroup
properties: properties:
min_size: 3 min_size: 3
@ -25,7 +25,7 @@ resources:
properties: properties:
scaling_adjustment: 1 scaling_adjustment: 1
auto_scaling_group_id: auto_scaling_group_id:
get_resource: master_instance_group get_resource: master_instance
adjustment_type: change_in_capacity adjustment_type: change_in_capacity
master_instance_scale_in: master_instance_scale_in:
@ -33,10 +33,10 @@ resources:
properties: properties:
scaling_adjustment: -1 scaling_adjustment: -1
auto_scaling_group_id: auto_scaling_group_id:
get_resource: master_instance_group get_resource: master_instance
adjustment_type: change_in_capacity adjustment_type: change_in_capacity
worker_instance_group: worker_instance:
type: OS::Heat::AutoScalingGroup type: OS::Heat::AutoScalingGroup
properties: properties:
min_size: 2 min_size: 2
@ -54,7 +54,7 @@ resources:
properties: properties:
scaling_adjustment: 1 scaling_adjustment: 1
auto_scaling_group_id: auto_scaling_group_id:
get_resource: worker_instance_group get_resource: worker_instance
adjustment_type: change_in_capacity adjustment_type: change_in_capacity
worker_instance_scale_in: worker_instance_scale_in:
@ -62,7 +62,7 @@ resources:
properties: properties:
scaling_adjustment: -1 scaling_adjustment: -1
auto_scaling_group_id: auto_scaling_group_id:
get_resource: worker_instance_group get_resource: worker_instance
adjustment_type: change_in_capacity adjustment_type: change_in_capacity
vip_CP: vip_CP:
@ -70,4 +70,4 @@ resources:
properties: properties:
network: net0 network: net0
outputs: {} outputs: {}

34
samples/mgmt_driver/kubernetes_vnf_package/BaseHOT/podaffinity/nested/podaffinity_nested_master.yaml Normal file
View File

@ -0,0 +1,34 @@
heat_template_version: 2013-05-23
description: 'masterNode HOT for Sample VNF'
parameters:
flavor:
type: string
image:
type: string
net1:
type: string
scheduler_hints:
type: string
vip_port_ip:
type: string
resources:
masterNode:
type: OS::Nova::Server
properties:
flavor: { get_param: flavor }
name: masterNode
image: { get_param: image }
networks:
- port:
get_resource: masterNode_CP1
scheduler_hints:
group: { get_param: scheduler_hints }
masterNode_CP1:
type: OS::Neutron::Port
properties:
network: { get_param: net1 }
allowed_address_pairs:
- ip_address: { get_param: vip_port_ip }

30
samples/mgmt_driver/kubernetes_vnf_package/BaseHOT/podaffinity/nested/podaffinity_nested_worker.yaml Normal file
View File

@ -0,0 +1,30 @@
heat_template_version: 2013-05-23
description: 'workerNode HOT for Sample VNF'
parameters:
flavor:
type: string
image:
type: string
net1:
type: string
scheduler_hints:
type: string
resources:
workerNode:
type: OS::Nova::Server
properties:
flavor: { get_param: flavor }
name: workerNode
image: { get_param: image }
networks:
- port:
get_resource: workerNode_CP2
scheduler_hints:
group: { get_param: scheduler_hints }
workerNode_CP2:
type: OS::Neutron::Port
properties:
network: { get_param: net1 }

95
samples/mgmt_driver/kubernetes_vnf_package/BaseHOT/podaffinity/podaffinity_hot_top.yaml Normal file
View File

@ -0,0 +1,95 @@
heat_template_version: 2013-05-23
description: 'Simple Base HOT for Sample VNF'
parameters:
nfv:
type: json
k8s_worker_node_group:
type: string
description: Name of the ServerGroup
default: ServerGroupWorker
k8s_master_node_group:
type: string
description: Name of the ServerGroup
default: ServerGroupMaster
resources:
srvgroup_worker:
type: OS::Nova::ServerGroup
properties:
name: { get_param: k8s_worker_node_group }
policies: [ 'anti-affinity' ]
srvgroup_master:
type: OS::Nova::ServerGroup
properties:
name: { get_param: k8s_master_node_group }
policies: [ 'anti-affinity' ]
master_instance:
type: OS::Heat::AutoScalingGroup
properties:
min_size: 3
max_size: 5
desired_capacity: 3
resource:
type: master_instance.hot.yaml
properties:
flavor: { get_param: [ nfv, VDU, masterNode, flavor ] }
image: { get_param: [ nfv, VDU, masterNode, image ] }
net1: { get_param: [ nfv, CP, masterNode_CP1, network ] }
scheduler_hints: { get_resource: srvgroup_master }
vip_port_ip: { get_attr: [vip_CP, fixed_ips, 0, ip_address] }
master_instance_scale_out:
type: OS::Heat::ScalingPolicy
properties:
scaling_adjustment: 1
auto_scaling_group_id:
get_resource: master_instance
adjustment_type: change_in_capacity
master_instance_scale_in:
type: OS::Heat::ScalingPolicy
properties:
scaling_adjustment: -1
auto_scaling_group_id:
get_resource: master_instance
adjustment_type: change_in_capacity
worker_instance:
type: OS::Heat::AutoScalingGroup
properties:
min_size: 2
max_size: 4
desired_capacity: 2
resource:
type: worker_instance.hot.yaml
properties:
flavor: { get_param: [ nfv, VDU, workerNode, flavor ] }
image: { get_param: [ nfv, VDU, workerNode, image ] }
net1: { get_param: [ nfv, CP, workerNode_CP2, network ] }
scheduler_hints: { get_resource: srvgroup_worker }
worker_instance_scale_out:
type: OS::Heat::ScalingPolicy
properties:
scaling_adjustment: 1
auto_scaling_group_id:
get_resource: worker_instance
adjustment_type: change_in_capacity
worker_instance_scale_in:
type: OS::Heat::ScalingPolicy
properties:
scaling_adjustment: -1
auto_scaling_group_id:
get_resource: worker_instance
adjustment_type: change_in_capacity
vip_CP:
type: OS::Neutron::Port
properties:
network: net0
outputs: {}

14
samples/mgmt_driver/kubernetes_vnf_package/BaseHOT/simple/simple_hot_top.yaml
View File

@ -6,7 +6,7 @@ parameters:
type: json type: json
resources: resources:
master_instance_group: master_instance:
type: OS::Heat::AutoScalingGroup type: OS::Heat::AutoScalingGroup
properties: properties:
min_size: 1 min_size: 1
@ -24,7 +24,7 @@ resources:
properties: properties:
scaling_adjustment: 1 scaling_adjustment: 1
auto_scaling_group_id: auto_scaling_group_id:
get_resource: master_instance_group get_resource: master_instance
adjustment_type: change_in_capacity adjustment_type: change_in_capacity
master_instance_scale_in: master_instance_scale_in:
@ -32,10 +32,10 @@ resources:
properties: properties:
scaling_adjustment: -1 scaling_adjustment: -1
auto_scaling_group_id: auto_scaling_group_id:
get_resource: master_instance_group get_resource: master_instance
adjustment_type: change_in_capacity adjustment_type: change_in_capacity
worker_instance_group: worker_instance:
type: OS::Heat::AutoScalingGroup type: OS::Heat::AutoScalingGroup
properties: properties:
min_size: 2 min_size: 2
@ -53,7 +53,7 @@ resources:
properties: properties:
scaling_adjustment: 1 scaling_adjustment: 1
auto_scaling_group_id: auto_scaling_group_id:
get_resource: worker_instance_group get_resource: worker_instance
adjustment_type: change_in_capacity adjustment_type: change_in_capacity
worker_instance_scale_in: worker_instance_scale_in:
@ -61,7 +61,7 @@ resources:
properties: properties:
scaling_adjustment: -1 scaling_adjustment: -1
auto_scaling_group_id: auto_scaling_group_id:
get_resource: worker_instance_group get_resource: worker_instance
adjustment_type: change_in_capacity adjustment_type: change_in_capacity
outputs: {} outputs: {}

254
samples/mgmt_driver/kubernetes_vnf_package/Definitions/sample_kubernetes_df_podaffinity.yaml Normal file
View File

@ -0,0 +1,254 @@
tosca_definitions_version: tosca_simple_yaml_1_2
description: Simple deployment flavour for Sample VNF
imports:
- etsi_nfv_sol001_common_types.yaml
- etsi_nfv_sol001_vnfd_types.yaml
- sample_kubernetes_types.yaml
topology_template:
inputs:
id:
type: string
vendor:
type: string
version:
type: version
descriptor_id:
type: string
descriptor_version:
type: string
provider:
type: string
product_name:
type: string
software_version:
type: string
vnfm_info:
type: list
entry_schema:
type: string
flavour_id:
type: string
flavour_description:
type: string
substitution_mappings:
node_type: company.provider.VNF
properties:
flavour_id: podaffinity
requirements:
virtual_link_external1_1: [ masterNode_CP1, virtual_link ]
virtual_link_external1_2: [ workerNode_CP2, virtual_link ]
node_templates:
VNF:
type: company.provider.VNF
properties:
flavour_description: A complex flavour
interfaces:
Vnflcm:
instantiate_end:
implementation: mgmt-drivers-kubernetes
terminate_end:
implementation: mgmt-drivers-kubernetes
heal_start:
implementation: mgmt-drivers-kubernetes
heal_end:
implementation: mgmt-drivers-kubernetes
scale_start:
implementation: mgmt-drivers-kubernetes
scale_end:
implementation: mgmt-drivers-kubernetes
artifacts:
mgmt-drivers-kubernetes:
description: Management driver for kubernetes cluster
type: tosca.artifacts.Implementation.Python
file: Scripts/kubernetes_mgmt.py
masterNode:
type: tosca.nodes.nfv.Vdu.Compute
properties:
name: masterNode
description: masterNode compute node
vdu_profile:
min_number_of_instances: 3
max_number_of_instances: 5
sw_image_data:
name: Image for masterNode HA kubernetes
version: '20.04'
checksum:
algorithm: sha-512
hash: fb1a1e50f9af2df6ab18a69b6bc5df07ebe8ef962b37e556ce95350ffc8f4a1118617d486e2018d1b3586aceaeda799e6cc073f330a7ad8f0ec0416cbd825452
container_format: bare
disk_format: qcow2
min_disk: 0 GB
size: 2 GB
artifacts:
sw_image:
type: tosca.artifacts.nfv.SwImage
file: ../Files/images/ubuntu-20.04-server-cloudimg-amd64.img
capabilities:
virtual_compute:
properties:
requested_additional_capabilities:
properties:
requested_additional_capability_name: m1.medium
support_mandatory: true
target_performance_parameters:
entry_schema: test
virtual_memory:
virtual_mem_size: 4 GB
virtual_cpu:
num_virtual_cpu: 2
virtual_local_storage:
- size_of_storage: 45 GB
workerNode:
type: tosca.nodes.nfv.Vdu.Compute
properties:
name: workerNode
description: workerNode compute node
vdu_profile:
min_number_of_instances: 2
max_number_of_instances: 4
sw_image_data:
name: Image for workerNode HA kubernetes
version: '20.04'
checksum:
algorithm: sha-512
hash: fb1a1e50f9af2df6ab18a69b6bc5df07ebe8ef962b37e556ce95350ffc8f4a1118617d486e2018d1b3586aceaeda799e6cc073f330a7ad8f0ec0416cbd825452
container_format: bare
disk_format: qcow2
min_disk: 0 GB
size: 2 GB
artifacts:
sw_image:
type: tosca.artifacts.nfv.SwImage
file: ../Files/images/ubuntu-20.04-server-cloudimg-amd64.img
capabilities:
virtual_compute:
properties:
requested_additional_capabilities:
properties:
requested_additional_capability_name: m1.medium
support_mandatory: true
target_performance_parameters:
entry_schema: test
virtual_memory:
virtual_mem_size: 4 GB
virtual_cpu:
num_virtual_cpu: 2
virtual_local_storage:
- size_of_storage: 45 GB
masterNode_CP1:
type: tosca.nodes.nfv.VduCp
properties:
layer_protocols: [ ipv4 ]
order: 0
requirements:
- virtual_binding: masterNode
workerNode_CP2:
type: tosca.nodes.nfv.VduCp
properties:
layer_protocols: [ ipv4 ]
order: 0
requirements:
- virtual_binding: workerNode
policies:
- scaling_aspects:
type: tosca.policies.nfv.ScalingAspects
properties:
aspects:
master_instance:
name: master_instance
description: master_instance scaling aspect
max_scale_level: 2
step_deltas:
- delta_1
worker_instance:
name: worker_instance
description: worker_instance scaling aspect
max_scale_level: 2
step_deltas:
- delta_1
- masterNode_initial_delta:
type: tosca.policies.nfv.VduInitialDelta
properties:
initial_delta:
number_of_instances: 3
targets: [ masterNode ]
- workerNode_initial_delta:
type: tosca.policies.nfv.VduInitialDelta
properties:
initial_delta:
number_of_instances: 2
targets: [ workerNode ]
- masterNode_scaling_deltas:
type: tosca.policies.nfv.VduScalingAspectDeltas
properties:
aspect: master_instance
deltas:
delta_1:
number_of_instances: 1
targets: [ masterNode ]
- workerNode_scaling_deltas:
type: tosca.policies.nfv.VduScalingAspectDeltas
properties:
aspect: worker_instance
deltas:
delta_1:
number_of_instances: 1
targets: [ workerNode ]
- instantiation_levels:
type: tosca.policies.nfv.InstantiationLevels
properties:
levels:
instantiation_level_1:
description: Smallest size
scale_info:
master_instance:
scale_level: 0
worker_instance:
scale_level: 0
instantiation_level_2:
description: Largest size
scale_info:
master_instance:
scale_level: 2
worker_instance:
scale_level: 2
default_level: instantiation_level_1
- masterNode_instantiation_levels:
type: tosca.policies.nfv.VduInstantiationLevels
properties:
levels:
instantiation_level_1:
number_of_instances: 3
instantiation_level_2:
number_of_instances: 5
targets: [ masterNode ]
- workerNode_instantiation_levels:
type: tosca.policies.nfv.VduInstantiationLevels
properties:
levels:
instantiation_level_1:
number_of_instances: 2
instantiation_level_2:
number_of_instances: 4
targets: [ workerNode ]

1
samples/mgmt_driver/kubernetes_vnf_package/Definitions/sample_kubernetes_top.vnfd.yaml
View File

@ -8,6 +8,7 @@ imports:
- sample_kubernetes_types.yaml - sample_kubernetes_types.yaml
- sample_kubernetes_df_simple.yaml - sample_kubernetes_df_simple.yaml
- sample_kubernetes_df_complex.yaml - sample_kubernetes_df_complex.yaml
- sample_kubernetes_df_podaffinity.yaml
topology_template: topology_template:
inputs: inputs:

2
samples/mgmt_driver/kubernetes_vnf_package/Definitions/sample_kubernetes_types.yaml
View File

@ -50,7 +50,7 @@ node_types:
default: [ Tacker ] default: [ Tacker ]
flavour_id: flavour_id:
type: string type: string
constraints: [ valid_values: [ simple,complex ] ] constraints: [ valid_values: [ simple,complex,podaffinity ] ]
default: simple default: simple
flavour_description: flavour_description:
type: string type: string

4
samples/mgmt_driver/kubernetes_vnf_package/TOSCA-Metadata/TOSCA.meta
View File

@ -9,7 +9,7 @@ Content-Type: application/x-iso9066-image
Name: Scripts/install_k8s_cluster.sh Name: Scripts/install_k8s_cluster.sh
Content-Type: application/sh Content-Type: application/sh
Algorithm: SHA-256 Algorithm: SHA-256
Hash: bc859fb8ffb9f92a19139553bdd077428a2c9572196e5844f1c912a7a822c249 Hash: ec6423c8d68ff19e0d44b1437eddefa410a5ed43a434fa51ed07bde5a6d06abe
Name: Scripts/install_helm.sh Name: Scripts/install_helm.sh
Content-Type: application/sh Content-Type: application/sh
@ -19,4 +19,4 @@ Hash: 4af332b05e3e85662d403208e1e6d82e5276cbcd3b82a3562d2e3eb80d1ef714
Name: Scripts/kubernetes_mgmt.py Name: Scripts/kubernetes_mgmt.py
Content-Type: text/x-python Content-Type: text/x-python
Algorithm: SHA-256 Algorithm: SHA-256
Hash: bf651994ca7422aadeb0a12fed179f44ab709029c2eee9b2b9c7e8cbf339a66d Hash: bbaf48e285fc4ea2c5b250bd76cba93103ad24b97488509943005945c1a38b6c