Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/dns/drivers/__pycache__/rackspace.cpython-39.pyc
Ðазад
a q�h` � @ s d dl Z d dlmZ d dlmZ d dlmZ d dlmZ d dl m Z d dl m Z m Z d dlmZ d d lmZ d d lmZ d d lmZmZ d d lmZmZ d d lmZmZmZ ddgZ g d�Z g d�Z G dd� de�Z G dd� dee�Z G dd� de!�Z"G dd� dee�Z#dd� Z$dd� Z%dS ) � N)�httplib)�OpenStackDriverMixin)�PollingConnection)� BaseHTTPError)� LibcloudError)�merge_valid_keys� get_new_obj)�AUTH_URL)�OpenStack_1_1_Connection)�OpenStack_1_1_Response)�Provider� RecordType)�ZoneDoesNotExistError�RecordDoesNotExistError)� DNSDriver�Zone�Record�RackspaceDNSResponse�RackspaceDNSConnection)�email�commentZns1)�ttlr �priority�created�updatedc @ s e Zd ZdZdd� ZdS )r z' Rackspace DNS Response class. c C s� t | j�}| jj}| �� }|tjkrb|d dkrDtd| |d d��n |d dkrbtd| |d d��|r�d |v r�d |d |d |d f }|S d |v r�d d� |d d D �}dd� |� }|S t d| ��d S )N�resource�zone� �id)�value�driver�zone_id�record)r r � record_id�code�message� %s - %s (%s)�detailsZvalidationErrorsc S s g | ]}|�qS � r( )�.0�mr( r( ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/libcloud/dns/drivers/rackspace.py� <listcomp>@ � z4RackspaceDNSResponse.parse_error.<locals>.<listcomp>�messageszValidation errors: %sz, zUnexpected status code: %s) �int�status� connection�contextZ parse_bodyr � NOT_FOUNDr r �joinr )�selfr0 r2 �body�err�errorsr( r( r+ � parse_error. s. � ��z RackspaceDNSResponse.parse_errorN)�__name__� __module__� __qualname__�__doc__r9 r( r( r( r+ r ) s c sP e Zd ZdZeZdZdZdZe Z dZ � fdd�Z dd � Z d d � Zd d � Z� ZS )r z) Rackspace DNS Connection class. Ng @� �2.0c s( |� dd �| _tt| �j|i |�� d S �N�region)�poprA �superr �__init__)r5 �args�kwargs�� __class__r( r+ rD T s z RackspaceDNSConnection.__init__c C s |j d }d| ddid�}|S )NZjobIdz /status/%sZ showDetailsT��action�params)�object)r5 �responser2 Zrequest_kwargsZjob_idrF r( r( r+ �get_poll_request_kwargsX s �z.RackspaceDNSConnection.get_poll_request_kwargsc C s^ |j d }|dkrV|j d }d|v r@d|d |d |d f }n|d }t|| jd��|d kS ) Nr0 �ERROR�errorr$ r% r& r' �r Z COMPLETED)rL r r )r5 rM r0 �datar% r( r( r+ � has_completed^ s ��z$RackspaceDNSConnection.has_completedc C sb d| j v r | jjddd d�}ntd| j ��|j}| jdkrH|�dd�}| jd kr^|�dd�}|S ) Nr? ZcloudDNSzrax:dns)�nameZ service_typerA z Auth version %s not supported�uszhttps://lon.dns.apizhttps://dns.api�uk)� _auth_versionZservice_catalog� get_endpointr �urlrA �replace)r5 �epZ public_urlr( r( r+ rX n s$ �� � �z#RackspaceDNSConnection.get_endpoint)r: r; r< r= r Z responseClsZ XML_NAMESPACE� poll_interval�timeoutr Zauth_urlrW rD rN rS rX � __classcell__r( r( rG r+ r G s c @ s0 e Zd Zd dd�Zd dd�Zdd� Zdd � ZdS ) �RackspacePTRRecordNc C s: |r t |�nd | _|| _tj| _|| _|| _|p2i | _d S )N) �strr �ipr �PTR�type�domainr �extra)r5 r ra rd r re r( r( r+ rD � s zRackspacePTRRecord.__init__c C s | j j| ||d�S )N)r" rd re )r �ex_update_ptr_record)r5 rd re r( r( r+ �update� s �zRackspacePTRRecord.updatec C s | j j| d�S )N)r" )r �ex_delete_ptr_record�r5 r( r( r+ �delete� s zRackspacePTRRecord.deletec C s d| j j| j| j| jjf S )Nz'<%s: ip=%s, domain=%s, provider=%s ...>)rH r: ra rd r rT ri r( r( r+ �__repr__� s ��zRackspacePTRRecord.__repr__)N)N)r: r; r< rD rg rj rk r( r( r( r+ r_ � s r_ c s$ e Zd ZdZdZejZeZ d=� fdd� Z e j de j d e jd e jd e jd e jd e jde jdiZedd� �Zdd� Zdd� Zdd� Zdd� Zd>dd �Zd?d d �Z d@d d �Z dAd!d"�Z d#d$� Z d%d&� Z d'd(� Z!d)d*� Z"dBd+d,�Z#dCd-d.�Z$d/d0� Z%d1d2� Z&d3d4� Z'd5d6� Z(d7d8� Z)d9d:� Z*d;d<� Z+� Z,S )D�RackspaceDNSDriverz Rackspace DNSzhttp://www.rackspace.com/NTrU c sL | � � }||vr td| ��tj| fi |�� tt| �j|||||d� d S )NzInvalid region: %s)�key�secret�host�portrA )� list_regions� ValueErrorr rD rC rl ) r5 rm rn �securero rp rA rF Z valid_regionsrG r( r+ rD � s �zRackspaceDNSDriver.__init__�A�AAAA�CNAME�MX�NSrb �SRV�TXTc C s ddgS )NrU rV r( )�clsr( r( r+ rq � s z RackspaceDNSDriver.list_regionsc c sd d}d}||d�}| j jd|d�j}|d }|D ]}| �|�V q0t|t|�|�r`||7 }qq`qd S )Nr �d )�limit�offset�/domainsrI �domains)r1 �requestrL �_to_zone�_rackspace_result_has_more�len)r5 r~ r} rK rM Z zones_list�itemr( r( r+ � iterate_zones� s �� z RackspaceDNSDriver.iterate_zonesc c s� | j �d|jd�� d}d}d||d�}| j jd|j |d�j}|d }|d }|D ]}| j||d �} | V qTt|t|�|�r�||7 }q q�q d S ) Nr �r r r r| T)Z showRecordr} r~ � /domains/%srI � recordsList�records�rR r )r1 � set_contextr r� rL � _to_recordr� r� ) r5 r r~ r} rK rM Z records_listr� r� r" r( r( r+ �iterate_records� s$ � � z"RackspaceDNSDriver.iterate_recordsc C s6 | j �d|d�� | j jd| d�}| j|jd�}|S )Nr r� r� �rJ �rR )r1 r� r� r� rL )r5 r! rM r r( r( r+ �get_zone� s zRackspaceDNSDriver.get_zonec C sH | j |d�}| j�d|d�� | jjd||f d�j}| j||d�}|S )N)r! r" r� �/domains/%s/records/%sr� r� )r� r1 r� r� rL r� )r5 r! r# r rM r" r( r( r+ � get_record� s � z RackspaceDNSDriver.get_record�masterc C s� |r|ni }d|vr t d��||d dg id�}|r<||d< d|v rP|d |d< d|gi}| jjdd |d �}| j|jd d d d �}|S )Nr z/"email" key must be present in extra dictionaryr� )rT � emailAddressr� r r r� r �POST�rJ �methodrR rM r r� )rr r1 � async_requestr� rL ) r5 rd rc r re �payloadrR rM r r( r( r+ � create_zone� s � �z RackspaceDNSDriver.create_zonec C s� |r|ni }|r t d| d��i }|r0t|�|d< d|v rD|d |d< d|v rX|d |d< |r`|n|j}|rn|n|j}| j�d|jd�� | jjd |j d |d � tt � |j �t |d �}t |t|||d �d�}|S )NzDomain cannot be changedrQ r r r� r r r� r� �PUTr� �rK Z valid_keysre )rc r re ��obj�klass� attributes)r r/ rc r r1 r� r r� r �copy�deepcopyre �VALID_ZONE_EXTRA_PARAMSr r ) r5 r rd rc r re rR �mergedZ updated_zoner( r( r+ � update_zone s6 � ���z RackspaceDNSDriver.update_zonec C s� |r|ni }| j |j|d�}|| j| |d�}d|v rFt|d �|d< d|v r^t|d �|d< d|gi}| j�d|jd�� | jjd|j |d d �j}| j |d d d |d �}|S )N�rd rT �rT rc rR r r r� r r� z/domains/%s/recordsr� )rJ rR r� rM r r� ) �_to_full_record_namerd �RECORD_TYPE_MAPr/ r1 r� r r� rL r� ) r5 rT r rc rR re r� rM r" r( r( r+ � create_record, s* � ���z RackspaceDNSDriver.create_recordc C s� |r|ni }| j |jj|jd�}d|i}|r4||d< d|v rH|d |d< d|v r\|d |d< |d urh|n|j}|rv|n|j}| j�d|jd�� | jj d|jj|jf d |d � t t � |j �t|d �}t|t||| |d �d �}|S )Nr� rT rR r r r" r� r� r� r� r� )rc rR r re r� )r� r rd rT rc rR r1 r� r r� r r� r� re �VALID_RECORD_EXTRA_PARAMSr r ) r5 r" rT rc rR re r� r� Zupdated_recordr( r( r+ � update_recordD s> � �� ���z RackspaceDNSDriver.update_recordc C s. | j �d|jd�� | j jd|j dd� dS )Nr r� r� �DELETE�rJ r� T)r1 r� r r� )r5 r r( r( r+ � delete_zonei s �z RackspaceDNSDriver.delete_zonec C s6 | j �d|jd�� | j jd|jj|jf dd� dS )Nr" r� r� r� r� T)r1 r� r r� r �r5 r" r( r( r+ � delete_recordo s ��z RackspaceDNSDriver.delete_recordc c s� t |� d|jd i}|jd }| j�ddi� zR| jjd| |d�j}|d }tf d |i|��}|D ]}| j||d �}|V qfW n> ty� } z&| j d kr�W Y d } ~ d S � W Y d } ~ n d } ~ 0 0 d S ) a� Return a generator to iterate over existing PTR Records. The ``device`` should be an instance of one of these: :class:`libcloud.compute.base.Node` :class:`libcloud.loadbalancer.base.LoadBalancer` And it needs to have the following ``extra`` fields set: service_name - the service catalog name for the device uri - the URI pointing to the GET endpoint for the device Those are automatically set for you if you got the device from the Rackspace driver for that service. For example: server = rs_compute.ex_get_node_details(id) ptr_iter = rs_dns.ex_list_ptr_records(server) loadbalancer = rs_lbs.get_balancer(id) ptr_iter = rs_dns.ex_list_ptr_records(loadbalancer) Note: the Rackspace DNS API docs indicate that the device 'href' is optional, but testing does not bear this out. It throws a 400 Bad Request error if you do not pass in the 'href' from the server or loadbalancer. So ``device`` is required. :param device: the device that owns the IP :rtype: ``generator`` of :class:`RackspacePTRRecord` �href�uri� service_namer Z ptr_records�/rdns/%srI r� �rel�rR �linki� N) �_check_ptr_extra_fieldsre r1 r� r� rL �dict�_to_ptr_recordr r$ ) r5 �devicerK r� rM r� r� r� r" �excr( r( r+ �ex_iterate_ptr_recordsv s" � z)RackspaceDNSDriver.ex_iterate_ptr_recordsc C sP | j �d|d�� | j jd||f d�j}tt|d d ��}| j||d d�S ) aK Get a specific PTR record by id. :param service_name: the service catalog name of the linked device(s) i.e. cloudLoadBalancers or cloudServersOpenStack :param record_id: the id (i.e. PTR-12345) of the PTR record :rtype: instance of :class:`RackspacePTRRecord` r" r� z /rdns/%s/%sr� r� r� r� r� )r1 r� r� rL �next�iterr� )r5 r� r# rM r� r( r( r+ �ex_get_ptr_record� s �z$RackspaceDNSDriver.ex_get_ptr_recordc C s� t |� |du ri }|tj|d�}d|v r6|d |d< d|gid|jd |jd d�d �}| jjd d |d �j}tt|d d ��}| j ||d d�S )a� Create a PTR record for a specific IP on a specific device. The ``device`` should be an instance of one of these: :class:`libcloud.compute.base.Node` :class:`libcloud.loadbalancer.base.LoadBalancer` And it needs to have the following ``extra`` fields set: service_name - the service catalog name for the device uri - the URI pointing to the GET endpoint for the device Those are automatically set for you if you got the device from the Rackspace driver for that service. For example: server = rs_compute.ex_get_node_details(id) rs_dns.create_ptr_record(server, ip, domain) loadbalancer = rs_lbs.get_balancer(id) rs_dns.create_ptr_record(loadbalancer, ip, domain) :param device: the device that owns the IP :param ip: the IP for which you want to set reverse DNS :param domain: the fqdn you want that IP to represent :param extra: a ``dict`` with optional extra values: ttl - the time-to-live of the PTR record :rtype: instance of :class:`RackspacePTRRecord` Nr� r r� r r� r� )�contentr� r� )r� r� z/rdnsr� r� rM r� r� ) r� r rb re r1 r� rL r� r� r� ) r5 r� ra rd re rR r� rM r� r( r( r+ �ex_create_ptr_record� s* � ��� �z'RackspaceDNSDriver.ex_create_ptr_recordc C s� |dur||j krd}|durRt|�}|D ]&}||jv r*|j| || kr*||= q*|du rb|sb|S t|� |j}| �|� | j||||d�S )a Update a PTR record for a specific IP on a specific device. If you need to change the domain or ttl, use this API to update the record by deleting the old one and creating a new one. :param record: the original :class:`RackspacePTRRecord` :param domain: the fqdn you want that IP to represent :param extra: a ``dict`` with optional extra values: ttl - the time-to-live of the PTR record :rtype: instance of :class:`RackspacePTRRecord` N)re )rd r� re r� ra rh r� )r5 r" rd re rm ra r( r( r+ rf � s z'RackspaceDNSDriver.ex_update_ptr_recordc C sJ t |� | j�d|jd�� | jjd|jd d|jd |jd�d� d S ) z� Delete an existing PTR Record :param record: the original :class:`RackspacePTRRecord` :rtype: ``bool`` r" r� r� r� r� r� )r� ra )rJ r� rK T)r� r1 r� r r� re ra r� r( r( r+ rh s �z'RackspaceDNSDriver.ex_delete_ptr_recordc C sl |d }|d }d}|� dd�}i }d|v r8|d |d< d|v rL|d |d< tt|�||t|�| |d �}|S ) Nr rT r� r r r� r r )r rd rc r r re )�getr r` r/ )r5 rR r rd rc r re r r( r( r+ r� ' s �zRackspaceDNSDriver._to_zonec C s� |d }|d }| j |j|d�}| �|d �}|d }d|i}tD ]} | |v rB|| || < qBtt|�||||| |�dd �|d�} | S ) Nr rT r� rc rR �fqdnr )r rT rc rR r r r re )�_to_partial_record_namerd Z_string_to_record_typer� r r` r� ) r5 rR r r r� rT rc Z record_datare rm r" r( r( r+ r� 8 s �z RackspaceDNSDriver._to_recordc C sb |d }|d }|d }|d |d d�}t D ]}||v r.|| ||< q.tt|�||| |d�}|S )Nr rR rT r� r� )r� r� )r ra rd r re )r� r_ r` ) r5 rR r� r ra rd re rm r" r( r( r+ r� I s �z!RackspaceDNSDriver._to_ptr_recordc C s |rd||f }n|}|S )z� Build a FQDN from a domain and record name. :param domain: Domain name. :type domain: ``str`` :param name: Record name. :type name: ``str`` z%s.%sr( �r5 rd rT r( r( r+ r� W s z'RackspaceDNSDriver._to_full_record_namec C s ||kr dS |� d| d�}|S )z� Remove domain portion from the record name. :param domain: Domain name. :type domain: ``str`` :param name: Full record name (fqdn). :type name: ``str`` Nz.%sr )rZ r� r( r( r+ r� h s z*RackspaceDNSDriver._to_partial_record_namec C s | � � }| j|d< |S r@ )Zopenstack_connection_kwargsrA )r5 rF r( r( r+ �_ex_connection_class_kwargs{ s z.RackspaceDNSDriver._ex_connection_class_kwargs)NTNNrU )r� NN)NNNN)N)NNNN)N)NN)-r: r; r< rT Zwebsiter Z RACKSPACErc r Z connectionClsrD r rt ru rv rw rx rb ry rz r� � classmethodrq r� r� r� r� r� r� r� r� r� r� r� r� r� rf rh r� r� r� r� r� r� r^ r( r( rG r+ rl � sR � � ! � %4 < "rl c C s4 ||k r dS | � dd�D ]}|d dkr dS qdS )NF�linksr( r� r� T)r� )rM Z result_lengthr} r� r( r( r+ r� � s r� c C sF t | d�r6t| jt�r6| j�d�d ur6| j�d�d usBtd| ��d S )Nre r� r� z\Can't create PTR Record for %s because it doesn't have a 'uri' and 'service_name' in 'extra')�hasattr� isinstancere r� r� r )Zdevice_or_recordr( r( r+ r� � s ����r� )&r� Zlibcloud.utils.py3r Zlibcloud.common.openstackr Zlibcloud.common.baser Zlibcloud.common.exceptionsr Zlibcloud.common.typesr Zlibcloud.utils.miscr r Zlibcloud.common.rackspacer Z"libcloud.compute.drivers.openstackr r Zlibcloud.dns.typesr r r r Zlibcloud.dns.baser r r �__all__r� r� r r rL r_ rl r� r� r( r( r( r+ �<module> s4 � @ g
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка