Vh ddlmZmZmZeZdZdZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlmZddlmZmZddlmZddlmZdd lmZd Zd Zed k(reyy) )absolute_importdivisionprint_functiona$ --- module: vsphere_copy short_description: Copy a file to a VMware datastore description: - Upload files to a VMware datastore through a vCenter REST API. author: - Dag Wieers (@dagwieers) options: src: description: - The file to push to vCenter. required: true type: str aliases: [ name ] datacenter: description: - The datacenter on the vCenter server that holds the datastore. required: false type: str datastore: description: - The datastore to push files to. required: true type: str path: description: - The file to push to the datastore. required: true type: str aliases: [ dest ] timeout: description: - The timeout in seconds for the upload to the datastore. default: 10 type: int diskformat: version_added: 4.2.0 description: - Optional argument - Set a diskformat for certain uploads like stream optimized VMDKs - There is no official documentation, but it looks like V(StreamVmdk) needs to be set for stream optimized VMDKs that are uploaded to vSAN storage - Setting this for non-VMDK files might lead to undefined behavior and is not supported. choices: ["StreamVmdk"] type: str notes: - "This module ought to be run from a system that can access the vCenter or the ESXi directly and has the file to transfer. It can be the normal remote target or you can change it either by using C(transport: local) or using C(delegate_to)." extends_documentation_fragment: - community.vmware.vmware.documentation a - name: Copy file to datastore using delegate_to community.vmware.vsphere_copy: hostname: '{{ vcenter_hostname }}' username: '{{ vcenter_username }}' password: '{{ vcenter_password }}' src: /some/local/file datacenter: DC1 Someplace datastore: datastore1 path: some/remote/file delegate_to: localhost - name: Copy file to datastore when datacenter is inside folder called devel community.vmware.vsphere_copy: hostname: '{{ vcenter_hostname }}' username: '{{ vcenter_username }}' password: '{{ vcenter_password }}' src: /some/local/file datacenter: devel/DC1 datastore: datastore1 path: some/remote/file delegate_to: localhost - name: Copy file to datastore using other_system community.vmware.vsphere_copy: hostname: '{{ vcenter_hostname }}' username: '{{ vcenter_username }}' password: '{{ vcenter_password }}' src: /other/local/file datacenter: DC2 Someplace datastore: datastore2 path: other/remote/file delegate_to: other_system - name: Copy file to datastore using other_system community.vmware.vsphere_copy: hostname: '{{ vcenter_hostname }}' username: '{{ vcenter_username }}' password: '{{ vcenter_password }}' src: /other/local/streamOptimized.vmdk datacenter: DC2 Someplace datastore: datastore2 path: disk_imports/streamOptimized.vmdk timeout: 360 diskformat: StreamVmdk delegate_to: other_system N) AnsibleModule) urlencodequote) to_native)open_url)base_argument_speccdt|jdz}|jdsd|z}t|}|r|j dd}||d<|r||d<t |}|d|S) z5 Constructs a URL path that vSphere accepts reliably z /folder/%s/)dsName&z%26dcPath diskFormat?)rlstrip startswithdictreplacer) datastore datacenterpath diskformatparamss q/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/vmware/plugins/modules/vsphere_copy.py vmware_pathrs| % C 01 1D ??3 Tz  #F''U3 %x)| v FF ##c t}|jttddgtdtdtddgdtd d tddd g t|d}|jd}|jd}|jj d}|jj d}|jj d}|jj d}|jj d}|jj d} |jj d} |jj d} t |d} tj| jtj|jdk(rd}nSt!j  j#dt j$}tj|jt'|||| }t)|||gs|jd d!||}d"t+t-|d#}d} t/|||d$| ||| d% }|s|jd*|ddd+|jI}d,|cxkrd-kr#nn |jKd||jL|.y|jNj d/d}|jNj d0djQd1k(rd2}nd}|jd*d||jL|t|jN||3y#t$r)} |jdt| zYd} ~ d} ~ wwxYw#t0j2$r} t5| j6t8rmt-| j6dkDr9| dt:j<k(r}|jd&d| dt| |'nZ|jt| n>|jt+| d| dt+| |t?j@(Yd} ~ d} ~ wt$rw} d)} t5| dtBr| d}n#tDtFf$rYnwxYw|jt| d|t| |t?j@(Yd} ~ ld} ~ wwxYw)4NTname)requiredaliasesF)r!deststr)r!r"type int)defaultr% StreamVmdk)r!r%choices)srcrrrtimeoutr) argument_specsupports_check_modehostnameusernamepasswordr+rrrrvalidate_certsr,rbzFailed to open src file %s)msgr)accesszDOne of following parameter is missing - hostname, username, passwordzhttps://zapplication/octet-stream)z Content-TypezContent-LengthPUT)dataheadersmethodr, url_username url_passwordr2force_basic_authz'Failed to upload, image probably in use)r4statuserrnoreasonurl)r4r>r?r@rA exceptionzFailed to upload)r4rAr?r>r@i,)changedr>r@rAzcontent-lengthztransfer-encodingchunked)r4r?r>r@lengthr9rFrA))r updaterrrgetopenatexitregisterclose Exception fail_jsonr osstatst_sizemmapfileno ACCESS_READrallr$lenr socketerror isinstanceargstupler? ECONNRESET traceback format_excr'KeyError TypeErrorgetcode exit_jsonr4r9lower)r-moduler/r0r1r+rrrrr2r,fder8 remote_pathrAr9r error_coder>rHrFs rmainrlso&(M $ 1'% 4& >Re,U\NK M#!F }}Z(H}}Z(H}}  ,H --  E "C""<0J !!+.I ==  V $D""<0J]]&&'78Nmm *GJ #t_! wws|q yya0@0@A #iT:FK (H- .cd$k 2C3c$i.G AY StWUG"*R`&* ,0 /S#D  ? YY[F fsfQUUL/6 99==,b 1 7 7 9Y FGG/tFSTSXSXagquvwvvrAKRX[ \w J9IaLHIIJ2 << H affe $166{QQ45+++$$)R[_ghijgkt}~uAGJ$K  Yq\ 2   QAaDQ!$ 0D0D0F  H Y  !A$$qT )$   Yq\$j )! #AUAUAW  Y YYsa4+M&N  NNN S+CQ(( S+4S&7RS&R"S&!R"">S&&S+__main__) __future__rrrr% __metaclass__ DOCUMENTATIONEXAMPLESrLr?rTrQrYr_ansible.module_utils.basicr+ansible.module_utils.six.moves.urllib.parserransible.module_utils._textr ansible.module_utils.urlsr Hansible_collections.community.vmware.plugins.module_utils._argument_specr rrl__name__rrrysgA@ 3 j. ` 4H0.g$"Z\z zFr