Vh ddlmZmZmZeZdZdZdZ ddl Z dZ ddl Z ddl mZdd lmZdd lmZmZgd d d ggdddggdgdgdggdd ZdZdZdZdZdZdZdZdZdZdZd Zd!Z d"Z!d#Z"d$Z#d%Z$d&Z%d'Z&d(Z'd)Z(d*Z)d+Z*d,Z+d-Z,d.Z-gd/Z.gd0Z/d1Z0d2Z1d3Z2d4Z3d5Z4dEd6Z5d7Z6d8Z7d9Z8d:Z9d;Z:d<Z;d=ZZ=gd?Z>d@Z?dAZ@dBZAdCZBeCdDk(reByy#e $rdZ YwxYw)F)absolute_importdivisionprint_functiona module: one_vm short_description: Creates or terminates OpenNebula instances description: - Manages OpenNebula instances. requirements: - pyone extends_documentation_fragment: - community.general.attributes attributes: check_mode: support: full diff_mode: support: none options: api_url: description: - URL of the OpenNebula RPC server. - It is recommended to use HTTPS so that the username/password are not transferred over the network unencrypted. - If not set then the value of the E(ONE_URL) environment variable is used. type: str api_username: description: - Name of the user to login into the OpenNebula RPC server. If not set then the value of the E(ONE_USERNAME) environment variable is used. type: str api_password: description: - Password of the user to login into OpenNebula RPC server. If not set then the value of the E(ONE_PASSWORD) environment variable is used. if both O(api_username) or O(api_password) are not set, then it will try authenticate with ONE auth file. Default path is C(~/.one/one_auth). - Set environment variable E(ONE_AUTH) to override this path. type: str template_name: description: - Name of VM template to use to create a new instance. type: str template_id: description: - ID of a VM template to use to create a new instance. type: int vm_start_on_hold: description: - Set to true to put vm on hold while creating. default: false type: bool instance_ids: description: - 'A list of instance IDs used for states: V(absent), V(running), V(rebooted), V(poweredoff).' aliases: ['ids'] type: list elements: int state: description: - V(present) - create instances from a template specified with C(template_id)/C(template_name). - V(running) - run instances. - V(poweredoff) - power-off instances. - V(rebooted) - reboot instances. - V(absent) - terminate instances. choices: ["present", "absent", "running", "rebooted", "poweredoff"] default: present type: str hard: description: - Reboot, power-off or terminate instances C(hard). default: false type: bool wait: description: - Wait for the instance to reach its desired state before returning. Keep in mind if you are waiting for instance to be in running state it does not mean that you will be able to SSH on that machine only that boot process have started on that instance. See the example using the M(ansible.builtin.wait_for) module for details. default: true type: bool wait_timeout: description: - How long before wait gives up, in seconds. default: 300 type: int attributes: description: - A dictionary of key/value attributes to add to new instances, or for setting C(state) of instances with these attributes. - Keys are case insensitive and OpenNebula automatically converts them to upper case. - Be aware V(NAME) is a special attribute which sets the name of the VM when it is deployed. - C(#) character(s) can be appended to the C(NAME) and the module will automatically add indexes to the names of VMs. - 'For example: V(NAME: foo-###) would create VMs with names V(foo-000), V(foo-001),...' - When used with O(count_attributes) and O(exact_count) the module will match the base name without the index part. default: {} type: dict labels: description: - A list of labels to associate with new instances, or for setting C(state) of instances with these labels. default: [] type: list elements: str count_attributes: description: - A dictionary of key/value attributes that can only be used with O(exact_count) to determine how many nodes based on a specific attributes criteria should be deployed. This can be expressed in multiple ways and is shown in the EXAMPLES section. type: dict count_labels: description: - A list of labels that can only be used with O(exact_count) to determine how many nodes based on a specific labels criteria should be deployed. This can be expressed in multiple ways and is shown in the EXAMPLES section. type: list elements: str count: description: - Number of instances to launch. default: 1 type: int exact_count: description: - Indicates how many instances that match O(count_attributes) and O(count_labels) parameters should be deployed. Instances are either created or terminated based on this value. - B(NOTE:) Instances with the least IDs will be terminated first. type: int mode: description: - Set permission mode of the instance in octet format, for example V(0600) to give owner C(use) and C(manage) and nothing to group and others. type: str owner_id: description: - ID of the user which will be set as the owner of the instance. type: int group_id: description: - ID of the group which will be set as the group of the instance. type: int memory: description: - The size of the memory for new instances (in MB, GB, ..). type: str disk_size: description: - The size of the disk created for new instances (in MB, GB, TB,...). - B(NOTE:) If The Template hats Multiple Disks the Order of the Sizes is matched against the order specified in O(template_id)/O(template_name). type: list elements: str cpu: description: - Percentage of CPU divided by 100 required for the new instance. Half a processor is written 0.5. type: float vcpu: description: - Number of CPUs (cores) new VM will have. type: int networks: description: - A list of dictionaries with network parameters. See examples for more details. default: [] type: list elements: dict disk_saveas: description: - Creates an image from a VM disk. - It is a dictionary where you have to specify C(name) of the new image. - Optionally you can specify C(disk_id) of the disk you want to save. By default C(disk_id) is 0. - B(NOTE:) This operation will only be performed on the first VM (if more than one VM ID is passed) and the VM has to be in the C(poweredoff) state. - Also this operation will fail if an image with specified C(name) already exists. type: dict persistent: description: - Create a private persistent copy of the template plus any image defined in DISK, and instantiate that copy. default: false type: bool version_added: '0.2.0' datastore_id: description: - Name of Datastore to use to create a new instance. version_added: '0.2.0' type: int datastore_name: description: - Name of Datastore to use to create a new instance. version_added: '0.2.0' type: str updateconf: description: - When O(instance_ids) is provided, updates running VMs with the C(updateconf) API call. - When new VMs are being created, emulates the C(updateconf) API call using direct template merge. - Allows for complete modifications of the C(CONTEXT) attribute. - "Supported attributes include:" - B(BACKUP_CONFIG:) V(BACKUP_VOLATILE), V(FS_FREEZE), V(INCREMENT_MODE), V(KEEP_LAST), V(MODE); - B(CONTEXT:) (Any value, except V(ETH*). Variable substitution will be made); - B(CPU_MODEL:) V(FEATURES), V(MODEL); - B(FEATURES:) V(ACPI), V(APIC), V(GUEST_AGENT), V(HYPERV), V(IOTHREADS), V(LOCALTIME), V(PAE), V(VIRTIO_BLK_QUEUES), V(VIRTIO_SCSI_QUEUES); - B(GRAPHICS:) V(COMMAND), V(KEYMAP), V(LISTEN), V(PASSWD), V(PORT), V(TYPE); - B(INPUT:) V(BUS), V(TYPE); - B(OS:) V(ARCH), V(BOOT), V(BOOTLOADER), V(FIRMWARE), V(INITRD), V(KERNEL), V(KERNEL_CMD), V(MACHINE), V(ROOT), V(SD_DISK_BUS), V(UUID); - B(RAW:) V(DATA), V(DATA_VMX), V(TYPE), V(VALIDATE); - B(VIDEO:) V(ATS), V(IOMMU), V(RESOLUTION), V(TYPE), V(VRAM). type: dict version_added: 6.3.0 author: - "Milan Ilic (@ilicmilan)" - "Jan Meerkamp (@meerkampdvv)" a - name: Create a new instance community.general.one_vm: template_id: 90 register: result - name: Print VM properties ansible.builtin.debug: msg: result - name: Deploy a new VM on hold community.general.one_vm: template_name: 'app1_template' vm_start_on_hold: 'True' - name: Deploy a new VM and set its name to 'foo' community.general.one_vm: template_name: 'app1_template' attributes: name: foo - name: Deploy a new VM and set its group_id and mode community.general.one_vm: template_id: 90 group_id: 16 mode: 660 - name: Deploy a new VM as persistent community.general.one_vm: template_id: 90 persistent: true - name: Change VM's permissions to 640 community.general.one_vm: instance_ids: 5 mode: 640 - name: Deploy 2 new instances and set memory, vcpu, disk_size and 3 networks community.general.one_vm: template_id: 15 disk_size: 35.2 GB memory: 4 GB vcpu: 4 count: 2 networks: - NETWORK_ID: 27 - NETWORK: "default-network" NETWORK_UNAME: "app-user" SECURITY_GROUPS: "120,124" - NETWORK_ID: 27 SECURITY_GROUPS: "10" - name: Deploy a new instance which uses a Template with two Disks community.general.one_vm: template_id: 42 disk_size: - 35.2 GB - 50 GB memory: 4 GB vcpu: 4 count: 1 networks: - NETWORK_ID: 27 - name: "Deploy an new instance with attribute 'bar: bar1' and set its name to 'foo'" community.general.one_vm: template_id: 53 attributes: name: foo bar: bar1 - name: "Enforce that 2 instances with attributes 'foo1: app1' and 'foo2: app2' are deployed" community.general.one_vm: template_id: 53 attributes: foo1: app1 foo2: app2 exact_count: 2 count_attributes: foo1: app1 foo2: app2 - name: Enforce that 4 instances with an attribute 'bar' are deployed community.general.one_vm: template_id: 53 attributes: name: app bar: bar2 exact_count: 4 count_attributes: bar: # Deploy 2 new instances with attribute 'foo: bar' and labels 'app1' and 'app2' and names in format 'fooapp-##' # Names will be: fooapp-00 and fooapp-01 - name: Deploy 2 new instances community.general.one_vm: template_id: 53 attributes: name: fooapp-## foo: bar labels: - app1 - app2 count: 2 # Deploy 2 new instances with attribute 'app: app1' and names in format 'fooapp-###' # Names will be: fooapp-002 and fooapp-003 - name: Deploy 2 new instances community.general.one_vm: template_id: 53 attributes: name: fooapp-### app: app1 count: 2 # Reboot all instances with name in format 'fooapp-#' # Instances 'fooapp-00', 'fooapp-01', 'fooapp-002' and 'fooapp-003' will be rebooted - name: Reboot all instances with names in a certain format community.general.one_vm: attributes: name: fooapp-# state: rebooted # Enforce that only 1 instance with name in format 'fooapp-#' is deployed # The task will delete oldest instances, so only the 'fooapp-003' will remain - name: Enforce that only 1 instance with name in a certain format is deployed community.general.one_vm: template_id: 53 exact_count: 1 count_attributes: name: fooapp-# - name: Deploy an new instance with a network community.general.one_vm: template_id: 53 networks: - NETWORK_ID: 27 register: vm - name: Wait for SSH to come up ansible.builtin.wait_for: port: 22 host: '{{ vm.instances[0].networks[0].ip }}' - name: Terminate VMs by ids community.general.one_vm: instance_ids: - 153 - 160 state: absent - name: Reboot all VMs that have labels 'foo' and 'app1' community.general.one_vm: labels: - foo - app1 state: rebooted - name: "Fetch all VMs that have name 'foo' and attribute 'app: bar'" community.general.one_vm: attributes: name: foo app: bar register: results - name: Deploy 2 new instances with labels 'foo1' and 'foo2' community.general.one_vm: template_name: app_template labels: - foo1 - foo2 count: 2 - name: Enforce that only 1 instance with label 'foo1' will be running community.general.one_vm: template_name: app_template labels: - foo1 exact_count: 1 count_labels: - foo1 - name: Terminate all instances that have attribute foo community.general.one_vm: template_id: 53 exact_count: 0 count_attributes: foo: - name: "Power-off the VM and save VM's disk with id=0 to the image with name 'foo-image'" community.general.one_vm: instance_ids: 351 state: poweredoff disk_saveas: name: foo-image - name: "Save VM's disk with id=1 to the image with name 'bar-image'" community.general.one_vm: instance_ids: 351 disk_saveas: name: bar-image disk_id: 1 - name: "Deploy 2 new instances with a custom 'start script'" community.general.one_vm: template_name: app_template count: 2 updateconf: CONTEXT: START_SCRIPT: ip r r 169.254.16.86/32 dev eth0 - name: "Add a custom 'start script' to a running VM" community.general.one_vm: instance_ids: 351 updateconf: CONTEXT: START_SCRIPT: ip r r 169.254.16.86/32 dev eth0 - name: "Update SSH public keys inside the VM's context" community.general.one_vm: instance_ids: 351 updateconf: CONTEXT: SSH_PUBLIC_KEY: |- ssh-rsa ... ssh-ed25519 ... a instances_ids: description: A list of instances IDs whose state is changed or which are fetched with O(instance_ids) option. type: list returned: success sample: [1234, 1235] instances: description: A list of instances info whose state is changed or which are fetched with O(instance_ids) option. type: complex returned: success contains: vm_id: description: Vm ID. type: int sample: 153 vm_name: description: Vm name. type: str sample: foo template_id: description: Vm's template ID. type: int sample: 153 group_id: description: Vm's group ID. type: int sample: 1 group_name: description: Vm's group name. type: str sample: one-users owner_id: description: Vm's owner ID. type: int sample: 143 owner_name: description: Vm's owner name. type: str sample: app-user mode: description: Vm's mode. type: str returned: success sample: 660 state: description: State of an instance. type: str sample: ACTIVE lcm_state: description: Lcm state of an instance that is only relevant when the state is ACTIVE. type: str sample: RUNNING cpu: description: Percentage of CPU divided by 100. type: float sample: 0.2 vcpu: description: Number of CPUs (cores). type: int sample: 2 memory: description: The size of the memory in MB. type: str sample: 4096 MB disk_size: description: The size of the disk in MB. type: str sample: 20480 MB networks: description: A list of dictionaries with info about IP, NAME, MAC, SECURITY_GROUPS for each NIC. type: list sample: [ { "ip": "10.120.5.33", "mac": "02:00:0a:78:05:21", "name": "default-test-private", "security_groups": "0,10" }, { "ip": "10.120.5.34", "mac": "02:00:0a:78:05:22", "name": "default-test-private", "security_groups": "0" } ] uptime_h: description: Uptime of the instance in hours. type: int sample: 35 labels: description: A list of string labels that are associated with the instance. type: list sample: ["foo", "spec-label"] attributes: description: A dictionary of key/values attributes that are associated with the instance. type: dict sample: { "HYPERVISOR": "kvm", "LOGO": "images/logos/centos.png", "TE_GALAXY": "bar", "USER_INPUTS": null } updateconf: description: A dictionary of key/values attributes that are set with the updateconf API call. type: dict version_added: 6.3.0 sample: { "OS": { "ARCH": "x86_64" }, "CONTEXT": { "START_SCRIPT": "ip r r 169.254.16.86/32 dev eth0", "SSH_PUBLIC_KEY": "ssh-rsa ...\\nssh-ed25519 ..." } } tagged_instances: description: - A list of instances info based on a specific attributes and/or labels that are specified with O(count_attributes) and O(count_labels) options. type: complex returned: success contains: vm_id: description: Vm ID. type: int sample: 153 vm_name: description: Vm name. type: str sample: foo template_id: description: Vm's template ID. type: int sample: 153 group_id: description: Vm's group ID. type: int sample: 1 group_name: description: Vm's group name. type: str sample: one-users owner_id: description: Vm's user ID. type: int sample: 143 owner_name: description: Vm's user name. type: str sample: app-user mode: description: Vm's mode. type: str returned: success sample: 660 state: description: State of an instance. type: str sample: ACTIVE lcm_state: description: Lcm state of an instance that is only relevant when the state is ACTIVE. type: str sample: RUNNING cpu: description: Percentage of CPU divided by 100. type: float sample: 0.2 vcpu: description: Number of CPUs (cores). type: int sample: 2 memory: description: The size of the memory in MB. type: str sample: 4096 MB disk_size: description: The size of the disk in MB. type: list sample: ["20480 MB", "10240 MB"] networks: description: A list of dictionaries with info about IP, NAME, MAC, SECURITY_GROUPS for each NIC. type: list sample: [ { "ip": "10.120.5.33", "mac": "02:00:0a:78:05:21", "name": "default-test-private", "security_groups": "0,10" }, { "ip": "10.120.5.34", "mac": "02:00:0a:78:05:22", "name": "default-test-private", "security_groups": "0" } ] uptime_h: description: Uptime of the instance in hours. type: int sample: 35 labels: description: A list of string labels that are associated with the instance. type: list sample: ["foo", "spec-label"] attributes: description: A dictionary of key/values attributes that are associated with the instance. type: dict sample: {"HYPERVISOR": "kvm", "LOGO": "images/logos/centos.png", "TE_GALAXY": "bar", "USER_INPUTS": null} updateconf: description: A dictionary of key/values attributes that are set with the updateconf API call. type: dict version_added: 6.3.0 sample: {"OS": {"ARCH": "x86_64"}, "CONTEXT": {"START_SCRIPT": "ip r r 169.254.16.86/32 dev eth0", "SSH_PUBLIC_KEY": "ssh-rsa ...\\nssh-ed25519 ..."}} NTF) AnsibleModule) dict_merge)flattenrender) ARCHMACHINEKERNELINITRD BOOTLOADERBOOT SD_DISK_BUSUUIDFIRMWAREMODELFEATURES) ACPIPAEAPIC LOCALTIMEHYPERV GUEST_AGENTVIRTIO_BLK_QUEUESVIRTIO_SCSI_QUEUES IOTHREADSTYPEBUS)rLISTENPORTPASSWDKEYMAPCOMMAND)ATSIOMMU RESOLUTIONrVRAM)DATADATA_VMXrVALIDATE) FS_FREEZE KEEP_LASTBACKUP_VOLATILEMODEINCREMENT_MODE) OS CPU_MODELrINPUTGRAPHICSVIDEORAWCONTEXT BACKUP_CONFIGc|jD]m\}}|tvr!|jdj|t|s9|D]0}|t|vs|jdj||2oy)zDChecks if attributes are compatible with one.vm.updateconf API call.z#'{0:}' is not a valid VM attribute.msgz/'{0:}' is not a valid VM subattribute of '{1:}'N)itemsUPDATECONF_ATTRIBUTES fail_jsonformat)moduleto_checkattr subattributessubattrs l/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/general/plugins/modules/one_vm.pycheck_updateconfrFs'~~/nm , ,   !F!M!Md!S  T$T* $ nG3D99  %V%]%]^egk%l m n nci}|jD]J\}}|tvri}|jD]\}}t|r |t|vr|||<!|sF|||<L|S)z4Extracts 'updateconf' attributes from a VM template.)r<r=) vm_template updateconfrBrCtmprDvalues rEparse_updateconfrMsJ*002 #m , , +113 !NGU$T*w>STX>Y/Y CL ! "Jt  # rGc|jjdddd}d}d}d}|jD]}||s |dz}|}|j} |dk(ry|dkDr|j d|z|S)Nrz$There are more templates with name: r:) templatepoolinfo VMTEMPLATENAMEr>)r@client predicatepoolfoundfound_template template_nametemplates rE get_templater^s    # #BB 3D ENMOO* X AIE%N$MMM *  z CmST rGc$t||fdS)Nc"|jk(SNrV)r]r\s rEz&get_template_by_name..s(--=:XrGr^)r@rWr\s `rEget_template_by_nameres (Y ZZrGc$t||fdS)Nc"|jk(SraID)r] template_ids rErcz$get_template_by_id..s(++:TrGrd)r@rWrjs `rEget_template_by_idrks (U VVrGcX| t|||n t|||}|r |jSyra)rkreri)r@rW requested_idrequested_namer]s rEget_template_idrosACOC[!&&,?auv|EGUbVH{{rGc|jj}d}d}d}|jD]}||s |dz}|}|j} |dk(ry|dkDr|j d|z|S)NrrQrRz%There are more datastores with name: r:) datastorepoolrT DATASTORErVr>)r@rWrXrYrZfound_datastoredatastore_name datastores rE get_datastorervs    $ $ &D EON^^, Y AIE'O&^^N ,  z D~UV rGc$t||fdS)Nc"|jk(Srarb)rurts rErcz'get_datastore_by_name..sINNn<\rGrv)r@rWrts `rEget_datastore_by_namerzs )] ^^rGc$t||fdS)Nc"|jk(Srarh)ru datastore_ids rErcz%get_datastore_by_id..sILLLstrappend)r@rWstateidsvmsrrs rEget_vms_by_idsrs[ C &% ( :%8+   !:SZ!G  H 2  JrGc |jj|j}g}g}d|jvrmt |jdt r,|jdD]}|j |ddzn$|j |jdddzd|jvrt |jdt rk|jdD]X}|j |jdd|jdd|jdd|jd dd Zn|j |jdjdd|jdjdd|jdjdd|jdjd dd d dl}|j}|j|j}|j||j|z } | d z} t||} d} |jtjd k(rt |j"} t%||j\} } t'|j}idt)|jdd|jd|j*dt|jd| d|j,d|j.d|d|d|jddzd|jdd|jdd|j0d|j2d t)| d!| d"| | |d#}|S)$NDISKSIZEz MBNICIPrQMACNETWORKSECURITY_GROUPS)ipmacnamesecurity_groupsriACTIVErj TEMPLATE_IDrvm_namer lcm_state owner_nameowner_idnetworks disk_sizememoryMEMORYvcpuVCPUcpuCPU group_namegroup_iduptime_h attributesmode)labelsrJ)rrTriTEMPLATE isinstancelistrgettime localtimeSTIMEmktimeparse_vm_permissionsSTATE VM_STATESindex LCM_STATES LCM_STATE!get_vm_labels_and_attributes_dictrMrrVUNAMEUIDGNAMEGID)rWr networks_infordisknicr current_time vm_start_time vm_uptimepermissions_str vm_lcm_state vm_labels vm_attributesrJrTs rE get_vm_infor&sh  BMI  bkk&)4 0 F+ 7  f!56 7   R[[085@ A   bkk%($ /{{5) $$''$+775"-GGIr2'*ww/@"'E &   kk%(,,T26{{5)--eR8 E*..y"=KK&**+>#LNN288,M L)DKK ,FFI 'I*626OL xx9??8,,!",,/ @OI}!"++.J s2;;}56   277  288$   \   bhh   BFF  M  Y  "++h'%/   F#  r{{5!  bhh  BFF  C N  m! " # $ ' D, KrGcT|jj|jj}t |j dzt |j dzzt |jz}t |jdzt |jdzzt |jz}t |jdzt |jdzzt |jz}t|t|zt|z}|S)N)rrTri PERMISSIONSrOWNER_UOWNER_MOWNER_AGROUP_UGROUP_MGROUP_AOTHER_UOTHER_MOTHER_Ar)rWrvm_PERMISSIONS owner_octal group_octal other_octal permissionss rErrqsYY^^BEE*66Nn,,-1C8N8N4ORS4SSVYZhZpZpVqqKn,,-1C8N8N4ORS4SSVYZhZpZpVqqKn,,-1C8N8N4ORS4SSVYZhZpZpVqqKk"S%55K8HHK rGcd}|D]}|jj|j}t||}|xs||k7}|jrJ||k7sPt t |ddd}|Dcgc] }t |} } |jj|j| d| d| d| d| d| d | d | d | d |Scc}w#tj$r|jd YwxYw)NF)baserrrRrzUPermissions changing is unsuccessful, but instances are present if you deployed them.r:) rrTrir check_modebinrchmodpyoneOneAuthorizationExceptionr>) r@rWrrchangedrold_permissionsrd mode_bitss rEset_vm_permissionsr}s:G ~ YY^^BEE ".vr:;_ ;  _ %C!#k":;AB?O)89AQ9I9 ~ EE9Q<1y|Yq\S\]^S_ajklamoxyzo{~GHI~JLUVWLXY ~ N:22 ~  %| } ~s2CA C%DDcd}|D]}|jj|j}| |j}| |j}|xs ||jk7xs||jk7}|j ru||jk7s||jk7s |jj |j|||S#tj$r|jdYwxYw)NFzSOwnership changing is unsuccessful, but instances are present if you deployed them.r:) rrTrirrrchownrrr>)r@rWrrrrrs rEset_vm_ownershiprsG | YY^^BEE "  vvH  vvHEX/E8rvv3E  h"&&&8H enumerater) r@size_strSYMBOLSsinitnumsymbolprefixi size_in_bytes size_in_MBs rEget_size_in_MBrs +GA D C !A AaFcM qt  abE !A AaFcM *C WWYF W8D&#;NNO1XF'!"+&&1!a%2%q &fVn,-M+.J rGc |r|jdd} |jj|j} t t | jdg} |rFt t |} | | k7r-|j dt| zdzt| zt| xsi|xsi}t|dj|t |d t tt | jdgt |xsdg| zDcgc]5\}}|.|s|n)t|d ttt||i7c}}d d }t|| xsi} |jj| |t||}t#|}t%||Scc}}w#tj $r%}|j t|Yd}~Qd}~wwxYw) NrVrQrzThis template has z disks but you defined r:,T)extractr)LABELSrr)rr]rTrlenrr>rrjoinziprr instantiater r OneExceptionrr)r@rWrjattributes_dict labels_listrnetwork_attrs_listvm_start_on_hold vm_persistentrrr] disk_count size_countvm_extra_templatersizerers rE create_vmr&s!%%fb1##K099HWX\\&"567J+,  #   !5J!GJc!cfijtfu!u  v"8>r?3HbI"#4((;')48" VR01 8dVj%89  dD*TCvt <=>4#     7 ##4o6KL%++K,3,<,23D,E,9 ; fe $B vr ""/  &   %SV$$%s:F55(F;;G3G..G3cd}t|j|}||vr$|dz}t|j|}||vr$|SNrrR)rzfill)vm_filled_indexes_list num_sign_cntcountercnt_strs rEgenerate_next_indexr.sSG'l  .G + +A+g,$$\2 + + NrGc|jj|j}i}g}|jD]'\}}|dk7r|||<|||j d})||fS)Nrr)rrT USER_TEMPLATEr<split)rWrvm_USER_TEMPLATE attrs_dictrkeyrLs rErr svyy~~e,::JK&,,./ U (?#JsO5#4#kk#. /  ""rGc4|jjddddj}g}d}|r|jdd}|dk7r|dt ||j dz }|j d}|D]|}|jj|s|r8|jt |djr|j|Y|r\|j|k(sl|j|~|}ddl } | j|}|D]}g} t||j\} } |r[t |dkDrM|jD]:\} }| | vr|s | | |k7s| j|n| j|ntt!|j#t!| }g} |r,t |dkDr|D]}|| vs| j|ntt!|j#t!| }|S)NrOrPrQrV#r)vmpoolrTVMpoprcountendswithrV startswithrrcopyrrir<rset difference)rWrrrYvm_listr base_name with_hashrr= remove_listvm_labels_listvm_attributes_dictr4vallabels rEget_all_vms_by_attributesrHs ==  b"b" - 0 0DG D""62. rz5#d)djjo56 MM#&  'Bww!!),Y!9!A!A!CNN2&"rww$NN2& 'iioGB -NvWYW\W\-]** s?3a7+113 S,,1#6#=#**2.&&r* s7|..s;/?@A 3{+a/$ .&&r* s7|..s;/?@A+B. NrGc fg} d}|r|jdd}|jrdggfSd}|jd|dk7r<dkDr7t|d|id}|dt |z }t fd|D}|dkDrx|}|"t |}|j|||z }||d<t|||||||| | | }|jd}t||}| j||dz}|dkDrx| r|r-| D]}t|||| n|r| D]}t|||| d| gfS) NrQrVTr6rc3lK|]+}|jtdj-ywra)rVrr)).0rrAr+s rE z&create_count_of_vms..fs,%gY[rwws9~'?'E'El'S%gs14rrR) rrr:rHrrr.rr&r wait_for_holdwait_for_running)r@rWrjr:rrrrwait wait_timeoutrr r new_vms_listrr*r@ new_vm_name next_index new_vm_dict new_vm_idnew_vmrrAr+s @@rEcreate_count_of_vmsrWQsLG!%%fb1 R|"==%L"})+FVW4EtL8S\L89 !%%g_f%g!g !) ! -,-C\RJ " ) )* 5 : %K"- +_k9Vh 0-R  OOG, fi0F#   !)" " @ffb,? @ " C \B C r !!rGct|||}|t|z }|dk7}g}g}|}|jr|||fS|dkDr!t|||||||| | | | || \}}}||z }n|dkrzg}|dkr;|j d}|j |t |||| |dz }|dkr;| r|D]}t|||| |}t|}|Dcgc] }||vs| }}|||fScc}wr() rHrrrWr9r terminate_vm wait_for_doner>)r@rWrj exact_countrcount_attributes_dictrcount_labels_listrrhardrOrPrr rr@ vm_count_diffrrQinstances_listtagged_instances_listtagged_instances old_vms_listold_vmr old_vms_sets rEcreate_exact_count_of_vmsrfs_(0EGXYG#g,.Mq GLN# (===q4GPVXceruDHSU^`rtx{GHXZgix5z1!1 /   a[[^F    '  6 Q M a " @ffb,? @&,' .5 O;9N O O N$9 99!Ps C"C") INITPENDINGHOLDrSTOPPED SUSPENDEDDONErQPOWEROFF UNDEPLOYEDCLONINGCLONING_FAILURE)LCM_INITPROLOGrRUNNINGMIGRATE SAVE_STOP SAVE_SUSPEND SAVE_MIGRATEPROLOG_MIGRATE PROLOG_RESUME EPILOG_STOPEPILOGSHUTDOWNSTATE13STATE14CLEANUP_RESUBMITUNKNOWNHOTPLUGSHUTDOWN_POWEROFF BOOT_UNKNOWN BOOT_POWEROFFBOOT_SUSPENDED BOOT_STOPPEDCLEANUP_DELETEHOTPLUG_SNAPSHOT HOTPLUG_NICHOTPLUG_SAVEASHOTPLUG_SAVEAS_POWEROFFHOTPULG_SAVEAS_SUSPENDEDSHUTDOWN_UNDEPLOYc ddl}|j}|j|z |kr |jj|j}|j}|j }|||r|S|t jdt jdt jdt jdt jdt jdfvr|jdt |z |jd |j|z |kr |jd y) Nrrgrhrirrormz"Action is unsuccessful. VM state: r:rRzWait timeout has expired!) rrrTrirrrrr>sleep) r@rWrrPstate_predicater start_timerrs rEwait_for_statersJ 99; #| 3 YY^^BEE "LL 5) ,I 9??62IOOI4NPYP_P_`fPg$??84iooi6PR[RaRablRmoo   !E RWHX!X  Y 1  99; #| 3 45rGc"t||||dS)Ncf|tjdfvxr|tjdfvS)Nrrs)rrrrrs rErcz"wait_for_running..s5&+ 0I/J&J&yy]g]m]mnw]x\yOyrGrr@rWrrPs rErNrNs &&"l={ ||rGc"t||||dS)Nc2|tjdfvS)Nrlrrrs rErczwait_for_done..V[`i`o`opv`w_xVxrGrrs rErZrZ &&"l.rrGrrs rErMrMrrGc"t||||dS)Nc2|tjdfvS)Nrmrrs rErcz#wait_for_poweroff..sV[`i`o`opz`{_|V|rGrrs rEwait_for_poweroffrs &&"l<} ~~rGcd}|s|Sd}|jsP|r(|jjd|j|S|jjd|j|S)NFTzterminate-hard terminate)rractionri)r@rWrr^rs rErYrYs_G G     II  -ruu 5 N II  ["%% 0 NrGc<d}|D]}t||||xs|}|Sr)rYr@rWrr^rrs rE terminate_vmsrs4GDvvr48CGD NrGc|jj|j}d}|j}|j}|t j dt j dfvr|tj dfvrd}|r\|jsP|s(|jjd|j|S|jjd|j|S)NFr|rrmTpoweroffz poweroff-hard) rrTrirrrrrrr)r@rWrr^rrrs rE poweroff_vmrs  BG I HHE))*5z7G7GH[7\]]bgpyppAKqLpMcMv(( II  Z / N II  _bee 4 NrGc<d}|D]}t||||xs|}|Sr)rrs rE poweroff_vmsr s4GCffb$7B7C NrGcv|js|D]}|jj|j}|j}|j }|t jdfvsY|tjdfvsrt|||||D]}t|||||D]}t|||y)NrrmT) rrrTrirrrrrrr resume_vm)r@rWrrPr^rrrs rE reboot_vmsrs    6B&B IHHE!1!12E!F GGEZcZiZijtZuYvLvFFB5  6 @B ffb, ? @ *B ffb ) * rGc|jj|j}d}|j}|tj dfvrt |||}|S|j}|tj dk(r|jd|tj dfvrd}|r2|js&|jjd|j|S) NFrirzCannot perform action 'resume' because this action is not available for LCM_STATE: 'SHUTDOWN_POWEROFF'. Wait for the VM to shutdown properlyr:rsTresume) rrTrirrr release_vmrrr>rr)r@rWrrrrs rErr*s  BG HHE ())VVR0 IJ$$%899d e)))455v(( 255) NrGc:d}|D]}t|||xs|}|Sr)r)r@rWrrrs rE resume_vmsr@s0G;FFB/:7; NrGc.|jj|j}d}|j}|tj dk7r|j dnd}|r2|js&|jjd|j|S)NFrizgCannot perform action 'release' because this action is not available because VM is not in state 'HOLD'.r:Trelease) rrTrirrrr>rr)r@rWrrrs rErrIs|  BG HHE ''> ?v(( BEE* NrGc|jdrNddl}|jd|jd(|jd|jdzdzyyy)NrVrz ^[^#]+#*$zIllegal 'NAME' attribute: 'zZ' .Signs '#' are allowed only at the end of the name and the name cannot contain only '#'.r:)rrematchr>)r@rrs rEcheck_name_attributerZsc~~f 88L*.."8 9 A   !>PVAW!Wy"z  { BrG)rrr1rrrrr3r4r7 CREATED_BYCPU_COST DISK_COST MEMORY_COSTrVMIDAUTOMATIC_DS_REQUIREMENTS DEPLOY_FOLDERrc|jD]#}|tvs |jd|zdz%t||y)NzRestricted attribute `z$` cannot be used when filtering VMs.r:)keysTEMPLATE_RESTRICTED_ATTRIBUTESr>r)r@rr4s rEcheck_attributesrgsL j 0 0   !9C!?Bh!h  ij,rGc|jds|jd|jd}|jdd}|jsm|jtj dk7r|jd |j j|j||dd t||||yy#tj$r%}|jt|Yd}~Cd}~wwxYw) Nrz/Key 'name' is required for 'disk_saveas' optionr:disk_idrrmzG'disksaveas' option can be used only when the VM is in 'POWEROFF' stater1rP) rr>rrrrr disksaveasrirrrr)r@rWr disk_saveasrP image_namerr%s rE disk_save_asros ??6 "NO(Jooi+G    88yz2 2   !j  k ) II T2 F &&"l;  !! )   Q  ( ( )s)CC9C44C9c|jjd}|jjd}|jjd}|stjjd}|stjjd}|stjjd}|s|stjjd}|>tjj tjjdd d } t |d 5}|jj}dddjd d }|jd d}|s|jdd dlm}|dd}||||S#1swY_xYw#ttf$r|jd|zY`t$r|jd|zYwxYw)Napi_url api_username api_passwordONE_URL ONE_USERNAME ONE_PASSWORDONE_AUTHHOMEz.oneone_authr:rrRz,Could not find or read ONE_AUTH file at '%s'r:z,Error occurs when read ONE_AUTH file at '%s'z-Opennebula API url (api_url) is not specified) namedtupleauth)urlusernamepassword)paramsrosenvironpathropenreadrstripr1OSErrorIOErrorr> Exception collectionsr) r@rrrauthfilefp authstringr auth_paramss rEget_connection_infors --  I &C}}  0H}}  0H jjnnY' ::>>.1 ::>>.1 zz~~j1H77<< v(> S b(C(4B!#!1!1!3J4%++C03%++C03 LM&V%DEK 3H EE44W% b  &TW_&_ a b  &TW_&_ a bs0 F.%F"0F."F+'F..$G4G43G4c0idddddddddddddd dd gd d d ddddddd dddddddgdddddddddd dddd dddddddd dddddddddddd dd!dd ddd dd"ddddd dgd d#d$d%d ddd did#ddd#dgd dd$dd dd"d&d#idddd&d#id' }t|gd(gd)gd*gd+d d,gd d-gd d.gd/d-gd/d.gd,d0gd0dgd dgd d!gd dgd d1gd d2gd3d1ggd4}ts|jd56t|}|j}|j d }|j d}|j d}|j d}|j d}|j d} |j d} |j d} |j d} |j d} |j d}|j d}|j d}|j d!}|j d1}|j d7}|j d8}|j d2}|j d0}|j d,}|j d-}|j d9}|j d.}|j d:}|j d/}|j d3}|j d;}|j r |js|jd<n;tj|j|j d=z|jz>0|r=|jD cic]\}} |j| }}} t|||re|jD cic]\}} |j| }}} |s&d?dl}!|jd@|!j|}t|||r t!|||r|s|jdA|}d}"||rHt#|0||}"|"8||jdBt%|z6n|r|jdC|z6d}#|s|rZt'|0||}#|#9|r|jdDt%|z6n)|r'|jdE|z6ndFt%|#z|dG<|r|"|jdH6||s|s|jdI6|s|r||jdJ6|"|dk7r|jdK6|r!t%t)t+|||dL<|rt%||dM<|rt%||dN<||dk7r|jdO6||d?kr|jdP6|d?kr|jdQ6| (d?dl}$|$j/dR| |jdS6|"t1|0|"||||||||| | |||\}%}&}'|'}(nU|"$|dk(rt3|0|"|||||| | ||| \}%}&}'|&}(n/|s|s|s|jdT6|s|s|s|s|r|jdU6|r|dVvr|jdW6g}(d})d}%|rt5|0||}(nd})t70||}(t9|(d?k(r|dXk7r|dk7r|jdY6t9|(d?k(r|dk(r|)s|jdZ6|)r|dXk(r|jd[6|dXk(rt;|0|(|}%n;|d\k(rt=|0|(| |}%n&|d]k(rt?|0|(|}%n|d^k(r tA|0|(}%|(}&g}'| tC|0|(| xs|%}%| | tE|0|(| | xs|%}%|"|tG|0|(|xs|%}%| r@|jHs4|dk7r/tJtLtNtLd_}*|(D]}+|+|*||0|+| |4t9|(d?k(r|jd`6tQ|0|(d?|| d}%tS0fda|&D},tSdb|&D}-tS0fdc|'D}.|%|,|-|.dd}/|jTdei|/ycc} }wcc} }w)fNrFr)requiredtyperrT)rrno_log instance_idsrrr)raliasesrelementsr\rjrbool)defaultrrpresent)rrrebooted poweredoffrunning)rchoicesrrrrrOrPi,r^rrrr)rrrdict)rrrrRr) rrtr}rr:r[rcount_attributesr count_labelsr persistentrJ)rjr\r)rjr\r)rrr:)rrr:r[rrrr:rrr) argument_specmutually_exclusivesupports_check_modez#This module requires pyone to work!r:r}rtrrrJzCredentials missingr)sessionrzWhen you pass `count_attributes` without `attributes` option when deploying, `attributes` option will have same values implicitly.zvWhen you pass `count_labels` without `labels` option when deploying, `labels` option will have same values implicitly.z'There is no template with template_id: z There is no template with name: z)There is no datastore with datastore_id: z!There is no datastore with name: zID=SCHED_DS_REQUIREMENTSz7Option `exact_count` needs template_id or template_namezZEither `count_attributes` or `count_labels` has to be specified with option `exact_count`.zbOption `exact_count` has to be specified when either `count_attributes` or `count_labels` is used.z.Only state 'present' is valid for the templaterrrz>The `exact_count` option is valid only for the `present` statez#`exact_count` cannot be less than 0z `count` has to be greater than 0z ^[0-7]{3}$zNOption `mode` has to have exactly 3 digits and be in the octet format e.g. 600zDAt least one of `instance_ids`,`attributes`,`labels` must be passed!zgParameters as `memory`, `cpu`, `vcpu`, `disk_size` and `networks` you can only set when deploying a VM!)rrrrzlThe 'hard' option can be used only for one of these states: 'rebooted', 'poweredoff', 'absent' and 'present'rzRThere are no instances with specified `instance_ids`, `attributes` and/or `labels`z5There are no instances with specified `instance_ids`.z9Option `instance_ids` is required when state is `absent`.rrr)rrrrz(There is no VM whose disk will be saved.c3<K|]}|t|ywrarrKr one_clients rErLzmain..s\RR^[R0\c3:K|]}||jywrarh)rKrs rErLzmain..sJ22>Jsc3<K|]}|t|ywrarrs rErLzmain..sjB[][iK B7jr)r instances instances_idsrb)+r HAS_PYONEr>rrrrrwarnr OneServerrr<upperrr=rFrorrrrrrrfrWrrHrrrrrrrrrrZrNrrr exit_json)1fieldsr@rrrrequested_template_namerequested_template_idput_vm_on_holdrrrrrOrPr^rrrrrequested_datastore_idrequested_datastore_namerr:r[rrrrrrrJr4rLr=rjr}rrr`rartaggedwait_forrr r rbresultrs1 @rEmainrst #u5#UE:# UETJ# Uw\ab # eU; # E59 # v>#  Q # UE2# 6# 6# D&1!#" C7##$ E62%#& ue4'#( E73)#* UE2+#,#(UK',e<%*E: "FG.$)59"$f5).? &eD%*FN'"'8v&E#FJONLH . > . = .9 -|< -x8 -w7 '0 .68P .9NK;X . ; ,k:/"04%5F( BC v &D ]]F::n-L$jj9"JJ}5ZZ 23N JJw E**V$Kzz*%Hzz*%H ::f D::n-L ::f D ZZ !F **U C ::f D ;'I#ZZ7%zz*:;zz*%H JJw E**]+KL)Jzz"45 ZZ !F::n-L**]+KL)JL)J MMdmm )*__TXXt}}s7JT]]7Z[ ;E;K;K;MNZS%ciik5(N N,AQAWAWAYZ:3CIIK.ZZ  KK] ^#34J!12,F M NK(,C%fj:OQhi  $0  %NQTUjQk%k l(  %GJa%a bL!9' \\IJJJMjBWjj y=n~ FFvO[s aa$__main__)F)D __future__rrrr __metaclass__ DOCUMENTATIONEXAMPLESRETURNrr ImportErrorransible.module_utils.basicr0ansible.module_utils.common.dict_transformationsrEansible_collections.community.general.plugins.module_utils.opennebularr r=rFrMr^rerkrorvrzr~rrrrrrrrrrr&r.rrHrWrfrrrrNrZrMrrYrrrrrrrrrrrrr__name__r rGrEr(sCB H Vb HS jI  4Ga k:&Fe_I ; 3\  n  *[W&_[ HV (* 6(#V # 1h1"h*:Z N l 6(| {{"&*,"{"q -<"#FL@F zFk IsC**C43C4