Vh/dZddlmZmZmZeZdZdZdZ ddl m Z ddl m Z ddlZe jd ZGd d eZd Zd ZdZdZdZdZdZedk(reyy)zJ Ansible module for managing volumes on Dell Technologies (Dell) PowerFlex)absolute_importdivisionprint_functiona module: volume version_added: '1.0.0' short_description: Manage volumes on Dell PowerFlex description: - Managing volumes on PowerFlex storage system includes creating, getting details, modifying attributes and deleting volume. - It also includes adding/removing snapshot policy, mapping/unmapping volume to/from SDC and listing associated snapshots. author: - P Srinivas Rao (@srinivas-rao5) extends_documentation_fragment: - dellemc.powerflex.powerflex options: vol_name: description: - The name of the volume. - Mandatory for create operation. - It is unique across the PowerFlex array. - Mutually exclusive with I(vol_id). type: str vol_id: description: - The ID of the volume. - Except create operation, all other operations can be performed using I(vol_id). - Mutually exclusive with I(vol_name). type: str storage_pool_name: description: - The name of the storage pool. - Either name or the id of the storage pool is required for creating a volume. - During creation, if storage pool name is provided then either protection domain name or id must be mentioned along with it. - Mutually exclusive with I(storage_pool_id). type: str storage_pool_id: description: - The ID of the storage pool. - Either name or the id of the storage pool is required for creating a volume. - Mutually exclusive with I(storage_pool_name). type: str protection_domain_name: description: - The name of the protection domain. - During creation of a volume, if more than one storage pool exists with the same name then either protection domain name or id must be mentioned along with it. - Mutually exclusive with I(protection_domain_id). type: str protection_domain_id: description: - The ID of the protection domain. - During creation of a volume, if more than one storage pool exists with the same name then either protection domain name or id must be mentioned along with it. - Mutually exclusive with I(protection_domain_name). type: str vol_type: description: - Type of volume provisioning. choices: ["THICK_PROVISIONED", "THIN_PROVISIONED"] type: str compression_type: description: - Type of the compression method. choices: ["NORMAL", "NONE"] type: str use_rmcache: description: - Whether to use RM Cache or not. type: bool snapshot_policy_name: description: - Name of the snapshot policy. - To remove/detach snapshot policy, empty I(snapshot_policy_id)/I(snapshot_policy_name) is to be passed along with I(auto_snap_remove_type). type: str snapshot_policy_id: description: - ID of the snapshot policy. - To remove/detach snapshot policy, empty I(snapshot_policy_id)/I(snapshot_policy_name) is to be passed along with I(auto_snap_remove_type). type: str auto_snap_remove_type: description: - Whether to remove or detach the snapshot policy. - To remove/detach snapshot policy, empty I(snapshot_policy_id)/I(snapshot_policy_name) is to be passed along with I(auto_snap_remove_type). - If the snapshot policy name/id is passed empty then I(auto_snap_remove_type) is defaulted to C(detach). choices: ['remove', 'detach'] type: str size: description: - The size of the volume. - Size of the volume will be assigned as higher multiple of 8 GB. type: int cap_unit: description: - The unit of the volume size. It defaults to 'GB'. choices: ['GB' , 'TB'] type: str vol_new_name: description: - New name of the volume. Used to rename the volume. type: str allow_multiple_mappings: description: - Specifies whether to allow or not allow multiple mappings. - If the volume is mapped to one SDC then for every new mapping I(allow_multiple_mappings) has to be passed as true. type: bool sdc: description: - Specifies SDC parameters. type: list elements: dict suboptions: sdc_name: description: - Name of the SDC. - Specify either I(sdc_name), I(sdc_id) or I(sdc_ip). - Mutually exclusive with I(sdc_id) and I(sdc_ip). type: str sdc_id: description: - ID of the SDC. - Specify either I(sdc_name), I(sdc_id) or I(sdc_ip). - Mutually exclusive with I(sdc_name) and I(sdc_ip). type: str sdc_ip: description: - IP of the SDC. - Specify either I(sdc_name), I(sdc_id) or I(sdc_ip). - Mutually exclusive with I(sdc_id) and I(sdc_ip). type: str access_mode: description: - Define the access mode for all mappings of the volume. choices: ['READ_WRITE', 'READ_ONLY', 'NO_ACCESS'] type: str bandwidth_limit: description: - Limit of volume network bandwidth. - Need to mention in multiple of 1024 Kbps. - To set no limit, 0 is to be passed. type: int iops_limit: description: - Limit of volume IOPS. - Minimum IOPS limit is 11 and specify 0 for unlimited iops. type: int sdc_state: description: - Mapping state of the SDC. choices: ['mapped', 'unmapped'] type: str delete_snapshots: description: - If C(true), the volume and all its dependent snapshots will be deleted. - If C(false), only the volume will be deleted. - It can be specified only when the I(state) is C(absent). - It defaults to C(false), if not specified. type: bool state: description: - State of the volume. choices: ['present', 'absent'] required: true type: str notes: - The I(check_mode) is not supported. a - name: Create a volume dellemc.powerflex.volume: hostname: "{{hostname}}" username: "{{username}}" password: "{{password}}" validate_certs: "{{validate_certs}}" port: "{{port}}" vol_name: "sample_volume" storage_pool_name: "pool_1" protection_domain_name: "pd_1" vol_type: "THICK_PROVISIONED" compression_type: "NORMAL" use_rmcache: true size: 16 state: "present" - name: Map a SDC to volume dellemc.powerflex.volume: hostname: "{{hostname}}" username: "{{username}}" password: "{{password}}" validate_certs: "{{validate_certs}}" port: "{{port}}" vol_name: "sample_volume" allow_multiple_mappings: true sdc: - sdc_id: "92A304DB-EFD7-44DF-A07E-D78134CC9764" access_mode: "READ_WRITE" sdc_state: "mapped" state: "present" - name: Unmap a SDC to volume dellemc.powerflex.volume: hostname: "{{hostname}}" username: "{{username}}" password: "{{password}}" validate_certs: "{{validate_certs}}" port: "{{port}}" vol_name: "sample_volume" sdc: - sdc_id: "92A304DB-EFD7-44DF-A07E-D78134CC9764" sdc_state: "unmapped" state: "present" - name: Map multiple SDCs to a volume dellemc.powerflex.volume: hostname: "{{hostname}}" username: "{{username}}" password: "{{password}}" validate_certs: "{{validate_certs}}" port: "{{port}}" vol_name: "sample_volume" protection_domain_name: "pd_1" sdc: - sdc_id: "92A304DB-EFD7-44DF-A07E-D78134CC9764" access_mode: "READ_WRITE" bandwidth_limit: 2048 iops_limit: 20 - sdc_ip: "198.10.xxx.xxx" access_mode: "READ_ONLY" allow_multiple_mappings: true sdc_state: "mapped" state: "present" - name: Get the details of the volume dellemc.powerflex.volume: hostname: "{{hostname}}" username: "{{username}}" password: "{{password}}" validate_certs: "{{validate_certs}}" port: "{{port}}" vol_id: "fe6c8b7100000005" state: "present" - name: Modify the details of the Volume dellemc.powerflex.volume: hostname: "{{hostname}}" username: "{{username}}" password: "{{password}}" validate_certs: "{{validate_certs}}" port: "{{port}}" vol_name: "sample_volume" storage_pool_name: "pool_1" new_vol_name: "new_sample_volume" size: 64 state: "present" - name: Delete the Volume dellemc.powerflex.volume: hostname: "{{hostname}}" username: "{{username}}" password: "{{password}}" validate_certs: "{{validate_certs}}" port: "{{port}}" vol_name: "sample_volume" delete_snapshots: false state: "absent" - name: Delete the Volume and all its dependent snapshots dellemc.powerflex.volume: hostname: "{{hostname}}" username: "{{username}}" password: "{{password}}" validate_certs: "{{validate_certs}}" port: "{{port}}" vol_name: "sample_volume" delete_snapshots: true state: "absent" a! changed: description: Whether or not the resource has changed. returned: always type: bool sample: 'false' volume_details: description: Details of the volume. returned: When volume exists type: dict contains: id: description: The ID of the volume. type: str mappedSdcInfo: description: The details of the mapped SDC. type: dict contains: sdcId: description: ID of the SDC. type: str sdcName: description: Name of the SDC. type: str sdcIp: description: IP of the SDC. type: str accessMode: description: Mapping access mode for the specified volume. type: str limitIops: description: IOPS limit for the SDC. type: int limitBwInMbps: description: Bandwidth limit for the SDC. type: int name: description: Name of the volume. type: str sizeInKb: description: Size of the volume in Kb. type: int sizeInGb: description: Size of the volume in Gb. type: int storagePoolId: description: ID of the storage pool in which volume resides. type: str storagePoolName: description: Name of the storage pool in which volume resides. type: str protectionDomainId: description: ID of the protection domain in which volume resides. type: str protectionDomainName: description: Name of the protection domain in which volume resides. type: str snapshotPolicyId: description: ID of the snapshot policy associated with volume. type: str snapshotPolicyName: description: Name of the snapshot policy associated with volume. type: str snapshotsList: description: List of snapshots associated with the volume. type: str "statistics": description: Statistics details of the storage pool. type: dict contains: "numOfChildVolumes": description: Number of child volumes. type: int "numOfMappedSdcs": description: Number of mapped Sdcs of the volume. type: int sample: { "accessModeLimit": "ReadWrite", "ancestorVolumeId": null, "autoSnapshotGroupId": null, "compressionMethod": "Invalid", "consistencyGroupId": null, "creationTime": 1631618520, "dataLayout": "MediumGranularity", "id": "cdd883cf00000002", "links": [ { "href": "/api/instances/Volume::cdd883cf00000002", "rel": "self" }, { "href": "/api/instances/Volume::cdd883cf00000002/relationships /Statistics", "rel": "/api/Volume/relationship/Statistics" }, { "href": "/api/instances/VTree::6e86255c00000001", "rel": "/api/parent/relationship/vtreeId" }, { "href": "/api/instances/StoragePool::e0d8f6c900000000", "rel": "/api/parent/relationship/storagePoolId" } ], "lockedAutoSnapshot": false, "lockedAutoSnapshotMarkedForRemoval": false, "managedBy": "ScaleIO", "mappedSdcInfo": null, "name": "ansible-volume-1", "notGenuineSnapshot": false, "originalExpiryTime": 0, "pairIds": null, "protectionDomainId": "9300c1f900000000", "protectionDomainName": "domain1", "replicationJournalVolume": false, "replicationTimeStamp": 0, "retentionLevels": [], "secureSnapshotExpTime": 0, "sizeInGB": 16, "sizeInKb": 16777216, "snapshotPolicyId": null, "snapshotPolicyName": null, "snapshotsList": [ { "accessModeLimit": "ReadOnly", "ancestorVolumeId": "cdd883cf00000002", "autoSnapshotGroupId": null, "compressionMethod": "Invalid", "consistencyGroupId": "22f1e80c00000001", "creationTime": 1631619229, "dataLayout": "MediumGranularity", "id": "cdd883d000000004", "links": [ { "href": "/api/instances/Volume::cdd883d000000004", "rel": "self" }, { "href": "/api/instances/Volume::cdd883d000000004 /relationships/Statistics", "rel": "/api/Volume/relationship/Statistics" }, { "href": "/api/instances/Volume::cdd883cf00000002", "rel": "/api/parent/relationship/ancestorVolumeId" }, { "href": "/api/instances/VTree::6e86255c00000001", "rel": "/api/parent/relationship/vtreeId" }, { "href": "/api/instances/StoragePool::e0d8f6c900000000", "rel": "/api/parent/relationship/storagePoolId" } ], "lockedAutoSnapshot": false, "lockedAutoSnapshotMarkedForRemoval": false, "managedBy": "ScaleIO", "mappedSdcInfo": null, "name": "ansible_vol_snap_1", "notGenuineSnapshot": false, "originalExpiryTime": 0, "pairIds": null, "replicationJournalVolume": false, "replicationTimeStamp": 0, "retentionLevels": [], "secureSnapshotExpTime": 0, "sizeInKb": 16777216, "snplIdOfAutoSnapshot": null, "snplIdOfSourceVolume": null, "storagePoolId": "e0d8f6c900000000", "timeStampIsAccurate": false, "useRmcache": false, "volumeReplicationState": "UnmarkedForReplication", "volumeType": "Snapshot", "vtreeId": "6e86255c00000001" } ], "statistics": { "childVolumeIds": [ ], "descendantVolumeIds": [ ], "initiatorSdcId": null, "mappedSdcIds": [ "c42425XXXXXX" ], "numOfChildVolumes": 0, "numOfDescendantVolumes": 0, "numOfMappedSdcs": 1, "registrationKey": null, "registrationKeys": [ ], "replicationJournalVolume": false, "replicationState": "UnmarkedForReplication", "reservationType": "NotReserved", "rplTotalJournalCap": 0, "rplUsedJournalCap": 0, "userDataReadBwc": { "numOccured": 0, "numSeconds": 0, "totalWeightInKb": 0 }, "userDataSdcReadLatency": { "numOccured": 0, "numSeconds": 0, "totalWeightInKb": 0 }, "userDataSdcTrimLatency": { "numOccured": 0, "numSeconds": 0, "totalWeightInKb": 0 }, "userDataSdcWriteLatency": { "numOccured": 0, "numSeconds": 0, "totalWeightInKb": 0 }, "userDataTrimBwc": { "numOccured": 0, "numSeconds": 0, "totalWeightInKb": 0 }, "userDataWriteBwc": { "numOccured": 0, "numSeconds": 0, "totalWeightInKb": 0 } }, "snplIdOfAutoSnapshot": null, "snplIdOfSourceVolume": null, "storagePoolId": "e0d8f6c900000000", "storagePoolName": "pool1", "timeStampIsAccurate": false, "useRmcache": false, "volumeReplicationState": "UnmarkedForReplication", "volumeType": "ThinProvisioned", "vtreeId": "6e86255c00000001" } ) AnsibleModule)utilsNvolumeceZdZdZdZ d(dZd(dZ d)dZd(dZd)dZ d)d Z d Z d Z d Z d ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ d Z!d!Z"d"Z#d#Z$d$Z%d%Z&d&Z'd'Z(y)*PowerFlexVolumezClass with volume operationsc ztj|_|jjt ddgddgddgddgddgddgddgddgg}d d gg}ddgg}t |jd ||| |_tj|j  tj|j j|_ tjd y#t$rM}tjt||j j!t|Yd}~yd}~wwxYw)z. Define all parameters required by this modulevol_namevol_idstorage_pool_namestorage_pool_idprotection_domain_nameprotection_domain_idsnapshot_policy_namesnapshot_policy_idsdc sdc_stateF) argument_specsupports_check_modemutually_exclusiverequired_togetherrequired_one_ofz3Got the PowerFlex system connection object instancemsgN)r%get_powerflex_gateway_host_parameters module_paramsupdateget_powerflex_volume_parametersrmoduleensure_required_libs%get_powerflex_gateway_host_connectionparamspowerflex_connLOGinfo Exceptionerrorstr fail_json)self mut_ex_argsrequired_together_argsrequired_one_of_argses l/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/dellemc/powerflex/plugins/modules/volume.py__init__zPowerFlexVolume.__init__,s<"HHJ !!"A"CD"H-+->?02HI.0DE "56 "34 ":; "89; $)+"6!7!+X 67$,, %*40 2  ""4;;/ ."'"M"M ""#$D  HHJ K . IIc!f  KK ! !c!f ! - - .s AC$$ D:-AD55D:Nc|r|n|} d}|r(|jjjd|i}|r(|jjjd|i}|s-dj|}|jj ||dS#t $rV}dj|t|}tj||jj |Yd}~yd}~wwxYw) zGet protection domain details :param protection_domain_name: Name of the protection domain :param protection_domain_id: ID of the protection domain :return: Protection domain details Nid filter_fieldsnamez^Unable to find the protection domain with {0}. Please enter a valid protection domain name/id.rrz6Failed to get the protection domain {0} with error {1}) r%protection_domaingetformatr!r+r(r*r&r))r,rr name_or_id pd_detailserr_msgr0errormsgs r1get_protection_domainz%PowerFlexVolume.get_protection_domainPs.B)'  0J#!00BBFF#')=">G@ &!00BBFF#)+A"BGD &&,fZ&8 %%'%2a=  0$$*F:s1v$>  IIh  KK ! !h ! / /  0B B C1A C,,C1c|r|n|} d}|r(|jjjd|i}|r(|jjjd|i}|s-dj|}|jj ||dS#t $rV}dj|t|}tj||jj |Yd}~yd}~wwxYw) zGet snapshot policy details :param snap_pol_name: Name of the snapshot policy :param snap_pol_id: ID of the snapshot policy :return: snapshot policy details Nr4r5r7zZUnable to find the snapshot policy with {0}. Please enter a valid snapshot policy name/id.rrz4Failed to get the snapshot policy {0} with error {1}) r%snapshot_policyr9r:r!r+r(r*r&r))r, snap_pol_id snap_pol_namer;snap_pol_detailsr=r0r>s r1get_snapshot_policyz#PowerFlexVolume.get_snapshot_policyqs %0[]  0# #'#6#6#F#F#J#J#'"5$K$7 #'#6#6#F#F#J#J#)="9$K$; $&&,fZ&8 %%'%2#A& & 0$$*F:s1v$>  IIh  KK ! !h ! / /  0r@c|r|n|} d}|r(|jjjd|i}|r(|jjjd|i}t|dkDr/|-dj |}|j j |t|dkDr+|r)|jjj||d}|s-d j |}|j j ||d S#t$rV}d j |t|}tj||j j |Yd}~yd}~wwxYw) a Get storage pool details :param protection_domain_id: ID of the protection domain :param storage_pool_name: The name of the storage pool :param storage_pool_id: The storage pool id :return: Storage pool details Nr4r5r7zlMore than one storage pool found with {0}, Please provide protection domain Name/Id to fetch the unique poolr)r7protectionDomainIdzLUnable to find the storage pool with {0}. Please enter a valid pool name/id.rz1Failed to get the storage pool {0} with error {1}) r% storage_poolr9lenr:r!r+r(r*r&r)) r,rrrr; sp_detailsr=r0r>s r1get_storage_poolz PowerFlexVolume.get_storage_pools~)8_" ! 0J!00==AA#'"9B; !!00==AA#)+<"=B? :"';'C"#)&):"; %%'%2:"';!00==AA+<';#=B> %%+VJ%7 %%'%2a=  0#VJA7  IIh  KK ! !h ! / /  0sC?D E'A E""E'c|r|n|} |r)|jjjd|i}n(|jjjd|i}t|dk(r'dj |}t j |yd|dvr*|ddr"tj|ddd|dd <d}d}d |dvr=|dd r5|j|dd }t|dkDr|d|dd <|d }|r.d |vr*|d r%|j| }||dd <|d|dd<|dd*|dd} | |dd<|j| d|dd<|dS#t$rX} d} | j |t| } t j| |jj!| Yd} ~ yd} ~ wwxYw)zGet volume details :param vol_name: Name of the volume :param vol_id: ID of the volume :return: Details of volume if exist. r7r5r4r$Volume with identifier {0} not foundNsizeInKbKBsizeInGB storagePoolIdstoragePoolNamerIrprotectionDomainNamesnplIdOfSourceVolumesnapshotPolicyIdsnapshotPolicyName+Failed to get the volume {0} with error {1}r)r%rr9rKr:r&r'rget_size_in_gbrMr?rFr(r*r)r!r+) r,r r id_or_namevolume_detailsrsppd_idpdsnap_policy_idr0 error_msgs r1 get_volumezPowerFlexVolume.get_volumesK &V8 3 1!%!4!4!;!;!?!?#)8"4"@"6"&!4!4!;!;!?!?#'."@"2>"a'<CC  ^A.."1%j1050D0D"1%j1419q!*-BE."33"1%o6)).*;O*LMr7Q;;=f:N1%&7834E*b0+,//U/K:?q!"67<>vJq!"89a !78D!/!23I!J8Fq!"45,,^s r1 get_sdc_idzPowerFlexVolume.get_sdc_ids4 !J JJ 0"115599#)8"4:6 "115599#*F"3:5 #115599#'.:2 ;1$DKK  %%)%4q>$' ' 0#VJA7  IIh  KK ! !h ! / /  0sCC D.A D))D.cr |t|jdk(r|jjd|s|jjdd}|r|j |}|d}|r4|r2|dk7r-d j |} |jj| |j jj|||||| y #t$rV} d j |t| } tj| |jj| Yd} ~ yd} ~ wwxYw) aCreate volume :param use_rmcache: Boolean indicating whether to use RM cache. :param comp_type: Type of compression method for the volume. :param vol_type: Type of volume. :param size: Size of the volume. :param pool_id: Id of the storage pool. :param vol_name: The name of the volume. :return: Boolean indicating if create operation is successful Nr!Please provide valid volume name.rzNSize is a mandatory parameter for creating a volume. Please enter a valid sizer dataLayoutFineGranularity~compression_type for volume can only be mentioned when storage pools have Fine Granularity layout. Storage Pool found with {0})r size_in_gbr7 volume_type use_rmcachecompression_methodTz1Create volume {0} operation failed with error {1}) rKstripr!r+rMr:r%rcreater(r*r&r)) r,r pool_idsizevol_typert comp_typepool_data_layout pool_detailsr=r0r>s r1 create_volumezPowerFlexVolume.create_volume s= 03x~~'7#8A#= %%*M%N %%+?%@ $ #44W4M #/ #= -$(99&'-f-=&> %%'%2    & & - - 'Dx$+#, . . 0##)6(CF#;  IIh  KK ! !h ! / /  0sCC D6 A D11D6cH d}|D]8}|ds |jjj||d|dd}:|S#t$rU}dj t |}t j||jj|Yd}~yd}~wwxYw) a%Modify access mode of SDCs mapped to volume :param vol_id: The volume id :param access_mode_list: List containing SDC ID's whose access mode is to modified :return: Boolean indicating if modifying access mode is successful F accessModerh) volume_idrh access_modeTz9Modify access mode of SDC operation failed with error {0}rN) r%rset_access_mode_for_sdcr(r:r*r&r)r!r+)r,r access_mode_listchangedtempr0r>s r1modify_access_modez"PowerFlexVolume.modify_access_modeLs 0G( # %''..FF"(h$($6G8#G  # N 0((.s1v  IIh  KK ! !h ! / /  0s A3A B! A BB!c& d}|d|d(|jjjd i|d}|S#t$rO}d|ddt |}t j ||jj| Yd}~yd}~wwxYw) zModify IOPS and bandwidth limits of SDC's mapped to volume :param payload: Dict containing SDC ID's whose bandwidth and IOPS is to modified :return: Boolean indicating if modifying limits is successful Fbandwidth_limitN iops_limitTz$Modify bandwidth/iops limits of SDC rhz operation failed with error r) r%rset_mapped_sdc_limitsr(r*r&r)r!r+)r,payloadrr0r>s r1 modify_limitszPowerFlexVolume.modify_limitsds 0G()5L)5@##**@@K7KN 0181BCFLH IIh  KK ! !h ! / /  0s58 BAB  Bc |jjj||y#t$rV}dj |t |}t j||jj|Yd}~yd}~wwxYw)zDelete volume :param vol_id: The volume id :param remove_mode: Removal mode for the volume :return: Boolean indicating if delete operation is successful Tz1Delete volume {0} operation failed with error {1}rN) r%rdeleter(r:r*r&r)r!r+)r,r remove_moder0r>s r1 delete_volumezPowerFlexVolume.delete_volumexst 0    & & - -fk B 0##)6&#a   IIh  KK ! !h ! / /  0s&) BA BBc|d}g}g}d}|r|D]}|j|d|D]k}d|vr|dr|j|d}n4d|vr|dr|j|d}n|j|d }||vs[|j|mtjd |t |d k(ry |D]+}|j j j|d |-y#t$rZ}dj||d t|} tj| |jj| Yd}~yd}~wwxYw)zUnmap SDC's from volume :param volume: volume details :param sdc: List of SDCs to be unmapped :return: Boolean indicating if unmap operation is successful mappedSdcInfoNsdcIdrfrfrgrgrhrhzSDC IDs to remove %srFr4Tz3Unmap SDC {0} from volume {1} failed with error {2}r)appendrkr&r'rKr%rremove_mapped_sdcr(r:r*r)r!r+) r,rr current_sdcscurrent_sdc_ids sdc_id_listrhrr0r>s r1unmap_volume_from_sdcz%PowerFlexVolume.unmap_volume_from_sdcsso.   $ 6&&tG}5 6 +DT!d:&6$z2BCT!d8nX?X?(""6* + '5 { q  0% *##**<<4L&* * 0#VFF4L#a&A  IIh  KK ! !h ! / /  0s?0C00 E9AEEcv|d}g}g}g}g}|j|}|D]p} |j| } | |vr5|j| |j| | |j| Mt || | \} } |j ||| | rt jd||sd||fS d} |D]}|d|d|d|jjdd}|jjjdi||d s|d r9|d|d|d |d d }|jjjdi|d } | ||fS#t$r]}d j|d|dt!|}t j#||jj%|Yd}~yd}~wwxYw)zMap SDC's to volume :param volume: volume details :param sdc: List of SDCs :return: Boolean indicating if mapping operation is successful rzSDC to add: %sFr4rhrallow_multiple_mappings)rrhrrrrrrhrrTz3Mapping volume {0} to SDC {1} failed with error {2}r7rNr)get_current_sdcsget_sdc_id_from_inputrupdate_temp_datacheck_for_sdc_modificationupdate_sdc_listsr&r'r!r$r%radd_mapped_sdcrr(r:r*r)r+)r,rrrr sdc_map_listsdc_modify_list1sdc_modify_list2rrrhaccess_mode_dict limits_dictrrr0r>s r1map_volume_to_sdcz!PowerFlexVolume.map_volume_to_sdcso.   // = ED//5F_,""6*%%dF3##D)0JFD1*- +%%&68H&6 E E !<0*,<< < 0G# !'!(m#&}#5 **+DE :##**99DGD()S->%+D\"%h-+./@+A&),&7 GED''..DDOwO' (,.>> > 0//5vfVn69(mSV0M  IIh  KK ! !h ! / /  0s2BE F8AF33F8cR|r|j||r|j|yyNr)r,rrrrs r1rz PowerFlexVolume.update_sdc_listss*   # #$4 5   # #K 0 cd|vr|dr|j|d}|Sd|vr|dr|j|d}|S|j|d}|S)Nrfrrgrrhr)rkr,rrhs r1rz%PowerFlexVolume.get_sdc_id_from_inputss  $z"2__d:.>_?F   $x.__DN_;F __DN_;F rc^||d<d|vrt|d|d<d|vrd|d<d|vrd|d<yy)Nrhrrrget_access_moders r1rz PowerFlexVolume.update_temp_datasTX D ] 34   D (&*D" # t #!%D  $rcDg}|r|D]}|j|d|S)Nrr)r,rrrs r1rz PowerFlexVolume.get_current_sdcs s1 $ 6&&tG}5 6rcT|jjd}|jjd}|jjd}|r]|D]X} t| d| dgs't| d| dgst| d| dgs=|jjdZ||s|jjd |r7|5|3d } tj | |jj| |d k(r ||jjd y y y )zValidate the input parametersrcap_unitryrhrgrfz2sdc_id, sdc_ip and sdc_name are mutually exclusiverNzScap_unit can be specified along with size only. Please enter a valid value for sizezyTo remove/detach snapshot policy, please provide empty snapshot policy name/id along with auto_snap_remove_type parameterpresentzJdelete_snapshots can be specified only when the state is passed as absent.)r!r$allr+r&r)) r,auto_snap_remove_typerCrD delete_snapsstaterrryrr=s r1validate_parametersz#PowerFlexVolume.validate_parameterss@kk  ';;%%j1{{!!&)  Hhh89T(^T*-=>?T(^T*-=>?KK))/G)H  H  $ KK ! !'8 ! 9 !]%:'8G IIg  KK ! !g ! . I ,": KK ! !, " -#; rc djt|}tj|d|vr|d}dj||d}tj||jj j |d||dj|}tj|d|vrVd|vrR|jj j|d|dj|d}tj|d|vrR|jjj||ddj|d}tj|d |vr[|jjj||d d jt|d }tj|d |vrR|jjj||d d j|d }tj|d |vrR|jjj||d dj|d }tj|y#t$rV}dj|t|}tj||jj!|Yd}~yd}~wwxYw)z Update the volume attributes :param vol_id: Id of the volume :param modify_dict: Dictionary containing the attributes of volume which are to be updated :return: True, if the operation is successful z@Dictionary containing attributes which are to be updated is {0}.rzlRemoving/detaching the snapshot policy from a volume. auto_snap_remove_type: {0} and snapshot policy id: {1}rCz/The snapshot policy has been {0}ed successfullyz8Attached the snapshot policy {0} to volume successfully.new_namez5The name of the volume is updated to {0} sucessfully.new_sizez6The size of the volume is extended to {0} sucessfully.rtz.The use RMcache is updated to {0} sucessfully.r{z6The compression method is updated to {0} successfully.Tz.Failed to update the volume {0} with error {1}rN)r:r*r&r'r%rBremove_source_volumeadd_source_volumerrenameextendset_use_rmcacheset_compression_methodr(r)r!r+)r,r modify_dictr snap_typer0r=s r1 modify_volumezPowerFlexVolume.modify_volume2s; /%%+VC ,<%=  HHSM&+5'(?@ #F9k-.HI ##33HH . C%%+VI%6 &k9%4##33EE .8''-vk-.H'I [(##**11&2=j2IK--3VK 4K-L [(##**11&2=j2IK%%+VC J0G,H%I  +##**::K 68&&,f[-G&H k)##**AAK 46''-vk+.F'G  /((.vs1v(>  IIg  KK ! !g ! . .  /sI-I00 K9A K  Kci}|r:|d} |j| } | d} |j| ||dk7r||d<|j|||tj|dd} |j ||| |j |||||dk(r|r|d r ||d <|d |d <|6|dk7r1|r#|d rd } |jj| | |d ||d <|S)a :param vol_details: Details of the volume :param new_size: Size of the volume :param use_rmcache: Bool value of use rm cache :param comp_type: Type of compression method :param new_name: The new name of the volume :param snap_pol_id: Id of the snapshot policy :param auto_snap_remove_type: Whether to remove or detach the policy :return: Dictionary containing the attributes of volume which are to be updated rSrnrocompressionMethodr{rPrQrWrrCzWTo remove/detach a snapshot policy, provide the snapshot policy name/id as empty stringr) rMpool_data_layout_fineupdate_use_rmcacherr[update_new_sizeupdate_new_namer!r+)r, vol_detailsrrtr{rrCrrrxr}r|vol_size_in_gbr=s r1 to_modifyzPowerFlexVolume.to_modifyws7 !/2G000IL+L9   & &'7 8K(;<<+4 K(  [+F--k*.EtL X{NC [(K@  "{b'8%+6L*M3HK/ 023  &  "{b'8$5K)LE %%'%2$, 67?-8 M*rc|I|t|jdk(r|jjd||dk7r||d<yyy)Nrrmrr7r)rKrvr!r+)r,rrrs r1rzPowerFlexVolume.update_new_names\  3x~~'7#8A#= %%+2%3;v..*2 J'/ rc6||dz |cxkr|ksn||d<yyy)Nrr)r,rrrs r1rzPowerFlexVolume.update_new_sizes/  $q(HFF&.K #G rc&||d|k7r||d<yyy)N useRmcachertr)r,rrtrs r1rz"PowerFlexVolume.update_use_rmcaches)  "L)[8)4K &9 #rcj|dk7r.dj|}|jj|yy)Nrprqr)r:r!r+)r,r|r=s r1rz%PowerFlexVolume.pool_data_layout_fines> 0 0#F#34  KK ! !g ! . 1rc|r(d|vr$||dk7r|jjd|r(d|vr$||dk7r|jjd|r$||dk7r|jjd|r$||dk7r|jjd |r$||d k7r|jjd |r&||d k7r|jjd yyy)au :param vol_details: Details of the volume :param snap_pol_name: Name of the snapshot policy :param snap_pol_id: Id of the snapshot policy :param pd_name: Name of the protection domain :param pd_id: Id of the protection domain :param pool_name: Name of the storage pool :param pool_id: Id of the storage pool rXzEntered snapshot policy id does not match with the snapshot policy's id attached to the volume. Please enter a correct snapshot policy id.rrYzEntered snapshot policy name does not match with the snapshot policy's name attached to the volume. Please enter a correct snapshot policy name.rIzEntered protection domain id does not match with the volume's protection domain id. Please enter a correct protection domain id.rSzqEntered storage pool id does not match with the volume's storage pool id. Please enter a correct storage pool id.rVzEntered protection domain name does not match with the volume's protection domain name. Please enter a correct protection domain name.rTzwEntered storage pool name does not match with the volume's storage pool name. Please enter a correct storage pool name.N)r!r+)r,rrDrCpd_namer_ pool_namerxs r1 verify_paramszPowerFlexVolume.verify_paramss, -<{+=>> KK ! !'G ! H /;>-A!BB KK ! !'/ ! 0 Uk*>?? KK ! !'? ! @ w+o">> KK ! !'D ! E w+.D"EE KK ! !'K ! L k2C&DD KK ! !'F ! GE9rc &|jjd}|jjd}|jjd}|jjd}|jjd}|jjd}|jjd}|jjd}|jjd } |jjd } |jjd } |jjd } |jjd } |jjd}|jjd}tj|jjd}|jjd}|jjd}|jjd}|j |}t |}|j | } d}t di}|j| | | |||j| | | } |j| |} |j||}|j|||}|j| | } |j||\}}|r|r|j|| | ||||d}|dk(r|s|j|||||| | || \}}}i}|rK|dk(rF|j!|| | ||| | }dj#t%|}t&j)|d}d}d}|dk(r |r|r|dk(r|j+|||\}}}d}|dk(r|r|r|dk(r|j-||}d}|r|dk(r|j/||}d}|dk(r|r|j1||}|xs|xs|xs|xs |xs|xs|}|j3|||||d<|jj4di|y)zh Perform different actions on volume based on parameters passed in the playbook r r rzcompression_typerrrrrrrrtryr vol_new_namerrdelete_snapshotsrF)rr]rz-Parameters to be modified are as follows: {0}mappedunmappedabsentrNr)r!r$copydeepcopycheck_null_capitalize get_vol_typedictrget_auto_snap_rt get_size_dataget_pd_detailsget_sp_detailsget_snap_pol_detailsget_volrcreate_new_volumerr:r*r&r'sdc_state_mappedrrdelete_operationprepare_output exit_json) r,r r rzrsp_namesp_idrr_rDrCrrtryrrrrrrrresultr]create_changedrr map_changed mode_changedlimits_changed unmap_changedmodify_changed del_changeds r1perform_module_operationz(PowerFlexVolume.perform_module_operationsR ;;%%j1##H-;;%%j1;;--.@A++$$%89 ""#45++$$%=> ""#9: **+AB kk(()=> $ 2 23J Kkk((7 {{!!&);;%%j1{{)).9 mmDKK..u56KK&&{3 ;;--.@A ""7+556FG) $ : : !!#    !6 !.0@% I!% 5 5m6A6K!M!!$1##GU3##GUE:// {K "&h!?     {GU  I n595K5K&(,|r|jjd|r|jjd|j||||||} | rE|j|} | d}dj t | } t j| || | fS)Nz@Creation of volume is allowed using vol_name only, vol_id given.rzpvol_new_name parameter is not supported during creation of a volume. Try renaming the volume after the creation.r4z7Volume created successfully, fetched volume details {0})r!r+r~rcr:r*r&r') r,r r rzrrrtryrr]rrs r1rz!PowerFlexVolume.create_new_volumes  KK ! !'2 ! 3  KK ! !! " "++HeT,4k,<> !__X6N#D)F%%+VC,?%@  HHSM~~55rcd}d}d}|j||\}}}t|dkDr|j||}t|dkDr+|D]&} |d| d| d| dd} |j| }(|||fS)NFrr4rhrrr)rrKrr) r,r rr]rrrr limits_listrrs r1rz PowerFlexVolume.sdc_state_mappeds   " ">3 7 3 %{  1 $2263CEL { a # =!/!5"8n'+,='>"&|"4  "&!3!3G!< =^[88rcF|durd}||durd}|j||}|S)NTINCLUDING_DESCENDANTSFONLY_ME)r)r,r rrs r1rz PowerFlexVolume.delete_operations@ t #6   #'75'@(    v'7 8 rc*|r|j}|Sr) capitalize)r, input_strs r1rz%PowerFlexVolume.check_null_capitalizes !,,.IrcB |jjjd|i}t|dk(r'dj |}t j |yd|dvr*|ddr"tj|ddd|dd<d}d}d |dvr=|dd r5|j|dd }t|dkDr|d |dd <|d }|r.d |vr*|d r%|j| }||dd <|d |dd<|dd+|dd}||dd<|j|d |dd<nd|dd<d|dd<|jjjd|ddi}||dd<|jjj|dd} | r| ni|dd<|dS#t$rX} d} | j |t| } t j | |jj!| Yd} ~ yd} ~ wwxYw)zyShow volume details :param vol_id: ID of the volume :return: Details of volume if exist. r4r5rrONrPrQrRrSr7rTrIrUrVrWrXrYancestorVolumeId snapshotsList statisticsrZr)r%rr9rKr:r&r)rr[rMr?rFget_statisticsr(r*r!r+) r,r r]rr^r_r`ra list_of_snapsrr0rbs r1rzPowerFlexVolume.show_outputs < 1!0077;;#Vn<.N>"a'<CC #^A.."1%j1050D0D"1%j1419q!*-BE."33"1%o6)).*;O*LMr7Q;;=f:N1%&7834E*b0+,//U/K:?q!"67<>vJq!"89a !78D!/!23I!J8Fq!"45,,^q!"67!//66::1>!3DT3JK;MM1>N1 o .,,33BBq!$')JHL.2+0Z<1|#0J?C26*0X000(0 '0R<0|1& -DC/J0d3/ 5 /1Gfm(^3 &%   609( B1rr c$t}t}|dD]q}|d|k(s t|||||d|dk7s |d|dk7r>||d<d|d<d|d<|d|dk7r|d|d<|dt|dk7r|d|d<||fS||fS) z :param volume: The volume details :param sdc_id: The ID of the SDC :param sdc_details: The details of SDC :return: Dictionary with SDC attributes to be modified rr limitIopsr limitBwInMbpsrrhN)rupdate_access_modeget_limits_in_mb)rrhrjrrrs r1rr%sv&Ko& w<6 ! v{4Dc J;;|#<<(K8I,JJ(. H%,0 L)15 -.{#{<'@@0;L0IK -'(5F)GHI$$56 12  [ (( [ ((rcZ|dt|dk7r||d<t|d|d<yy)Nrrrhr)rhrjrrs r1r$r$AsD < K 6 78%+")8  &*(&8rc|r|dz Sy)z? :param limits: Limits in KB :return: Limits in MB r Nr)limitss r1r%r%Is }rc0dddd}|j|S)z^ :param access_mode: Access mode of the SDC :return: The enum for the access mode ReadWriteReadOnlyNoAccess READ_WRITE READ_ONLY NO_ACCESSr9)rrs r1rrSs("    ,,rc6ddd}|r|j|}|S)zg :param vol_type: Type of the volume :return: Corresponding value for the entered vol_type ThickProvisionedThinProvisioned)THICK_PROVISIONEDTHIN_PROVISIONEDr1)rz vol_type_dicts r1rras+ 0-M $$X. Orctd-idtdtdtdtdtdtdtd d td td td dtddgdtddgdtddgdtddgdtdtd dtd dtdd tttttgd!td td "#d$td%d&gd'td(d)d*d+g,S).zMThis method provide parameter required for the volume module on PowerFlexr r rrrrrtbool)typerrryintrrr )choicesrzr5r6rNORMALNONErdetachremoverrrrlistrr-)rhrgrfrrr)r:elementsoptionsrrrrTr*rr)requiredr:r<r)rrrr1r r osv    $ & 26&  $v =AF f%  =AF    6   u   tTl+ 24FGH x&89 #Hh+?@ V !%& 1 6*  &$vdf *78 $% 0U+ 3  0*561 2Duy(6KL3 rc8t}|jy)zc Create PowerFlex volume object and perform actions on it based on user input from playbookN)r r)objs r1mainrGs  C  "r__main__)r  __future__rrrr: __metaclass__ DOCUMENTATIONEXAMPLESRETURNansible.module_utils.basicrGansible_collections.dellemc.powerflex.plugins.module_utils.storage.dellrr get_loggerr&objectr rr$r%rrr rGrrrr1rRs QBB s jm ^o b5 ex y1fy1x)8( - @# zFr