| Server IP : 85.193.89.191 / Your IP : 3.144.85.61 Web Server : Apache System : Linux 956367-cx40159.tmweb.ru 3.10.0-1160.105.1.el7.x86_64 #1 SMP Thu Dec 7 15:39:45 UTC 2023 x86_64 User : bitrix ( 600) PHP Version : 8.1.27 Disable Function : NONE MySQL : OFF | cURL : OFF | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /lib/python2.7/site-packages/ansible/plugins/inventory/ |
Upload File : |
�
� �\c @` s d d l m Z m Z m Z e Z d Z d Z d d l Z d d l Z d d l
Z
d d l Z y d d l m
Z
m Z Wn' e k
r� d d l
m
Z
m Z n Xd d l m Z d d l m Z d d l m Z m Z m Z d d l m Z d d
l m Z d d l m Z m Z d d l m Z d d
l! m" Z" d d l# m$ Z$ d d l% m& Z& m' Z' m( Z( d d l) m* Z* d d l+ m, Z, d e* f d � � YZ- e d d d d d g � Z. d e e f d � � YZ/ d e0 f d � � YZ1 d e0 f d � � YZ2 d e0 f d � � YZ3 d S(! i ( t absolute_importt divisiont print_functionsN
name: azure_rm
plugin_type: inventory
short_description: Azure Resource Manager inventory plugin
extends_documentation_fragment:
- azure
description:
- Query VM details from Azure Resource Manager
- Requires a YAML configuration file whose name ends with 'azure_rm.(yml|yaml)'
- By default, sets C(ansible_host) to the first public IP address found (preferring the primary NIC). If no
public IPs are found, the first private IP (also preferring the primary NIC). The default may be overridden
via C(hostvar_expressions); see examples.
options:
plugin:
description: marks this as an instance of the 'azure_rm' plugin
required: true
choices: ['azure_rm']
include_vm_resource_groups:
description: A list of resource group names to search for virtual machines. '\*' will include all resource
groups in the subscription.
default: ['*']
include_vmss_resource_groups:
description: A list of resource group names to search for virtual machine scale sets (VMSSs). '\*' will
include all resource groups in the subscription.
default: []
fail_on_template_errors:
description: When false, template failures during group and filter processing are silently ignored (eg,
if a filter or group expression refers to an undefined host variable)
choices: [True, False]
default: True
keyed_groups:
description: Creates groups based on the value of a host variable. Requires a list of dictionaries,
defining C(key) (the source dictionary-typed variable), C(prefix) (the prefix to use for the new group
name), and optionally C(separator) (which defaults to C(_))
conditional_groups:
description: A mapping of group names to Jinja2 expressions. When the mapped expression is true, the host
is added to the named group.
hostvar_expressions:
description: A mapping of hostvar names to Jinja2 expressions. The value for each host is the result of the
Jinja2 expression (which may refer to any of the host's existing variables at the time this inventory
plugin runs).
exclude_host_filters:
description: Excludes hosts from the inventory with a list of Jinja2 conditional expressions. Each
expression in the list is evaluated for each host; when the expression is true, the host is excluded
from the inventory.
default: []
batch_fetch:
description: To improve performance, results are fetched using an unsupported batch API. Disabling
C(batch_fetch) uses a much slower serial fetch, resulting in many more round-trips. Generally only
useful for troubleshooting.
default: true
default_host_filters:
description: A default set of filters that is applied in addition to the conditions in
C(exclude_host_filters) to exclude powered-off and not-fully-provisioned hosts. Set this to a different
value or empty list if you need to include hosts in these states.
default: ['powerstate != "running"', 'provisioning_state != "succeeded"']
s}
# The following host variables are always available:
# public_ipv4_addresses: all public IP addresses, with the primary IP config from the primary NIC first
# public_dns_hostnames: all public DNS hostnames, with the primary IP config from the primary NIC first
# private_ipv4_addresses: all private IP addressses, with the primary IP config from the primary NIC first
# id: the VM's Azure resource ID, eg /subscriptions/00000000-0000-0000-1111-1111aaaabb/resourceGroups/my_rg/providers/Microsoft.Compute/virtualMachines/my_vm
# location: the VM's Azure location, eg 'westus', 'eastus'
# name: the VM's resource name, eg 'myvm'
# powerstate: the VM's current power state, eg: 'running', 'stopped', 'deallocated'
# provisioning_state: the VM's current provisioning state, eg: 'succeeded'
# tags: dictionary of the VM's defined tag values
# resource_type: the VM's resource type, eg: 'Microsoft.Compute/virtualMachine', 'Microsoft.Compute/virtualMachineScaleSets/virtualMachines'
# vmid: the VM's internal SMBIOS ID, eg: '36bca69d-c365-4584-8c06-a62f4a1dc5d2'
# vmss: if the VM is a member of a scaleset (vmss), a dictionary including the id and name of the parent scaleset
# sample 'myazuresub.azure_rm.yaml'
# required for all azure_rm inventory plugin configs
plugin: azure_rm
# forces this plugin to use a CLI auth session instead of the automatic auth source selection (eg, prevents the
# presence of 'ANSIBLE_AZURE_RM_X' environment variables from overriding CLI auth)
auth_source: cli
# fetches VMs from an explicit list of resource groups instead of default all (- '*')
include_vm_resource_groups:
- myrg1
- myrg2
# fetches VMs from VMSSs in all resource groups (defaults to no VMSS fetch)
include_vmss_resource_groups:
- '*'
# places a host in the named group if the associated condition evaluates to true
conditional_groups:
# since this will be true for every host, every host sourced from this inventory plugin config will be in the
# group 'all_the_hosts'
all_the_hosts: true
# if the VM's "name" variable contains "dbserver", it will be placed in the 'db_hosts' group
db_hosts: "'dbserver' in name"
# adds variables to each host found by this inventory plugin, whose values are the result of the associated expression
hostvar_expressions:
my_host_var:
# A statically-valued expression has to be both single and double-quoted, or use escaped quotes, since the outer
# layer of quotes will be consumed by YAML. Without the second set of quotes, it interprets 'staticvalue' as a
# variable instead of a string literal.
some_statically_valued_var: "'staticvalue'"
# overrides the default ansible_host value with a custom Jinja2 expression, in this case, the first DNS hostname, or
# if none are found, the first public IP address.
ansible_host: (public_dns_hostnames + public_ipv4_addresses) | first
# places hosts in dynamically-created groups based on a variable value.
keyed_groups:
# places each host in a group named 'tag_(tag name)_(tag value)' for each tag on a VM.
- prefix: tag
key: tags
# places each host in a group named 'azure_loc_(location name)', depending on the VM's location
- prefix: azure_loc
key: location
# places host in a group named 'some_tag_X' using the value of the 'sometag' tag on a VM as X, and defaulting to the
# value 'none' (eg, the group 'some_tag_none') if the 'sometag' tag is not defined for a VM.
- prefix: some_tag
key: tags.sometag | default('none')
# excludes a host from the inventory when any of these expressions is true, can refer to any vars defined on the host
exclude_host_filters:
# excludes hosts in the eastus region
- location in ['eastus']
# excludes hosts that are powered off
- powerstate != 'running'
N( t Queuet Empty( t
namedtuple( t release( t BaseInventoryPlugint
Constructablet Cacheable( t iteritems( t AzureRMAuth( t AnsibleParserErrort AnsibleError( t boolean( t to_native( t chain( t
ServiceClientt
Serializert Deserializer( t AzureConfiguration( t
ARMPollingt AzureRMRestConfigurationc B` s e Z d d � Z RS( c C` s� | d k r t d � � n | d k r6 t d � � n | sE d } n t t | � j | � | j d j t j � � | | _ | | _
d S( Ns) Parameter 'credentials' must not be None.s- Parameter 'subscription_id' must not be None.s https://management.azure.coms ansible-dynamic-inventory/{0}( t Nonet
ValueErrort superR t __init__t add_user_agentt formatR t __version__t credentialst subscription_id( t selfR R t base_url( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyR � s N( t __name__t
__module__R R ( ( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyR � s t UrlActiont urlt api_versiont handlert handler_argst InventoryModulec B` s� e Z d Z d � Z d � Z e d � Z d � Z d d � Z d d � Z
d d � Z d � Z d
� Z
d � Z d � Z d d
� Z d � Z d � Z d � Z d � Z RS( t azure_rmc C` s� t t | � j � t � | _ t � | _ g | _ d | _ d | _
d | _ i d d 6| _ t
� | _ d | _ t | _ d S( Ns
2017-03-30s
2015-06-15s application/json; charset=utf-8s Content-Type( R R) R R t _serializerR t
_deserializert _hostsR t _filterst _compute_api_versiont _network_api_versiont _default_header_parametersR t _request_queuet
azure_autht Falset _batch_fetch( R ( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyR � s c C` s5 t t | � j | � r1 t j d | � r1 t Sn t S( s�
:param loader: an ansible.parsing.dataloader.DataLoader object
:param path: the path to the inventory config file
:return the contents of the config file
s .{0,}azure_rm\.y(a)?ml$( R R) t verify_filet ret matcht TrueR4 ( R t path( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyR6 � s c C` s� t t | � j | | | � | j | � | j d � | _ | j d � | j d � | _ y | j � | j � Wn t k
r� } � n Xd S( Nt batch_fetcht exclude_host_filterst default_host_filters(
R R) t parset _read_config_datat
get_optionR5 R. t _credential_setupt
_get_hostst Exception( R t inventoryt loaderR: t cachet ex( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyR> � s
c C` s t d | j d � d | j d � d | j d � d | j d � d | j d � d | j d � d | j d � d | j d � d | j d � d
| j d
� d | j d � d | j d � � } t | � | _ t | j j | j j | j j j j � | _
t | j
j | j
� | _
d S(
Nt auth_sourcet profileR t client_idt secrett tenantt ad_usert passwordt cloud_environmentt cert_validation_modet api_profilet adfs_authority_url( t dictR@ R R3 R t azure_credentialsR t _cloud_environmentt endpointst resource_managert
_clientconfigR R t _client( R t auth_options( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyRA � s" c
C` s> | s i } n | j j t d | d | d | d | � � d S( NR% R& R' R( ( R2 t
put_nowaitR$ ( R R% R& R' R( ( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyt _enqueue_get s t *c C` sf | s | d k r d } n d } | j d | j j d | � } | j d | d | j d | j � d S( NR] sK /subscriptions/{subscriptionId}/providers/Microsoft.Compute/virtualMachiness_ /subscriptions/{subscriptionId}/resourceGroups/{rg}/providers/Microsoft.Compute/virtualMachinest subscriptionIdt rgR% R& R' ( R RX R R\ R/ t _on_vm_page_response( R R_ R% ( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyt _enqueue_vm_list
s
c C` sf | s | d k r d } n d } | j d | j j d | � } | j d | d | j d | j � d S( NR] sS /subscriptions/{subscriptionId}/providers/Microsoft.Compute/virtualMachineScaleSetssg /subscriptions/{subscriptionId}/resourceGroups/{rg}/providers/Microsoft.Compute/virtualMachineScaleSetsR^ R_ R% R& R' ( R RX R R\ R/ t _on_vmss_page_response( R R_ R% ( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyt _enqueue_vmss_list s
c C` s� x$ | j d � D] } | j | � q Wx$ | j d � D] } | j | � q7 W| j rd | j � n
| j � t | j d � � } | j d � } | j d � } | j d � } x | j D] } | j | � } | j | | j
� r� q� n | j j | � | j j
| d t t | j
d | j
d � d � � x3 t | j
� D]" \ } }
| j j
| | |
� q@W| j | | j
| d
| �| j | | j
| d
| �| j | | j
| d
| �q� Wd S( Nt include_vm_resource_groupst include_vmss_resource_groupst fail_on_template_errorst hostvar_expressionst conditional_groupst keyed_groupst ansible_hostt public_ipv4_addressest private_ipv4_addressest strict( R@ Ra Rc R5 t _process_queue_batcht _process_queue_serialR R- t
_get_hostnamet _filter_hostt hostvarsRD t add_hostt set_variablet nextR R R
t _set_composite_varst _add_host_to_composed_groupst _add_host_to_keyed_groups( R t vm_rgt vmss_rgt constructable_config_strictt constructable_config_composet constructable_config_groupst! constructable_config_keyed_groupst ht inventory_hostnamet kt v( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyRB s.
' c C` s� | j j | � x� | j D]� } d j | � } y t | j j | � � rN t SWq t k
r� } t | j d � � r t d j | | t
| � � � � q q q Xq Wt S( Ns4 {{% if {0} %}} True {{% else %}} False {{% endif %}}Rf s9 Error evaluating filter condition '{0}' for host {1}: {2}( t templart set_available_variablesR. R R t templateR9 RC R@ R R R4 ( R R� Rr t conditiont conditionalt e( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyRq ? s $ c C` s | j S( N( t default_inventory_hostname( R t host( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyRp O s c C` sc yK xD t rI | j j � } | j | j | j � } | j | | j � q WWn t k
r^ n Xd S( N( R9 R2 t
get_nowaitt send_requestR% R& R' R( R ( R t itemt resp( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyRo S s
c C` s� | j d � } | r: | j d | d | j d | j � n d | k r} x4 | d D]% } | j j t | | d | �� qQ Wn d S( Nt nextLinkR% R& R' t valuet vmss( t getR\ R/ R` R- t appendt AzureHost( R t responseR� t next_linkR ( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyR` \ s % c C` s� | j d � } | r: | j d | d | j d | j � n xV | d D]J } d j | d � } | j d | d | j d | j d t d | � � qE Wd S(
NR� R% R& R' R� s {0}/virtualMachinest idR( R� ( R� R\ R/ Rb R R` RS ( R R� R� R� R% ( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyRb g s %c C` s� x�t r�g } d } t � } y� x� | d k r� | j j � } t t j � � } i | j d 6} | j j | j
| � } | j t d d d | j
d | � � | | | <| d 7} q$ WWn t k
r� n X| s� Pn | j
| � } d } d | k r� d } n! d
| k rd
} n t d � � x� t | | � D]p \ }
} | j d � } | d }
| |
} | d
k r�t d j | | j
� � � n | j | d | j � q1Wq Wd S( Ni id s api-versiont
httpMethodt GETR% t namei t responsesR� s: didn't find expected key responses/value in batch responset httpStatusCodei� s6 a batched request failed with status code {0}, url {1}t content( R9 RS R2 R� t strt uuidt uuid4R& RY R� R% R� R t _send_batchR R
t enumerateR R' R( ( R t batch_requestst batch_item_indext batch_response_handlersR� R� t query_parameterst reqt
batch_respt key_namet idxt rt status_codet
returned_namet result( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyRn u s> %
c
` s� d } i d d 6} t d | � } � j j | d � } i t t j � � d 6} | j � j � � j j | | � } � j j
| | | � } t d d � } | j d � j d
| d � f d � � | j
� | j � S(
Ns /batchs
2015-11-01s api-versiont requestst objects x-ms-client-request-idt timeouti t clientt initial_responset deserialization_callbackc ` s � j d | � S( NR� ( R, ( R� ( R ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyt <lambda>� s ( RS R+ t bodyR� R� R� t updateR1 RY t postt sendR t
initializet runt resource(
R t batched_requestsR% R� t body_objt body_contentt headert requestR� t poller( ( R sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyR� � s
c C` s` i | d 6} | j j | | � } | j j | | j d t �} | j � | j } t j | � S( Ns api-versiont stream( RY R� R� R1 R4 t raise_for_statusR� t jsont loads( R R% R& R� R� R� R� ( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyR� � s
N( R" R# t NAMER R6 R9 R> RA R R\ Ra Rc RB Rq Rp Ro R` Rb Rn R� R� ( ( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyR) � s" # ) R� c B` sG e Z e j d � Z d d � Z e d � � Z d � Z e
d � Z RS( s ^PowerState/(?P<powerstate>.+)$c C` s- | | _ | | _ | | _ d | _ d | _ g | _ d j | d t j | d � j
� d d !� | _ i | _ | j
d d j | d � d | j j d
| j � | d d d
} xp | D]h } | j d i � j d t | � d k � } | j
d | d d | j j d
| j d t d | � � q� Wd S( Nt unknowns {0}_{1}R� R� i i R% s {0}/instanceViewR& R' t
propertiest networkProfilet networkInterfacest primaryi R( t
is_primary( t _inventory_clientt _vm_modelt _vmssR t
_instanceviewt _powerstatet nicsR t hashlibt sha1t hexdigestR� t _hostvarsR\ R/ t _on_instanceview_responseR� t lenR0 t _on_nic_responseRS ( R t vm_modelt inventory_clientR� t nic_refst nicR� ( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyR � s" 3
* c C` s | j i k r | j St d g d g d g d | j d d | j d d | j d d | j d | j d d
j � d | j j d i � d | j j d
d � d | j d d d | j r� t d | j d d | j d � n i � } xt | j d d � d t �D]� } x� t | j
d d d d � d t �D]� } | d j d � } | rd| d j | � n | d j d i � j d � } | r1| j | } | d j | j
d j d d � � | j
d j d i � j d � } | r�| d j | � q�q1q1WqW| | _ | j S( NRk t public_dns_hostnamesRl R� t locationR� t
powerstatet provisioning_stateR� t provisioningStatet tagst
resource_typet typeR� t vmidt vmIdR� t keyc S` s | j S( N( R� ( t n( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyR� � s t reverset ipConfigurationsc S` s | d d S( NR� R� ( ( t i( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyR� � s t privateIPAddresst publicIPAddresst ipAddresst dnsSettingst fqdn( R� RS R� R� t lowerR� R� t sortedR� R9 t
_nic_modelR� t
public_ipst
_pip_modelR ( R t new_hostvarsR� t ipct
private_ipt pip_idt pipt pip_fqdn( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyRr � s:
5%-
$" c ` s; | � _ t � f d � | j d g � D� d � � _ d S( Nc 3` sT | ]J } � j j | j d d � � r � j j | j d d � � j d � Vq d S( t codet R� N( t _powerstate_regexR8 R� t group( t .0t s( R ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pys <genexpr> s t statusesR� ( R� Ru R� R� ( R t vm_instanceview_model( ( R sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyR� s c C` sJ | j d � d k rF t d | d | j d | � } | j j | � n d S( NR� s# Microsoft.Network/networkInterfacest nic_modelR� R� ( R� t AzureNicR� R� R� ( R R R� R� ( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyR� s N( R" R# R7 t compileR R R t propertyRr R� R4 R� ( ( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyR� � s
* R c B` s e Z e d � Z d � Z RS( c C` s� | | _ | | _ | | _ i | _ x^ | d d D]N } | d j d � } | r3 | j j d | d d | j j d | j � q3 q3 Wd S( NR� R� R� R% R� R& R' ( R� R� R� R� R� R\ R0 t _on_pip_response( R R R� R� R� R� ( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyR s c C` s t | � | j | d <d S( NR� ( t AzurePipR� ( R t pip_model( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyR
$ s ( R" R# R4 R R
( ( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyR s R c B` s e Z d � Z RS( c C` s
| | _ d S( N( R� ( R R ( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyR ) s ( R" R# R ( ( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyR ( s (4 t
__future__R R R R� t
__metaclass__t
DOCUMENTATIONt EXAMPLESR� R� R7 R� t queueR R t ImportErrort collectionsR t ansibleR t ansible.plugins.inventoryR R R t ansible.module_utils.sixR
t$ ansible.module_utils.azure_rm_commonR t ansible.errorsR R
t) ansible.module_utils.parsing.convert_boolR t ansible.module_utils._textR t itertoolsR t msrestR R R t msrestazureR t msrestazure.polling.arm_pollingR R R$ R) R� R� R R ( ( ( sF /usr/lib/python2.7/site-packages/ansible/plugins/inventory/azure_rm.pyt <module> s< :J
� S