VhCddlmZddlmZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl mZddl mZddlmZddlmZddlmZmZdd lmZdd lmZdd lmZeZGd d eZ ddZ!e"dk(re!yy)) annotations)CLIN) constants)context)option_helpers)AnsibleOptionsError) to_nativeto_text) module_loader)run_cmd)DisplayceZdZdZdZdZdZdZdddZd d iZ d Z e d Z fd Z fdZfdZe dZe dZxZS)PullCLIaO Used to pull a remote copy of ansible on each managed node, each set to run via cron and update playbook source via a source repository. This inverts the default *push* architecture of ansible into a *pull* architecture, which has near-limitless scaling potential. None of the CLI tools are designed to run concurrently with themselves, you should use an external scheduler and/or locking to ensure there are no clashing operations. The setup playbook can be tuned to change the cron frequency, logging locations, and parameters to ansible-pull. This is useful both for extreme scale-out as well as periodic remediation. Usage of the 'fetch' module to retrieve logs from ansible-pull runs would be an excellent way to gather and analyze remote logs from ansible-pull. z ansible-pullgitz local.yml)r subversionhgbzrzFile does not existzFile is not readable) playbook.ymlaThe name of one the YAML format files to run as an Ansible playbook. This can be a relative path within the checkout. By default, Ansible will look for a playbook based on the host's fully-qualified domain name, on the host hostname and finally a playbook named *local.yml*.Tc"d}tjjddrltjdD]V}t|tr|ddj |zz }+d|vs t jj|sO|d|zz }X|S)N inventoryFz -i '%s' ,z -i %s ) rCLIARGSget isinstancelistjoinospathexists)inv_optsinvs @/home/dcms/DCMS/lib/python3.12/site-packages/ansible/cli/pull.py _get_inv_clizPullCLI._get_inv_cliBs ??  {E 2{3 0c4( chhsm ;;HCZ277>>##6 C/H  0 c jtt| ddtj|j tj |j tj|j tj|j tj|j tj|j tj|j |j jdddd|j jd d d d |j jdddd d d|j jddddd|j jdddd d d|j jddddtjd !|j jd"d#d$dd%|j jd&d'd d()|j jd*d+d,d-.|j jd/d d0d d12|j jd3d4d5|jd6|jd7|jd8|j jd9d:d d d;|j jd|j jd?d@d d dA|j jdBd dCd dD2|j jdEt j"dFd dG2y)Hz* create an options parser for bin/ansible z0%prog -U [options] []z@pulls playbooks from a VCS repo and executes them on target host)usagedescargsz Playbook(s)r*)helpmetavarnargsz--purgeF store_truez!purge checkout after playbook run)defaultactionr-z-oz--only-if-changed ifchangedz8only run the playbook if the repository has been updated)destr1r2r-z-sz--sleepsleepNz|sleep for random interval (between 0 and n number of seconds) before starting. This is a useful way to disperse git requests)r4r1r-z-fz--forceforcez>',, ' gll0K%&RU\UaUa&ab b == Q((W]]);< $ {{%&YZ Z   d&7&7 7%V]ViViknkskstxuFuFlG'HI I#-- ( Q)*?'--*OPP Qs /F"F<c Ftt| tjj }t j |j dt j djtjtj}tj}djt|||jdd|jddg}|rd|z}nd}d}t j"d dkDr@|d d jt%dt j"d Dcgc]}d c}zz }|j'}|s.d }|dt)j*dtj,zzz }t j"ddk(rdt j"ddt j"d} t j"dr| dt j"dzz } t j"dr| dz } t j"dr| dt j"dzz } t j"dr| dz } t j"dr| dz } t j"d s| d!z } nt j"dd"k(rqd#t j"ddt j"d} t j"dr| d$t j"dzz } t j"d s| d%z } nt j"dd&k(rWd#t j"ddt j"d} t j"dr| d$t j"dzz } nt j"dd'k(rWdt j"ddt j"d} t j"drU| dt j"dzz } n;t/d(t j"dd)dj|j0t j"d*r| d+z } t3j4t j"d} | t/d-t j"dzt6j8j;t6j8j=tjd} | d.|d|d/t j"dd0| d1|d2 } t j"d3D]} | d4t)j*| zz } t j"d5rOt j d6t j"d5zt?j@t j"d5t jCd7t jEd8| ztG| d9:\}}}|dk7r+t j"d;rt jId<n/|St j"d=rd>|vrt j d?y|jKt j"d}| t/d@| dA|d|} t j"dBr t j"dBD] }| dC|zz } t j"dDr t j"dDD] }| dE|zz } t j"dFr| dGt j"dFzz } t j"dHr| dIt j"dHzz } t j"d3D]} | d4t)j*| zz } t j"dJr| dKz } t j"dLr1| dMtMdjt j"dLzz } t j"dNr1| dOtMdjt j"dNzz } t j"dPr| dQt j"dPzz } n| dQ|zz } t j"dRr| dSz } t j"dTr| dUz } t7jNt j"d|j'}|r| |z } t jCdVt jCd8| ztG| d9:\}}}t j"dWrgt7jNdX t jCdYt j"dztQjRt j"d|S|Scc}w#tT$r@}t jWdZt j"dd[tY|Yd,}~|Sd,}~wwxYw)\z! use Runner lib to do SSH things zStarting Ansible Pull at %F %T rr=rzlocalhost,%s,127.0.0.1zlocalhost,127.0.0.1z -c local raz -%srvz -i localhost, z-e %s zansible_python_interpreter=%sr<rzname=r8z dest=r4r:z version=%sr;z accept_hostkey=yesprivate_key_filez key_file=%sr>z verify_commit=yesr@z track_submodules=yesr9z depth=1rzrepo=z revision=%sz export=yesrrz Unsupported (z$) SCM module for pull, choices are: r?z force=yesNzmodule '%s' not found. z /ansible z -m z -a "z " all -l "" extra_varsz -e %sr5zSleeping for %d seconds...z0running ansible with VCS module to checkout repozEXEC: %sT)liver6zFUnable to update repository. Continuing with (forced) run of playbook.r3s"changed": truez%Repository has not changed, quitting.z!Could not find a playbook to run.z/ansible-playbook vault_password_filesz --vault-password-file=%s vault_idsz --vault-id=%sbecome_password_filez --become-password-file=%sconnection_password_filez --connection-password-file=%sbecome_ask_passz --ask-become-pass skip_tagsz --skip-tags "%s"tagsz -t "%s"subsetz -l "%s"rAz -CrBz -Dz*running ansible-playbook to do actual workpurge/z removing: %szFailed to remove : )-rCrrundatetimenowrbstrftimersysargvplatformnoderYrZsetsplitrrranger&shlexquote executablerrQr find_pluginr r!dirnameabspathtimer5debugvvvvr warningselect_playbookr chdirshutilrmtree Exceptionerrorr )rTr{rhost hostnames limit_opts base_optsxr# repo_optsr!bin_pathcmdevrcb_outb_errplaybookvault_password_filevault_iderUs r%ryz PullCLI.runs gt "##% %EFG*+}}~~HHS$djjoa.@$**S/RSBT!UVW 1I=J.J ??; '! + "''aQ\A]8^*_13*_"`` `I$$&(H 5;;/NQTQ_Q_/_#`` `H ??= )U 2-4__U-CW__U[E\]Iz*]W__Z-HHH 0122 12^goo>P.QQQ x(11 {+44 ??;/Z' __] +| ;-4__U-CW__U[E\]Iz*^gooj.III ??;/]* __] +t 3-4__U-CW__U[E\]Iz*^gooj.III __] +u 4-4__U-CW__U[E\]Iz*]W__Z-HHH %)0)G),$2C2C)D'FG G ??7 #  %I(()GH <%'AGOOTaDb'bd d77??277??388A;#?@>FR[>Eoom>\>GU//,/ .B 8ekk"o- -C . ??7 # OO87??7;SS T JJww/ 0  HI Z#%&"3T2E5 7w' hi __[ ).@.M OOC D''(?@  %&IJ J.6y(K ??1 2'.7M'N I#25HHH I ??; '#OOK8 3'(22 3 ??1 2 /'//BX2YY YC ??5 6 3gooF`6aa aC//,/ .B 8ekk"o- -C . ??, - ' 'C ??; ' &499W__[=Y3Z)[[ [C ??6 " : $))GOOF4K*L MM MC ??8 $ : 99 9C : * *C ??7 # 5LC ??6 " 5LC ()$$&  8OC  BC j3&'"3T2E5 ??7 # HHSM b nwv/FFG goof56 r [+`T b GOOFq'A'MI/ ,GGLLt4 )))47MMi9P9PQS9T"UV  +  ,3v; & 12OY3wv'>#??88I.O>>#DWW\\$v 6F'',,tTZZ_Q-?&-HIKggll4)A)ABG{G4 P))"-7!HMMb'2I2I"2M"NO  P & 12Or')__name__ __module__ __qualname____doc__namerPrrQr ARGUMENTSSKIP_INVENTORY_DEFAULTS staticmethodr&rDrXryrr __classcell__)rUs@r%rr#s  D"5L !O "beI #  2Rh:bHr'rc.tj|yN)r cli_executor)r+s r%mainrns r'__main__r)# __future__r ansible.clirrzr rr]rrrYr}ransiblerrRransible.cli.argumentsrrEansible.errorsr+ansible.module_utils.common.text.convertersr r ansible.plugins.loaderr ansible.utils.cmd_functionsr ansible.utils.displayr rbrrrr'r%rss#  "<.J0/) )HcHV  zFr'