Skip to content
This repository has been archived by the owner on Jul 28, 2023. It is now read-only.

Commit

Permalink
Merge pull request #239 from indigo-dc/devel
Browse files Browse the repository at this point in the history
Devel
  • Loading branch information
micafer authored Jun 7, 2018
2 parents 2316dc3 + c7ea6d7 commit 190ec34
Show file tree
Hide file tree
Showing 17 changed files with 255 additions and 79 deletions.
17 changes: 17 additions & 0 deletions IM/connectors/CloudConnector.py
Original file line number Diff line number Diff line change
Expand Up @@ -271,6 +271,23 @@ def delete_snapshots(self, vm, auth_data):
except:
self.log_exception("Error deleting snapshots.")

def get_cloud_init_data(self, radl):
"""
Get the cloud init data specified by the user in the RADL
"""
configure_name = None
if radl.contextualize.items:
system_name = radl.systems[0].name

for item in radl.contextualize.items.values():
if item.system == system_name and item.get_ctxt_tool() == "cloud_init":
configure_name = item.configure

if configure_name:
return radl.get_configure_by_name(configure_name).recipes
else:
return None

def log_msg(self, level, msg, exc_info=0):
msg = "Inf ID: %s: %s" % (self.inf.id, msg)
self.logger.log(level, msg, exc_info=exc_info)
Expand Down
17 changes: 0 additions & 17 deletions IM/connectors/EC2.py
Original file line number Diff line number Diff line change
Expand Up @@ -497,23 +497,6 @@ def get_default_subnet(self, conn):

return vpc_id, subnet_id

def get_cloud_init_data(self, radl):
"""
Get the cloud init data specified by the user in the RADL
"""
configure_name = None
if radl.contextualize.items:
system_name = radl.systems[0].name

for item in radl.contextualize.items.values():
if item.system == system_name and item.get_ctxt_tool() == "cloud_init":
configure_name = item.configure

if configure_name:
return radl.get_configure_by_name(configure_name).recipes
else:
return None

def launch(self, inf, radl, requested_radl, num_vm, auth_data):

im_username = "im_user"
Expand Down
17 changes: 0 additions & 17 deletions IM/connectors/GCE.py
Original file line number Diff line number Diff line change
Expand Up @@ -353,23 +353,6 @@ def get_default_net(self, driver):
else:
return None

def get_cloud_init_data(self, radl):
"""
Get the cloud init data specified by the user in the RADL
"""
configure_name = None
if radl.contextualize.items:
system_name = radl.systems[0].name

for item in radl.contextualize.items.values():
if item.system == system_name and item.get_ctxt_tool() == "cloud_init":
configure_name = item.configure

if configure_name:
return radl.get_configure_by_name(configure_name).recipes
else:
return None

def create_firewall(self, inf, net_name, radl, driver):
"""
Create a firewall for the net using the outports param
Expand Down
20 changes: 2 additions & 18 deletions IM/connectors/OCCI.py
Original file line number Diff line number Diff line change
Expand Up @@ -552,23 +552,6 @@ def get_os_tpl_scheme(self, occi_info, os_tpl):
"""
return self.get_scheme(occi_info, os_tpl, 'os_tpl')

def get_cloud_init_data(self, radl):
"""
Get the cloud init data specified by the user in the RADL
"""
configure_name = None
if radl.contextualize.items:
system_name = radl.systems[0].name

for item in radl.contextualize.items.values():
if item.system == system_name and item.get_ctxt_tool() == "cloud_init":
configure_name = item.configure

if configure_name:
return radl.get_configure_by_name(configure_name).recipes
else:
return None

