VhdZddlmZmZmZeZdZdZdZ ddl m Z ddl m Z e jdZd Zd ZGd d eZd ZdZedk(reyy)z,Ansible module for managing volumes on Unity)absolute_importdivisionprint_functiona module: volume version_added: '1.1.0' short_description: Manage volume on Unity storage system description: - Managing volume on Unity storage system includes- Create new volume, Modify volume attributes, Map Volume to host, Unmap volume to host, Display volume details, Delete volume. extends_documentation_fragment: - dellemc.unity.unity author: - Arindam Datta (@arindam-emc) - Pavan Mudunuri(@Pavan-Mudunuri) options: vol_name: description: - The name of the volume. Mandatory only for create operation. type: str vol_id: description: - The id of the volume. - It can be used only for get, modify, map/unmap host, or delete operation. type: str pool_name: description: - This is the name of the pool where the volume will be created. - Either the I(pool_name) or I(pool_id) must be provided to create a new volume. type: str pool_id: description: - This is the id of the pool where the volume will be created. - Either the I(pool_name) or I(pool_id) must be provided to create a new volume. type: str size: description: - The size of the volume. type: int cap_unit: description: - The unit of the volume size. It defaults to C(GB), if not specified. choices: ['GB' , 'TB'] type: str description: description: - Description about the volume. - Description can be removed by passing empty string (""). type: str snap_schedule: description: - Snapshot schedule assigned to the volume. - Add/Remove/Modify the snapshot schedule for the volume. type: str compression: description: - Boolean variable, Specifies whether or not to enable compression. Compression is supported only for thin volumes. type: bool advanced_dedup: description: - Boolean variable, Indicates whether or not to enable advanced deduplication. - Compression should be enabled to enable advanced deduplication. - It can only be enabled on the all flash high end platforms. - Deduplicated data will remain as is even after advanced deduplication is disabled. type: bool is_thin: description: - Boolean variable, Specifies whether or not it is a thin volume. - The value is set as C(true) by default if not specified. type: bool sp: description: - Storage Processor for this volume. choices: ['SPA' , 'SPB'] type: str io_limit_policy: description: - IO limit policy associated with this volume. Once it is set, it cannot be removed through ansible module but it can be changed. type: str host_name: description: - Name of the host to be mapped/unmapped with this volume. - Either I(host_name) or I(host_id) can be specified in one task along with I(mapping_state). type: str host_id: description: - ID of the host to be mapped/unmapped with this volume. - Either I(host_name) or I(host_id) can be specified in one task along with I(mapping_state). type: str hlu: description: - Host Lun Unit to be mapped/unmapped with this volume. - It is an optional parameter, hlu can be specified along with I(host_name) or I(host_id) and I(mapping_state). - If I(hlu) is not specified, unity will choose it automatically. The maximum value supported is C(255). type: int mapping_state: description: - State of host access for volume. choices: ['mapped' , 'unmapped'] type: str new_vol_name: description: - New name of the volume for rename operation. type: str tiering_policy: description: - Tiering policy choices for how the storage resource data will be distributed among the tiers available in the pool. choices: ['AUTOTIER_HIGH', 'AUTOTIER', 'HIGHEST', 'LOWEST'] type: str state: description: - State variable to determine whether volume will exist or not. choices: ['absent', 'present'] required: true type: str hosts: description: - Name of hosts for mapping to a volume. type: list elements: dict suboptions: host_name: description: - Name of the host. type: str host_id: description: - ID of the host. type: str hlu: description: - Host Lun Unit to be mapped/unmapped with this volume. - It is an optional parameter, I(hlu) can be specified along with I(host_name) or I(host_id) and I(mapping_state). - If I(hlu) is not specified, unity will choose it automatically. The maximum value supported is C(255). type: str notes: - The I(check_mode) is not supported. at - name: Create Volume dellemc.unity.volume: unispherehost: "{{unispherehost}}" username: "{{username}}" password: "{{password}}" validate_certs: "{{validate_certs}}" vol_name: "{{vol_name}}" description: "{{description}}" pool_name: "{{pool}}" size: 2 cap_unit: "{{cap_GB}}" is_thin: true compression: true advanced_dedup: true state: "{{state_present}}" - name: Expand Volume by volume id dellemc.unity.volume: unispherehost: "{{unispherehost}}" username: "{{username}}" password: "{{password}}" validate_certs: "{{validate_certs}}" vol_id: "{{vol_id}}" size: 5 cap_unit: "{{cap_GB}}" state: "{{state_present}}" - name: Modify Volume, map host by host_name dellemc.unity.volume: unispherehost: "{{unispherehost}}" username: "{{username}}" password: "{{password}}" validate_certs: "{{validate_certs}}" vol_name: "{{vol_name}}" host_name: "{{host_name}}" hlu: 5 mapping_state: "{{state_mapped}}" state: "{{state_present}}" - name: Modify Volume, unmap host mapping by host_name dellemc.unity.volume: unispherehost: "{{unispherehost}}" username: "{{username}}" password: "{{password}}" validate_certs: "{{validate_certs}}" vol_name: "{{vol_name}}" host_name: "{{host_name}}" mapping_state: "{{state_unmapped}}" state: "{{state_present}}" - name: Map multiple hosts to a Volume dellemc.unity.volume: unispherehost: "{{unispherehost}}" username: "{{username}}" password: "{{password}}" validate_certs: "{{validate_certs}}" vol_id: "{{vol_id}}" hosts: - host_name: "10.226.198.248" hlu: 1 - host_id: "Host_929" hlu: 2 mapping_state: "mapped" state: "present" - name: Modify Volume attributes dellemc.unity.volume: unispherehost: "{{unispherehost}}" username: "{{username}}" password: "{{password}}" validate_certs: "{{validate_certs}}" vol_name: "{{vol_name}}" new_vol_name: "{{new_vol_name}}" tiering_policy: "AUTOTIER" compression: true is_thin: true advanced_dedup: true state: "{{state_present}}" - name: Delete Volume by vol name dellemc.unity.volume: unispherehost: "{{unispherehost}}" username: "{{username}}" password: "{{password}}" validate_certs: "{{validate_certs}}" vol_name: "{{vol_name}}" state: "{{state_absent}}" - name: Delete Volume by vol id dellemc.unity.volume: unispherehost: "{{unispherehost}}" username: "{{username}}" password: "{{password}}" validate_certs: "{{validate_certs}}" vol_id: "{{vol_id}}" state: "{{state_absent}}" a changed: description: Whether or not the resource has changed. returned: always type: bool sample: true volume_details: description: Details of the volume. returned: When volume exists type: dict contains: id: description: The system generated ID given to the volume. type: str name: description: Name of the volume. type: str description: description: Description about the volume. type: str is_data_reduction_enabled: description: Whether or not compression enabled on this volume. type: bool size_total_with_unit: description: Size of the volume with actual unit. type: str snap_schedule: description: Snapshot schedule applied to this volume. type: dict tiering_policy: description: Tiering policy applied to this volume. type: str current_sp: description: Current storage processor for this volume. type: str pool: description: The pool in which this volume is allocated. type: dict host_access: description: Host mapped to this volume. type: list io_limit_policy: description: IO limit policy associated with this volume. type: dict wwn: description: The world wide name of this volume. type: str is_thin_enabled: description: Indicates whether thin provisioning is enabled for this volume. type: bool sample: { "current_node": "NodeEnum.SPB", "data_reduction_percent": 0, "data_reduction_ratio": 1.0, "data_reduction_size_saved": 0, "default_node": "NodeEnum.SPB", "description": null, "effective_io_limit_max_iops": null, "effective_io_limit_max_kbps": null, "existed": true, "family_base_lun": { "UnityLun": { "hash": 8774954523796, "id": "sv_27" } }, "family_clone_count": 0, "hash": 8774954522426, "health": { "UnityHealth": { "hash": 8774954528278 } }, "host_access": [ { "accessMask": "PRODUCTION", "hlu": 0, "id": "Host_75", "name": "10.226.198.250" } ], "id": "sv_27", "io_limit_policy": null, "is_advanced_dedup_enabled": false, "is_compression_enabled": null, "is_data_reduction_enabled": false, "is_replication_destination": false, "is_snap_schedule_paused": false, "is_thin_clone": false, "is_thin_enabled": false, "metadata_size": 4294967296, "metadata_size_allocated": 4026531840, "name": "VSI-UNITY-test-task", "per_tier_size_used": [ 111400714240, 0, 0 ], "pool": { "id": "pool_3", "name": "Extreme_Perf_tier" }, "size_allocated": 107374182400, "size_total": 107374182400, "size_total_with_unit": "100.0 GB", "size_used": null, "snap_count": 0, "snap_schedule": null, "snap_wwn": "60:06:01:60:5C:F0:50:00:94:3E:91:4D:51:5A:4F:97", "snaps_size": 0, "snaps_size_allocated": 0, "storage_resource": { "UnityStorageResource": { "hash": 8774954518887 } }, "tiering_policy": "TieringPolicyEnum.AUTOTIER_HIGH", "type": "LUNTypeEnum.VMWARE_ISCSI", "wwn": "60:06:01:60:5C:F0:50:00:00:B5:95:61:2E:34:DB:B2" } ) AnsibleModule)utilsvolumez Ansible/1.7.1c:| xstt|dkS)z9 validates the input string for None or empty values r)lenstr)params h/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/dellemc/unity/plugins/modules/volume.pyis_none_or_empty_stringrs9 ,CJ1,,ceZdZdZdZdZdZdZddZddZ dZ ddZ ddZ d Z d Zdd Zd Zd ZdZdZdZdZdZdZdZdZdZdZy)VolumezClass with volume operationsNc|tj|_|jjt ddgddgddgg}ddgg}t |jd|||_tj|j tj|j jt|_ y ) z-Define all parameters required by this modulevol_namevol_id pool_namepool_id host_namehost_idF) argument_specsupports_check_modemutually_exclusiverequired_one_ofN) r$get_unity_management_host_parameters module_paramsupdateget_volume_parametersrmoduleensure_required_libsget_unity_unisphere_connectionparamsapplication_type unity_conn)selfrrs r __init__zVolume.__init__s"GGI !!"7"9:)84*I6*I68'12$,, %1+ - ""4;;/>> KK   02rc|r|n|}d} |jj||}|r$|jrtj d||S|rtj d||Stj d|y#t j $r}|jdk(rJdj|j}|j||}|jj|n<|j|t|}|jj|Yd}~yYd}~yd}~wt j$r:}|j|t|}tj|Yd}~yd}~wt$rV}|j|t|}tj||jj|Yd}~yd}~wwxYw) zGet the details of a volume. :param vol_name: The name of the volume :param vol_id: The id of the volume :return: instance of the respective volume if exist. z+Failed to get the volume {0} with error {1}name_idz&Successfully got the volume object %s zFailed to get the volume %sNiz$Incorrect username or password , {0}msg)r&get_lunexistedLOGinfor HttpError http_statusformatmessager! fail_jsonr UnityResourceNotFoundErrorerror Exception) r'rr id_or_nameerrormsgobj_volecred_errr.s r get_volumezVolume.get_volumesv &V8 @ +oo--8-HG'//A7KA7K6 C /}}#AHHIIooj(; %%#%.ooj#a&9 %%#%../ // //*c!f5C IIcN +//*c!f5C IIcN KK ! !c ! * * +s>AA> A>'A>>GBD++G0E66 GA GGc|r|n|}d} |jj||}|r$|jrtj d||S|rtj d||Sdj |}tj ||jj|y#t$rV}|j |t|}tj ||jj|Yd}~yd}~wwxYw)zGet the instance of a host. :param host_name: The name of the host :param host_id: The id of the volume :return: instance of the respective host if exist. z)Failed to get the host {0} with error {1}r*z$Successfully got the host object %s zFailed to get the host {0}r-N) r&get_hostr0r1r2r5r9r!r7r:r )r'rrr;r<obj_hostr.r>s r rBzVolume.get_hosts!(WY > +//YG/LH8++?J?J299*E # %%#%. +//*c!f5C IIcN KK ! !c ! * *  +&AB* B*'AB** D 3A DD c8d} tjd|tjj |j j |}|r&t|dkDrtjd||Sdj|}tj||jj|y#t$rV}|j|t|}tj||jj|Yd}~yd}~wwxYw) zGet the instance of a snapshot schedule. :param name: The name of the snapshot schedule :return: instance of the respective snapshot schedule if exist. z6Failed to get the snapshot schedule {0} with error {1}z0Attempting to get Snapshot Schedule with name %sr+rz%Successfully got Snapshot Schedule %sz-Failed to get snapshot schedule with name {0}r-N)r1debugrUnitySnapScheduleListgetr&_clir r2r5r9r!r7r:r )r'r+r<obj_ssr.r>s r get_snap_schedulezVolume.get_snap_schedules L + IIH 0044T__5I5I:>5@F3v;?@&I &&,fTl # %%#%. +//$A/C IIcN KK ! !c ! * * +s A2B:7AB:: DA DDcd}|r|n|} |jj||}|r$|jrtj d||S|rtj d||Sdj |}tj ||jj|y#t$rV}|j |t|}tj ||jj|Yd}~yd}~wwxYw)zGet the instance of a io limit policy. :param name: The io limit policy name :param id: The io limit policy id :return: instance of the respective io_limit_policy if exist. z4Failed to get the io limit policy {0} with error {1})r,r+z.Successfully got the IO limit policy object %sz/Successfully got the IO limit policy object %s z*Failed to get the io limit policy with {0}r-N) r&get_io_limit_policyr0r1r2r5r9r!r7r:r )r'r+idr<r; obj_iopolr.r>s r rNzVolume.get_io_limit_policysJ!Tr  +;;;NIi''I"$  J"$  BII  # %%#%. +//$A/C IIcN KK ! !c ! * * +rDc|r|n|}d} |jj||}|r$|jrtj d||S|rtj d||Sdj |}tj ||jj|y#t$rV}|j |t|}tj ||jj|Yd}~yd}~wwxYw)zGet the instance of a pool. :param pool_name: The name of the pool :param pool_id: The id of the pool :return: Dict containing pool details if exists z)Failed to get the pool {0} with error {1}r*z#Successfully got the pool object %szSuccessfully got pool %szFailed to get the pool with {0}r-N) r&get_poolr0r1r2r5r9r!r7r:r )r'rrr;r<obj_poolr.r>s r rRzVolume.get_pool;s!(WY > +//YG/LH8++>!#3X>"F:. # %%#%. +//*c!f5C IIcN KK ! !c ! * * +rDc|tjjvrtj|Sdj|}tj ||j j|y)zGet the storage processor enum. :param sp: The storage processor string :return: storage processor enum z(Invalid choice {0} for storage processorr-N)rNodeEnum __members__r5r1r9r!r7)r'spr<s r get_node_enumzVolume.get_node_enumZsY ++ +>>"% %AHHH IIh  KK ! !h ! /rc|tjjvrtj|Sdj|}tj ||j j|y)zGet the tiering_policy enum. :param tiering_policy: The tiering_policy string :return: tiering_policy enum z%Invalid choice {0} for tiering policyr-N)rTieringPolicyEnumrVr5r1r9r!r7)r'tiering_policyr<s r get_tiering_policy_enumzVolume.get_tiering_policy_enumhs] U44@@ @**>: :>EE H IIh  KK ! !h ! /rc |jjd} |jjd}|jjd}|jjd}|jjd}d} |jjd} | r|j| nd} |jjdr|j|j nd} |j rd |j i} |jjd } | r|j | nd} |j||| |||| | | || } tjd | | S#t$rV}dj|t|}tj||jj|Yd}~yd}~wwxYw)zCreate a volume. :param obj_pool: pool object instance :param size: size of the volume in GB :param host_access: host to be associated with this volume :return: Volume object on successful creation r description compressionadvanced_dedupis_thinNrWio_limit_policyrOr+r[) lun_namesize_gbrW host_accessrar^r[ snap_schedulerbis_compressionis_advanced_dedup_enabled Successfully created volume , %sz1Create volume operation {0} failed with error {1}r-)r!r$rXrNparam_io_limit_pol_idparam_snap_schedule_namer\ create_lunr1r2r:r5r r9r7)r'rSsizerfrr^r_r`rargrWrbr[r=r>r<s r create_volumezVolume.create_volumevs;;%%j1* 0++,,];K++,,];K![[//0@ANkk((3G M##D)B+-##B'4B;;%%&78#66--7/>B ,,!')F)F G ![[//0@AN!"99.I'+ ))826-/6A296A9G8E:I9DDR* TG HH7 AN 0))/#a&)A  IIh  KK ! !h ! / /  0sEE"" G+A F<<Gc d}|jjd}g}g}g}|s|jr|dk(r|S|r|jD]}|j |j |j |j j}|jj} tjd| d| jvs|j | d|dk(rb|j|vrT|jD]"} |j | jd$tt!|t!|z syd }|dk(r|jry|jD]"} |j | jd$tt!|t!|z rytt!|t!|z |_d }tjd t%||S#t&$rV} d j)|t%| } tj+| |jj-| Yd } ~ y d } ~ wwxYw)zCheck if host access modification is required :param host_access_list: host access dict list :return: Dict with attributes to modify, or None if no modification is required. F mapping_stateunmappedrzcheck if hlu present : %shlumappedrTz!host_access_modify_required : %s z4Failed to compare the host_access with error {0} {1}r-N)r!r$ new_host_listhostappendrOrBr host_luns_get_propertiesr1rGkeys param_host_idrIlistsetoverlapping_listr r:r5r9r7) r'host_access_list to_modifyrq host_id_listhlu_listnew_listrfrw host_dictitemr>r<s r host_access_modify_requiredz"Volume.host_access_modify_requireds , 0I KK..?MLHH#(:(:!Z/  !#3#8#8:K '' 7===@GGID $ > > @III99E  00  %(89:(&&l: $ 2 2= (;<=H L0A AB$ $I *%% $ 2 2= (;<=CMC ,==>$,0\1BS]1R,SD) $I II93y> J  0#V$4c!f=  IIh  KK ! !h ! / /  0s35G9BG9A:G9 A$G91AG99 IA IIc  i}|jjd}|r"|j|k7r|jd|i|jjd}|r"|j|k7r|jd|i|jjd}|ro|rmt t j||}||jkr|jjdn"||jkDr|jd|i|jjd}|"||jk7r|jd |i|jjd } | "| |jk7r|jd | i|jjd } | +| |jk7r|jjd |jjd} | r@|j| |jk7r"|jd|j| i|jjd} | r@|j| |j k7r"|jd|j| i|j"rL|j$r#|j"|j$j&k7r|jd|j"i|j(rL|j*r#|j(|j*jk7r|jd|j(i|j(dk(r5|j*r|jddint,j/dt,j1d|t3|dkDr|Sy#t4$r`} dj7|jt9| }t,j;||jj|Yd} ~ yd} ~ wwxYw)zCheck if volume modification is required :param obj_vol: volume instance :param cap_unit: capacity unit :return: Boolean value to indicate if modification is required new_vol_namer+r^rnz Volume size can be expanded onlyr-r_Nrhr`riraz Modifying is_thin is not allowedrWr[rbrgis_snap_schedule_pausedFz"No snapshot schedule is associatedzVolume to modify Dict : %srzGFailed to determine if volume {0},requires modification, with error {1})r!r$r+rr^intrget_size_bytes size_totalr7is_data_reduction_enabledriis_thin_enabledrX current_noder\r[rkrbrOrlrgr1warnrGr r:r5r r9)r'r=cap_unit to_updaterr^rn size_byter_r`rarWr[r>r<s r volume_modify_requiredzVolume.volume_modify_requiredsO 0I;;--n=L <  &,!78++,,];Kw22kA  -!=>;;%%f-D 4 4T8 DE w111KK))/>)?!3!33$$fi%89++,,];K&7#D#DD  "2K!@A![[//0@AN)"g&G&GG  "=~!NOkk((3G"w'2I2I'I %%*L%M##D)Bd((,0D0DD  $(:(:2(>!?@![[//0@AN$">">"#$'.'='=#>  "2"&">">&4#6"78 ))// 66&6699:$$*D,F,FGI,,-- 99&4499:$$o&*&C&C&EF,,2(($$&?%GHHHAB II3Y ?9~!   066r<s r multiple_host_mapzVolume.multiple_host_map9s! 0K <>k>:DK 0SZZ[hjqjvjvx{|}x~H IIh  KK ! !h ! / / 0sBB D!AC==Dct g}|D]0}|jtjjd|id2|j |}|S#t $ra}dj ||jt|}tj||jj|Yd}~yd}~wwxYw)zDetach multiple hosts from a volume :param host_list_detach: hosts to unmap the volume :param obj_vol: volume instance :return: response from API call rOrrwrz:Failed to detach hosts {0} from volume {1} with error {2} r-N) rxrrrrr:r5r+r r1r9r!r7)r'host_list_detachr=rfrrr>r<s r multiple_detachzVolume.multiple_detachTs 0K( ;""%2I2I2T2T-14L$:; ;>>k>:DK 0SZZ[kmtmymy{~@A|BCH IIh  KK ! !h ! / / 0sA A B7AB22B7c d|jvr|j|d|d<d|jvr|ddk7r d|di|d<gd}|D](}||jvs|j|di*tj d||j |d|d |d |d |d |d|d |d|d|d|d y#t $r`}dj|jt|}tj||jj|Yd}~yd}~wwxYw)zmodify volume attributes :param obj_vol: volume instance :param to_modify_dict: dict containing attributes to be modified. :return: None rbrcrgrr+) r+rnrfr^rWrbr[rgrrhriNz,Final update dict before modify api call: %srnrfr^rWr[rrhriz.Failed to modify the volume {0} with error {1}r-) r{rNrr1rGrr:r5r+r r9r!r7)r'r=to_modify_dict param_listrr>r<s r modify_volumezVolume.modify_volumegs' 0 N$7$7$99484L4L%&785M5:01."5"5"77"?3r9^O<=/IJ # 8~2244"))4,7 8 II%&4 6 NNv 6 .v 6'5m'D'5m'D,T2+9:K+L*89I*J)7)H3AB[3\*89I*J5CD_5`  b 0((.w||SV(D  IIh  KK ! !h ! / /  0s A)C,A(C D>AD99D>c |j|}|jdy#t$rZ}djtt |}t j||jj|Yd}~yd}~wwxYw)z_Delete volume. :param vol_obj: The object instance of the volume to be deleted )rF)force_snap_deleteTz7Delete operation of volume id:{0} failed with error {1}r-N) r@deleter:r5rOr r1r9r!r7)r'rr=r>r<s r delete_volumezVolume.delete_volumes{ 0ooVo4G NNUN 3 0//5vb69!f0>  IIh  KK ! !h ! / /  0s$' B ABB cg}|jr|jD]}|j|jjj }d}|j D]2}|j j|jk(s'|j}4|j|jj|jj|jj|d|S)zp Get volume host access list :param obj_vol: volume instance :return: host list rsN)r+rOrrt) rfrBrwrOrrylunr+rtrx access_mask)r'r= host_listrfrwrthost_luns r rz"Volume.get_volume_host_access_lists    &22 / }}[-=-=-@-@}AHHJ $+H||((GLL8&ll+  +*:*:*?*?(3(8(8(;(;0;0G0G0L0L),"./ /rch |j}|j}tjt |d|d<|jd|j |i|j r>|jd|j j|j jdi|jr>|jd|jj|jjdi|jr>|jd|jj|jjdi|S#t$r`}dj|jt|}tj||j j#| Yd }~y d }~wwxYw) zvget display volume attributes :param obj_vol: volume instance :return: volume dict to display rsize_total_with_unitrfrg)r+rOrbpoolz/Failed to display the volume {0} with error {1}r-N)rrzrconvert_size_with_unitrrrgr+rOrbrr:r5r r1r9r!r7)r'r=volume_detailsr>r<s r get_volume_display_attributesz$Volume.get_volume_display_attributess  0nn&G$446N5:&&s>,+G'H6JN1 2  ! !=$2R2RSZ2["\ ]$$%%$w/D/D/I/I-4-B-B-E-E'GHI&&%%&1H1H1K1K/6/F/F/I/I)KLM||%%v 8I8I6=lloo0G'HI" ! 0##)6',,A#?  IIh  KK ! !h ! / /  0sEE F1AF,,F1cd} ddg}|jjD]d}|jj|}||vs!t|ts2||k(s8dj |}|jj |fy#t $rU}dj t|}tj||jj |Yd}~yd}~wwxYw)zB validates the input string checks if it is empty string rrgr^z"Invalid input parameter "" for {0}r-2Failed to validate the module param with error {0}N) r!r$ isinstancer r5r7r:r1r9)r'invalid_string no_chk_listkeyvalerrmsgr>r<s r validate_input_stringzVolume.validate_input_strings 0*M:K{{)) 6kk((-k)jc.B>1AHHFKK))f)5  6 0##)6#a&>  IIh  KK ! !h ! / /  0s):BBB/B C$A CC$cP |D]}d|jvr:d|jvr(|dr#|drd}|jj|d}|jD],\}}|dk(rt |sd}|dk(st |r+d}.|sdj }|jj|y #t $rU}dj t|}tj||jj|Yd }~y d }~wwxYw) zA validates the host_list_input value for None and empty rrz4parameters are mutually exclusive: host_name|host_idr-TFzInvalid input parameter for {0}rN) r{r!r7itemsrr5r:r r1r9) r'host_list_inputrris_host_details_missingrvaluer>r<s r validate_host_listzVolume.validate_host_lists 0, 6 9>>#33 Y^^EU8U -)I2F!W --&-9*.'"+//"38JCk)2I%2P27/ )2I%2P27/ 8 +>EEcJFKK))f)5 6  0##)6#a&>  IIh  KK ! !h ! / /  0s+BC CC/C D%A D  D%cg}|rl|D]g}t}d}d}|dr#|j|d}|r |j}|dr|d}|dr|d}||d<||d<|j|i|S)z This method creates a dictionary of hosts and hlu parameter values :param hosts: host and hlu value passed from input file :return: list of host and hlu dictionary Nr)rrrt)dictrBrOrx)r'hosts host_list_newrrrrtrws r resolve_host_mappingszVolume.resolve_host_mappings s   0 F  $==4 3D=ED"&'' ?"9oG;u+C'. )$#& % $$Y/ 0rc g|_g|_|jjd}|jjd}|jjd}|jjd}|jjd}|jjd}|jjd}|jjd}|jjd } |jjd } |jjd } |jjd } |jjd } |jjd}|jjd}d}t di}d}d}d}|j |r|j ||!|dk(r|jjd|r|sd}||s|jjd| r"| s | s|s|jjd| r"| s | s|s|jjd|j||}| s| r=| sd}|jj|| | | dg}|j||_|rD| sd}|jj||xj|j|z c_|r#|j|}|j|_ |r&|j|}|jd|_|dk(r||_|r|j!}|j#}|j%||}t&j)d||j*r3|j-|j* }t&j)d!|n>|jr2|j-|j* }t&j)d"||d#k(r|s|s-d$j/|}|jj||dk(r|jjd%| r|jjd&|s|s|jjd'|s|jjd(d}|jrg}|jD]n}|d r6|j1t2j4j6d)|d i|d d*>|j1t2j4j6d)|d id+pt3j8||}|j;||,}|j=|||-}|rJt&j)d.||j}|j!}t&j)d/|d0}|d#k(r|r|r|j?||1d0}|d#k(r8|r6| d2k(r1|r/|jr#|jA|j|3}|rd0nd}|d#k(rM|rK| d4k(rF|rD|jr8|jC|j|5}t&jE||rd0nd}|d6k(r|r|jG|}d}|d#k(r|r|jI|7}||d8<||d9<|jjJd:i|y);zo Perform different actions on volume module based on parameters passed in the playbook rrrrrnrrgrbrrrtrqrstaterF)changedrNrzSize can not be 0 (Zero)r-GBz)cap_unit can be specified along with sizez.hlu can be specified with host_id or host_namezAmapping_state can be specified with host_id or host_name or hosts)rrzJ'mapping_state' is required along with 'host_name' or 'host_id' or 'hosts')rrrtrFrzVolume Modify Required: %s)rz"Host Modify Required in access: %szHost Modify Required: %spresentzSvolume with id {0} is not found, unable to create a volume without a valid vol_namezInvalid snap_schedulez3new_vol_name is not required to create a new volumez5pool_id or pool_name is required to create new volumez#Size is required to create a volumerOrr)rr)rSrnrfrjzGot volume id , %sT)r=rru)rr=rr)rr=absent)r=rr)&rvrr!r$rrrr7r@rrNrOrkrLr+rlrzget_idrr1rGrfrr5rxrrrget_size_in_gbrRrorrrr2rr exit_json)r'rrrrrnrrgrbrrrtrqrrrrresultrrto_modify_hostr=rrw msg_nonamerfrrSrs r perform_module_operationzVolume.perform_module_operation$s   ";;%%j1##H-KK&&{3 ++$$Y/{{!!&);;%%j1 **?; ++,,->?KK&&{3 ++$$Y/kk  ' **?; {{)).9  ""7+ ""7+   ""$   # #E *   KK ! !&@ ! A H  $ KK ! !'2 ! 3  '% KK ! !'= ! > )GE KK ! !'L ! M//(/C  ? %%&%1"+LMD!%!;!;D!AD   ? %%&%1   $"<",>q,AD ) B ,9D ) $446N^^%F!88(KN II2N C""!%!A!A%,%8%8"B": >O##!%!A!A%,%8%8"B": 4nE I n((.v %%*%5" %%*A%B %%+C%DW %%+A%B %%+6%7K!!  ..qDE{#**+0+B+B+M+MX\^bcl^mWn$(K12$**+0+B+B+M+MX\^bcl^mWnoq q''h7D}}y'}JH(((5@)BG !X-.!!--D!Z/N!!++T=R=R\c+d"&$E H ((0G!N I .!??@!N$y#1  ''r)NN)N)__name__ __module__ __qualname____doc__r|rkrlr(r@rBrLrNrRrXr\rorrrrrrrrrrrrrrr rrs&M #2,*+X+>+6+>+> 0 040l30jV0p060&.0`0"(0>0*062j(rrctd*idtdddtdddtdddtdddtddd tdd d tddd d gdtdddtdddtdddtddddgdtdddtdddtdddtdddtdddttddtddtdddtdd d tddd!d"gd#tddd$tddgd%d&td'dd(d)gS)+zUThis method provide parameters required for the ansible volume module on UnityrFr )requiredtyperr^rrrnrrrTB)rrchoicesraboolr_r`rWSPASPBrbrgrrrr}r)rrrt)rrelementsoptionsrtrqrurrrr[) AUTOTIER_HIGHAUTOTIERHIGHESTLOWESTrTrrr)rrrr r r s  u51 U/ %e4 E2   e%0   5u -  u54,G e&1 %f5 U8  UUEN C e%8 E6 E2 e%0  E#U?!%u5!AU;! , %e ,- .E$,j#9;/ 25u53 4UA>?5 8Duy(6KL9 rc8t}|jy)z^ Create Unity volume object and perform action on it based on user input from playbookN)rr)objs r mainrs (C  "r__main__N)r __future__rrrr __metaclass__ DOCUMENTATIONEXAMPLESRETURNansible.module_utils.basicrCansible_collections.dellemc.unity.plugins.module_utils.storage.dellr get_loggerr1r%robjectrr rrrrr rs 3@@ Z xa F{ z5ex "-v (Vv (r F# zFr