관리-도구
편집 파일: __init__.cpython-39.pyc
a �)g�P � @ s: d dl mZmZmZ eZd dlZd dlZd dlZd dl m Z d dl m Z m Z d dlmZ d dlmZ d dlmZ d dlmZ d d lmZmZ d d lm Z d d l m Z d d l m Z d d l!m"Z" d dl#m$Z$m%Z% e"� Z&dd� Zd dd�Z'd dd�Z(dd� Z)G dd� de�Z*G dd� de*�Z+G dd � d e,�Z-G d d � d e,�Z.dS )!� )�absolute_import�division�print_functionN)�Mapping)� AnsibleError�AnsibleParserError)�to_safe_group_name)� parse_address)� AnsiblePlugin)�CachePluginAdjudicator)�to_bytes� to_native)�boolean)� string_types)�Templar)�Display)� combine_vars�load_extra_varsc C s t | ddd�S )NT)�forceZsilent)� original_safe)�name� r �F/usr/lib/python3.9/site-packages/ansible/plugins/inventory/__init__.pyr , s r c C s d| v S )z� A helper function that checks a given host line to see if it contains a range pattern described in the docstring above. Returns True if the given line contains a pattern, else False. �[r )�liner r r � detect_range1 s r c s� g }| �r�| � ddd�� ddd��d�\}}}|�d�}t|�dkrXt|�dkrXtd��|d }|d }t|�dkrzd}n|d }|s�d }|s�td ��|d d kr�t|�dkr�t|�� � t|�kr�td ��� fd d�} nt} zJtj�|�} tj�|�} | | k�rtd��ttj| | d t |�� �} W n0 t �yV t t |�t |�d t |��} Y n0 | D ]>} d� || | �|f�}t |��r�|�t|�� n |�|� �q\|S dS )a� A helper function that expands a given line that contains a pattern specified in top docstring, and returns a list that consists of the expanded version. The '[' and ']' characters are used to maintain the pseudo-code appearance. They are replaced in this function with '|' to ease string splitting. References: https://docs.ansible.com/ansible/latest/user_guide/intro_inventory.html#hosts-and-groups r �|� �]�:� � z.host range must be begin:end or begin:end:stepr �0z!host range must specify end valuez:host range must specify equal-length begin and end formatsc s t | ��� �S �N)�str�zfill)�x�Zrlenr r �filli s z#expand_hostname_range.<locals>.fillz!host range must have begin <= end� N)�replace�split�lenr r$ �string� ascii_letters�index�list�int� ValueError�range�joinr �extend�expand_hostname_range�append)r Z all_hosts�headZnrange�tailZboundsZbeg�end�stepr( Zi_begZi_end�seqZrseqZhnamer r' r r6 ; sF $ " r6 c K s� zt | fi |��}W nB tyV } z*dt|�v r>td| ��n|�W Y d }~n d }~0 0 | dkr�|r�t|jdd �s�td�| ���|S )NZfact_caching_connectiona error, '%s' inventory cache plugin requires the one of the following to be set to a writeable directory path: ansible.cfg: [default]: fact_caching_connection, [inventory]: cache_connection; Environment: ANSIBLE_INVENTORY_CACHE_CONNECTION, ANSIBLE_CACHE_PLUGIN_CONNECTION.Zmemory�_optionsz�Unable to use cache plugin {0} for inventory. Cache options were provided but may not reconcile correctly unless set via set_options. Refer to the porting guide if the plugin derives user settings from ansible.constants.)� CacheObjectr r �getattrZ_plugin�format)� plugin_name�kwargs�cache�er r r �get_cache_plugin� s ��rE c s` e Zd ZdZdZee�Z� fdd�Zddd�Z dd � Z dd d �Z d d� Z dd� Z dd� Z� ZS )�BaseInventoryPluginz Parses an Inventory Source� generatorc s* t t| ��� i | _d | _t| _i | _d S r# )�superrF �__init__r= � inventory�display�_vars��self�� __class__r r rI � s z BaseInventoryPlugin.__init__Tc C s& || _ || _t|d�| _t|�| _dS )az Populates inventory from the given data. Raises an error on any parse failure :arg inventory: a copy of the previously accumulated inventory data, to be updated with any new data this plugin provides. The inventory can be empty if no other source/plugin ran successfully. :arg loader: a reference to the DataLoader, which can read in YAML and JSON files, it also has Vault support to automatically decrypt files. :arg path: the string that represents the 'inventory source', normally a path to a configuration file for this inventory, but it can also be a raw string for this plugin to consume :arg cache: a boolean that indicates if the plugin should use the cache or not you can ignore if this plugin does not implement caching. )�loaderN)rQ rJ r �templarr rL )rN rJ rQ �pathrC r r r �parse� s zBaseInventoryPlugin.parsec C s@ d}t |dd�}tj�|�r0t�|tj�r0d}n | j�d� |S )a� Verify if file is usable by this plugin, base does minimal accessibility check :arg path: a string that was passed as an inventory source, it normally is a path to a config file, but this is not a requirement, it can also be parsed itself as the inventory data to process. So only call this base class if you expect it to be a file. F�surrogate_or_strict��errorsTzWSkipping due to inventory source not existing or not being readable by the current user)r �osrS �exists�access�R_OKrK Zvvv)rN rS Zvalid�b_pathr r r � verify_file� s z BaseInventoryPlugin.verify_fileNc C sX t |t�stdt|� ��|D ]4}| jj|||d� |D ]}| j�|||| � q8q d S )Nz8Invalid data from file, expected dictionary and got: %s)�group�port)� isinstancer r r rJ �add_host� set_variable)rN �hosts� variablesr^ r_ �host�kr r r �_populate_host_vars� s z'BaseInventoryPlugin._populate_host_varsc s i }z� j j|dd�}W n0 tyH } ztt|���W Y d}~n d}~0 0 t� d�pZ� jg}|srtdt|� ��n>|�d�|vr�td|�dd� ��nt|t �s�td t |� ��� j |� j d � d � j v �r� �d ��rg d �}t� fd d�|D ��}t� �d�fi |��� _|S )z� validate config and set options as appropriate :arg path: path to common yaml format config file for this plugin F)rC NZ_redirected_namesz %s is emptyZpluginz!Incorrect plugin name in file: %sz none foundzJinventory source has invalid structure, it should be a dictionary, got: %s)ZdirectZ var_optionsrC �)Z_uriZcache_connection)�_timeoutZ cache_timeout)�_prefixZ cache_prefixc 3 s6 | ].}� � |d �dur|d � � |d �fV qdS �r Nr �� get_option��.0�optrM r r � <genexpr>� � z8BaseInventoryPlugin._read_config_data.<locals>.<genexpr>� cache_plugin)rQ Zload_from_file� Exceptionr r r? �NAME�getr` r �typeZ set_optionsrL r= rm �dictrE �_cache)rN rS ZconfigrD Z valid_names�cache_option_keys� cache_optionsr rM r �_read_config_data� s$ " z%BaseInventoryPlugin._read_config_datac C s( | j D ] }||v r|�|�| j |< qdS )a< update existing options from alternate configuration sources not normally used by Ansible. Many API libraries already have existing configuration sources, this allows plugin author to leverage them. :arg data: key/value pairs that correspond to configuration options for this plugin N)r= �pop)rN �datarf r r r �_consume_options� s z$BaseInventoryPlugin._consume_optionsc C sP zt |dd�\}}W n ty. |}d}Y n0 t|�rBt|�}n|g}||fS )z� Takes a single host pattern and returns a list of hostnames and an optional port number that applies to all of them. T)Z allow_rangesN)r rt r r6 )rN Z hostpattern�patternr_ Z hostnamesr r r �_expand_hostpattern s z'BaseInventoryPlugin._expand_hostpattern)T)NN)�__name__� __module__� __qualname__�__doc__�TYPE� staticmethodr �_sanitize_group_namerI rT r] rg r| r r� � __classcell__r r rO r rF � s " rF c s$ e Zd ZdZdZ� fdd�Z� ZS )�BaseFileInventoryPluginz% Parses a File based Inventory SourceZstoragec s t t| ��� d S r# )rH r� rI rM rO r r rI ! s z BaseFileInventoryPlugin.__init__)r� r� r� r� r� rI r� r r rO r r� s r� c @ sN e Zd Ze� Zedd� �Zdd� Zdd� Zdd� Z d d � Z d d � Z d d� Z dS )� Cacheablec C s | j S r# )ry rM r r r rC * s zCacheable.cachec s> � � d�}g d�}t� fdd�|D ��}t|fi |��� _d S )Nrs rh c 3 s6 | ].}� � |d �dur|d � � |d �fV qdS rk rl rn rM r r rq 1 rr z.Cacheable.load_cache_plugin.<locals>.<genexpr>)rm rx rE ry )rN rA rz r{ r rM r �load_cache_plugin. s zCacheable.load_cache_pluginc C s d� | j| �|��S )Nz{0}_{1})r@ ru �_get_cache_prefix)rN rS r r r � get_cache_key4 s zCacheable.get_cache_keyc C sd t �� }|�t| jdd�� |�� }t �� }|�t|dd�� |�� }d�|dd� |dd� g�S )z7 create predictable unique prefix for plugin/inventory rU rV Zs_N� )�hashlibZsha1�updater ru Z hexdigestr4 )rN rS �mZd1�nZd2r r r r� 7 s zCacheable._get_cache_prefixc C s | j �� d S r# )ry �flushrM r r r � clear_cacheD s zCacheable.clear_cachec C s | j �� d S r# )ry �update_cache_if_changedrM r r r r� G s z!Cacheable.update_cache_if_changedc C s | j �� d S r# )ry Z set_cacherM r r r �set_cache_pluginJ s zCacheable.set_cache_pluginN) r� r� r� r> ry �propertyrC r� r� r� r� r� r� r r r r r� & s r� c @ s4 e Zd Zd dd�Zd dd�Zddd�Zdd d �Zd S )� ConstructableTc C sf | j }z| �d�}W n ty* d}Y n0 |r@t|| j�|_n||_|jd|jj||jj f |d�S )zi helper method for plugins to compose variables for Ansible based on jinja2 expression and inventory varsZuse_extra_varsF�%s%s%s)�disable_lookups) rR rm rt r rL �available_variables�templateZ environmentZvariable_start_stringZvariable_end_string)rN r� rd r� �tZ use_extrar r r �_composeP s �zConstructable._composeFc C s� |r�t |t�r�|D ]t}z| �|| |�}W nJ tyt } z2|rTtd||t|�f ��W Y d}~qW Y d}~n d}~0 0 | j�|||� qdS )z5 loops over compose entries to create vars for hosts z Could not set %s for host %s: %sN)r` rx r� rt r r rJ rb )rN Zcomposerd re �strictZvarnameZ compositerD r r r �_set_composite_varsa s "z!Constructable._set_composite_varsc C s� |r�t |t�r�|r(t|| j�|��� �}|| j_|D ]�}d|| }| �|�}zt | j� |��}W nJ t y� } z2|r�t d||t | �f ��W Y d} ~ q4W Y d} ~ n d} ~ 0 0 |r4| j�|�}| j�||� q4dS )z} helper to create complex groups for plugins based on jinja2 conditionals, hosts that meet the conditional are added to groupz3{%% if %s %%} True {%% else %%} False {%% endif %%}z%Could not add host %s to group %s: %sN)r` rx r rJ �get_host�get_varsrR r� r� r r� rt r r � add_group� add_child) rN �groupsrd re r� �fetch_hostvarsZ group_nameZ conditional�resultrD r r r � _add_host_to_composed_groupsm s " z*Constructable._add_host_to_composed_groupsc C s> |�r:t |t��r:|D �] }|�r,t |t��r,|rHt|| j�|��� �}z| �|�d�|�}W nP t y� } z8|r�t d||�d�t |�f ��W Y d}~qW Y d}~n d}~0 0 |�dd�} |�d�} | dur�| dur�t d��|s�|dk�r | du�r |�dd�} |�d d �} |�d d�} | �r�z| j � | �} W nN t�y~ } z4|�r^t d | |t |�f ��W Y d}~qW Y d}~n d}~0 0 g }t |t��r�|dk�r�| du�r�|�| � n |�|� n�t |t��r |D ]0}|dk�r�| du�r�|�| � n |�|� �q�n|t |t��rl|�� D ]T\}}d || |f }|dk�r\| du�rNd || | f }n| du �r\|}|�|� �qnt dt|� ��|D ]|}| dk�r�| �d�du �r�d} | �d | | |f �}| j�|�}| j�||� | �r�| �| �}| j�|� | j�||� �q�n*|�r8|g i fv�r8t d|�d�|f ��qt d| ��qdS )zc helper to create groups for plugins based on variable values and add the corresponding hosts to it�keyz6Could not generate group for host %s from %s entry: %sNZ default_value�trailing_separatorzTparameters are mutually exclusive for keyed groups: default_value|trailing_separatorr) �prefix� separator�_Z parent_groupz3Could not generate parent group %s for group %s: %sr� FzUInvalid group name format, expected a string or a list of them or dictionary, got: %sZleading_separatorz=No key or key resulted empty for %s in host %s, invalid entryz7Invalid keyed group entry, it must be a dictionary: %s )r` r0 rx r rJ r� r� r� rv rt r r rR r� r r r7 r �itemsrw rm r� r� ra r� )rN �keysrd re r� r� Zkeyedr� rD Zdefault_value_namer� r� �sepZraw_parent_nameZnew_raw_group_namesr �gnameZgvalZ bare_nameZ result_gname� parent_namer r r �_add_host_to_keyed_groups� sv " " z'Constructable._add_host_to_keyed_groupsN)T)F)FT)FT)r� r� r� r� r� r� r� r r r r r� N s r� )N)N)/Z __future__r r r rw Z __metaclass__r� rX r- �collections.abcr Zansible.errorsr r Zansible.inventory.groupr r Z ansible.parsing.utils.addressesr Zansible.pluginsr Zansible.plugins.cacher r> Zansible.module_utils._textr r Z)ansible.module_utils.parsing.convert_boolr Zansible.module_utils.sixr Zansible.templater Zansible.utils.displayr Zansible.utils.varsr r rK r r6 rE rF r� �objectr� r� r r r r �<module> s4 H (