def create_volumes(self, system, auth_data):
"""
Attach the required volumes (in the RADL) to the launched instance
Expand Down Expand Up @@ -1233,7 +1216,8 @@ def attach_volume(self, vm, volume_id, device, mount_path, auth_data):
body += 'X-OCCI-Attribute: occi.core.id="%s"\n' % disk_id
body += 'X-OCCI-Attribute: occi.core.target="%s/storage/%s"\n' % (self.cloud.path, volume_id)
body += 'X-OCCI-Attribute: occi.core.source="%s/compute/%s"' % (self.cloud.path, vm.id)
body += 'X-OCCI-Attribute: occi.storagelink.deviceid="/dev/%s"' % device
if device:
body += '\nX-OCCI-Attribute: occi.storagelink.deviceid="/dev/%s"' % device
# body += 'X-OCCI-Attribute: occi.storagelink.mountpoint="%s"' % mount_path
resp = self.create_request('POST', url, auth_data, headers, body)

Expand Down
17 changes: 0 additions & 17 deletions IM/connectors/OpenStack.py
Original file line number Diff line number Diff line change
Expand Up @@ -566,23 +566,6 @@ def get_networks(self, driver, radl):

return nets

def get_cloud_init_data(self, radl):
"""
Get the cloud init data specified by the user in the RADL
"""
configure_name = None
if radl.contextualize.items:
system_name = radl.systems[0].name

for item in radl.contextualize.items.values():
if item.system == system_name and item.get_ctxt_tool() == "cloud_init":
configure_name = item.configure

if configure_name:
return radl.get_configure_by_name(configure_name).recipes
else:
return None

def launch(self, inf, radl, requested_radl, num_vm, auth_data):
driver = self.get_driver(auth_data)

Expand Down
1 change: 1 addition & 0 deletions changelog
Original file line number Diff line number Diff line change
Expand Up @@ -423,3 +423,4 @@ IM 1.7.3:
* Fix error getting VM info in case of having an HD added.
* Improve OpenStack network management.
* Enable to set poolname in the TOSCA docs.
* Error when trying to attach a storage in OCCI (OpenStack sites).
4 changes: 2 additions & 2 deletions contextualization/conf-ansible.yml
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
ignore_errors: yes
register: python_install
changed_when: python_install.stdout_lines|length > 1
when: python_exists|failed
when: python_exists is failed

- name: Get Facts
setup:
Expand All @@ -41,7 +41,7 @@

- name: Ubuntu force apt update (avoid apt lock)
command: apt update
when: ansible_distribution == "Ubuntu" and apt_update|failed
when: ansible_distribution == "Ubuntu" and apt_update is failed

- name: Ubuntu install Ansible requisites with apt
apt: name=python-pip,python-jinja2,sshpass,openssh-client,unzip
Expand Down
16 changes: 15 additions & 1 deletion doc/source/client.rst
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,8 @@ user can specify the following parameters::
auth_file=auth.dat
xmlrpc_ssl_ca_certs=/tmp/pki/ca-chain.pem

.. _inv-client:

Invocation
----------

Expand Down Expand Up @@ -251,10 +253,22 @@ OpenStack has a set of additional fields to access a cloud site:
The possible values are: ``2.0_password``, ``2.0_voms``, ``3.x_password`` or ``3.x_oidc_access_token``.
The default value is ``2.0_password``.

* ``base_url`` base URL to the OpenStack API endpoint. By default, the connector obtains API endpoint URL from the
* ``api_version`` the api version used to connect with nova endpoint.
The possible values are: ``1.0``, ``1.1``, ``2.0`, ``2.1`` or ``2.2``.
The default value is ``2.0``.

* ``base_url`` base URL to the OpenStack API nova endpoint. By default, the connector obtains API endpoint URL from the
server catalog, but if this argument is provided, this step is skipped and the provided value is used directly.
The value is: http://cloud_server.com:8774/v2/<tenant_id>.

* ``network_url`` base URL to the OpenStack API neutron endpoint. By default, the connector obtains API endpoint URL from the
server catalog, but if this argument is provided, this step is skipped and the provided value is used directly.
The value is: http://cloud_server.com:9696.

* ``image_url`` base URL to the OpenStack API glance endpoint. By default, the connector obtains API endpoint URL from the
server catalog, but if this argument is provided, this step is skipped and the provided value is used directly.
The value is: http://cloud_server.com:9292.

* ``service_region`` the region of the cloud site (case sensitive). It is used to obtain the API
endpoint URL. The default value is: ``RegionOne``.

Expand Down
2 changes: 2 additions & 0 deletions doc/source/endpoints.rst
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
.. _endpoints:

Public IM Endpoints at UPV
==========================

Expand Down
187 changes: 187 additions & 0 deletions doc/source/gstarted.rst
Original file line number Diff line number Diff line change
@@ -0,0 +1,187 @@
Quick Start
===========

Launch IM Service
-----------------

To launch an instance of the Infrastructure Manager the easiest solution is to use the Docker image named
`grycap/im` that has been created using the default configuration.

To launch the IM service using docker::

$ sudo docker run -d -p 8899:8899 -p 8800:8800 --name im grycap/im

More information about this image can be found here: `https://registry.hub.docker.com/u/grycap/im/ <https://registry.hub.docker.com/u/grycap/im/>`_.

IM Client tools
---------------

To access the IM service two client tools can be used (apart from the two APIs):

* The IM client: You only have to call the install command of the pip tool with the IM-client package::

$ pip install IM-client

See full reference in IM Client :ref:`inv-client`.

* The IM web: To launch the IM Web portal in the same machine where we have previously launched the IM service use
the followiing docker command::

$ sudo docker run -d -p 80:80 --name im-web --link im:im grycap/im-web

See full manual in IM Web :ref:`use-web`.

In this first examples we will use the IM-client tool to create, manage and finally destroy a single VM.

Authentication file
^^^^^^^^^^^^^^^^^^^
To access the IM service an authenticatio file must be created. It must have one line per authentication element.
It must have at least one line with the authentication data for the IM service and another one for the Cloud/s
provider/s the user want to access.

An example to access an OpenNebula and/or an OpenStack site::

id = im; type = InfrastructureManager; username = user; password = pass
id = one; type = OpenNebula; host = osenserver:2633; username = user; password = pass
id = ost; type = OpenStack; host = https://ostserver:5000; username = user; password = pass; tenant = tenant

See all the options of the auth file are describe in section :ref:`auth-file`.

RADL basic example
^^^^^^^^^^^^^^^^^^^
Then the user must describe in a input file the cloud topology. It can be done in the IM native language (RADL) or
the TOSCA standard. In this first example we will so how to launch a single VM using RADL::

network net (outbound = 'yes')
system node (
cpu.count >= 2 and
memory.size >= 2G and
net_interface.0.connection = 'net' and
disk.0.image.url = 'one://someserver.com/123'
)
deploy node 1

In this RADL user is requesting 1 VM with at least 2 CPUs and 2 GB of RAM connected with a public IP. Finally
the user must specify the image used to boot the VM with the field `disk.0.image.url`. In this URL the user must
specify an existing image on the cluod provider where VM will be launched. O.S. image URLs for different
Cloud providers:

* **one://<server>:<port>/<image-id>**, for OpenNebula;
* **ost://<server>/<ami-id>**, for OpenStack;
* **aws://<region>/<ami-id>**, for Amazon Web Service;
* **gce://<region>/<image-id>**, for Google Cloud;
* **azr://<publisher>/<offer>/<sku>/<version>**, for Microsoft Azure; and
* **<fedcloud_endpoint_url>/<image_id>**, for FedCloud OCCI connector.
* **appdb://<site_name>/<apc_name>?<vo_name>**, for FedCloud OCCI connector using AppDB info (from ver. 1.6.0).
* **docker://<docker_image>**, for Docker images.
* **fbw://<fogbow_image>**, for FogBow images.

See full information about RADL language at :ref:`radl`. More RADL examples are available at the IM GitHub repo
`examples folder <https://github.com/grycap/im/tree/master/examples>`_.

TOSCA basic example
^^^^^^^^^^^^^^^^^^^

In case of you want to use a TOSCA file to define a similar example to the previous RADL one the file
should be like that::

tosca_definitions_version: tosca_simple_yaml_1_0

imports:
- indigo_custom_types: https://raw.githubusercontent.com/indigo-dc/tosca-types/master/custom_types.yaml

topology_template:
node_templates:
simple_node:
type: tosca.nodes.indigo.Compute
capabilities:
endpoint:
properties:
network_name: PUBLIC
host:
properties:
num_cpus: 2
mem_size: 2 GB
os:
properties:
image: one://someserver.com/123

outputs:
node_ip:
value: { get_attribute: [ simple_node, public_address, 0 ] }
node_creds:
value: { get_attribute: [ simple_node, endpoint, credential, 0 ] }

For more information about TOSCA see the
`OASIS TOSCA Simple Profile in YAML Version 1.0 <http://docs.oasis-open.org/tosca/TOSCA-Simple-Profile-YAML/v1.0/TOSCA-Simple-Profile-YAML-v1.0.html>`_.
The TOSCA support has been developed under de framework of the `INDIGO DataCloud EU project <http://http://www.indigo-datacloud.eu>`_.
You can see some input examples at
`https://github.com/indigo-dc/tosca-types/tree/master/examples <https://github.com/indigo-dc/tosca-types/tree/master/examples>`_.

Basic IM Client usage
^^^^^^^^^^^^^^^^^^^^^

Now that we have the authentication file and the RADL input file we can create our first infrastructure using
the IM client::

$ im_client.py -a auth.dat create input_file

By default this command expects the IM to be hosted on the `localhost` machine. If the server is located at other
host you must specify the `-u` or `-r` parameters to set the URL of the XML-RPC API or REST API respectively::

$ im_client.py -a auth.dat create input_file -r http://imhost.com:8800
$ im_client.py -a auth.dat create input_file -u http://imhost.com:8899

To avoid putting this parameters on all the IM Cleint calls you can create an `im_client.cfg` file with the
default options to use. See all the options at the client manual page: :ref:`inv-client`.

In this moment the IM client with contact the IM service to start the creation of the infrastructure. It will require
some time depending on the number of VMs or the cloud provider. Finally when all the VMs are created it will retun a
message like that::

Connected with: http://locahost:8899
Infrastructure successfully created with ID: 573c4b0a-67d9-11e8-b75f-0a580af401da

In case of error in the creation of all the VMs it will return an error message describing the errors raised.
If only some of them fails it will return the ID and the user must check the status of the VMs and take the
corresponding decissions. To get the state of of the infrastructure call the `getstate` option of the client::

$ im_client.py -a auth.dat getstate 573c4b0a-67d9-11e8-b75f-0a580af401da

The infrastructure is in state: running
VM ID: 0 is in state: running.

You have to wait untill your infrastructure is the state `configured`. In the meanwhile you can get the output
of the contextualization process to follow the status::

$ im_client.py -a auth.dat getcontmsg 573c4b0a-67d9-11e8-b75f-0a580af401da

Msg Contextualizator:

2018-05-02 14:20:31.816193: Select master VM
2018-05-02 14:20:31.819775: Wait master VM to boot
.
.
.

This message will show all the steps made by the IM to fully configure the VM including the outputs of all
Ansible processes. Then you can access via SSH the created VM with the command::

$ im_client.py -a auth.dat ssh 573c4b0a-67d9-11e8-b75f-0a580af401da

And Enjoy you customized VM!!

Finally to destroy the infrastructure and all the related resources call the `destroy` operation::

$ im_client.py -a auth.dat destroy 573c4b0a-67d9-11e8-b75f-0a580af401da

Connected with: http://locahost:8899
Infrastructure successfully destroyed

IM Video Demos
-----------------

There is an Infrastructure Manager YouTube reproduction list with a set of videos with demos
of the functionality of the platform: see section: :ref:`videos`.
1 change: 1 addition & 0 deletions doc/source/index.rst
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,7 @@ Contents:
:maxdepth: 2

intro
gstarted
videos
manual
radl
Expand Down
Loading

0 comments on commit 190ec34

Please sign in to comment.