Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
trilio-internal
trilio-internal / idna python
Repository URL to install this package:
|
Version:
2.5 ▾
|
ó
±EYc @ s÷ d Z d d l Z d d l m Z d d l m Z d d l m Z d d l m Z d d l
Z
d d l Z d d l
Z d d l m Z d d l m Z d d l m Z d d
l m Z d d l m Z d d l m Z d d
l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m! Z! e j" e# Z$ e j% j& Z& d Z' d Z( d d d Z* d d e+ d Z, d d d d d Z- d d d d d d d d Z. d Z/ d Z0 e+ d Z1 e2 d Z3 d Z4 d Z5 d S( sP Functionality related to notifications common to multiple layers of
the system.
iÿÿÿÿN( t context( t log( t excutils( t timeutils( t exception( t _LE( t glance( t network( t model( t base( t instance( t objects( t fields( t rpc( t utilsc s f d } | S( sÅ Decorator for notify which is used from utils.monkey_patch().
:param name: name of the function
:param fn: - object of the function
:returns: fn -- decorated function
c së i } g | d <i | d <x | D] } | d j | q! Wx | D] } | | | d | <qC Wt j | | p t j p t j j } t j d d t j
pª t j } t | t j
j | j } | | | | | S( Nt argst kwargt apit publisher_id( t appendt common_contextt" get_context_from_function_and_argst get_currentt novaR t RequestContextR
t get_notifiert CONFt default_publisher_idt hostt getattrt default_notification_levelt lowert info( R R t bodyt argt keyt ctxtt notifiert method( t fnt name( sL /home/tvault/.virtenv/lib/python2.7/site-packages/nova/notifications/base.pyt wrapped_func: s$
( ( R( R' R) ( ( R' R( sL /home/tvault/.virtenv/lib/python2.7/site-packages/nova/notifications/base.pyt notify_decorator2 s c C sf t j s
d Si | d 6t j | d 6| d 6} t j d j t j pX t j
j d | d S( s Send an api.fault notification.Nt urlR t statusR s api.fault( R t notify_api_faultst sixt text_typeR
R t errorR R R R t get_admin_context( R+ R, R t payload( ( sL /home/tvault/.virtenv/lib/python2.7/site-packages/nova/notifications/base.pyt send_api_faultS s
t computec C s= t j s
d St } | d } | d } | d } | d } | | k rP t } n$ t j d k rt | | k rt t } n | r t | | | | | | | | n yJ d }
| d | d k rÆ | d }
n t | | d | d | d |
WnP t j k
rt j
d d
| n* t k
r8t j t d d
| n Xd S( sb Send compute.instance.update notification to report any changes occurred
in that instance
Nt vm_statet
task_statet vm_and_task_statet display_namet serviceR t old_display_namesi Failed to send instance update notification. The instance could not be found and was most likely deleted.R
s( Failed to send state update notification(
R t notify_on_state_changet Falset Truet send_update_with_statest Nonet" _send_instance_update_notificationR t InstanceNotFoundt LOGt debugt ExceptionR ( R t old_instancet new_instanceR9 R t update_with_state_changet old_vm_statet new_vm_statet old_task_statet new_task_stateR: ( ( sL /home/tvault/.virtenv/lib/python2.7/site-packages/nova/notifications/base.pyt send_updateb s8
c
C sð t j s
d St } | r[ t } | | k r4 t } q[ t j d k r[ | | k r[ t } q[ n | rì y5 t | | d | d | d | d | d | d | Wqì t j k
r¿ t j d d
| qì t k
rè t j t
d d
| qì Xn d S( sf Send compute.instance.update notification to report changes if there
are any, in the instance
NR7 RH RJ RI RK R9 R si Failed to send instance update notification. The instance could not be found and was most likely deleted.R
s( Failed to send state update notification( R R; R= R< R@ R RA RB RC RD R (
R R
RH RI RJ RK R9 R t
verify_statest fire_update( ( sL /home/tvault/.virtenv/lib/python2.7/site-packages/nova/notifications/base.pyR> s,
c C s | d k r | d } n | d k r2 | d } n | d k rK | d } n | d k rd | d } n i | d 6| d 6| d 6| d 6} | S( NR5 R6 t old_statet stateRJ RK ( R? ( R
RH RJ RI RK t states_payload( ( sL /home/tvault/.virtenv/lib/python2.7/site-packages/nova/notifications/base.pyt _compute_states_payloadÀ s
c
C s t | | d d } | j t | | | | | t d t \ }
} |
| d <| | d <t | |
} | | d <| r | | d <n t j | | j | d | t
| | | | | d S( sf Send 'compute.instance.update' notification to inform observers
about instance state changes.
t current_periodt audit_period_beginningt audit_period_endingt bandwidthR: s compute.instance.updateN( t info_from_instanceR? t updateRR t audit_period_boundsR= t bandwidth_usageR
R R t _send_versioned_instance_update(
R R
RH RJ RI RK R9 R R: R2 t audit_startt audit_endt bw( ( sL /home/tvault/.virtenv/lib/python2.7/site-packages/nova/notifications/base.pyR@ Ü s
c C s4 | d k r d } n | d k r* d } n | } | S( NR s nova-apiR4 s nova-compute( ( R9 t binary( ( sL /home/tvault/.virtenv/lib/python2.7/site-packages/nova/notifications/base.pyt _map_service_to_binaryþ s c C s t j d | j d d | j d d | j d d | j d } t j d | j d d | j d } g | d j D]2 \ } } t j d | d | d
d | d ^ q } | j j }
t j d
| } t j d
| d | d | d | d t j
j |
d | d | j d } t j d t
j j d t j d d
d t
j j d t j d | plt j d t | d | }
|
j | d S( NRO RP RJ RK RT RU RV t network_namet in_bytest bw_int out_bytest bw_outR
t state_updatet audit_periodt ip_addressest flavorR: t priorityt
event_typet objectt actiont publisherR R_ R2 ( t instance_notificationt InstanceStateUpdatePayloadt gett AuditPeriodPayloadt itemst BandwidthPayloadt
info_cachet network_infot
FlavorPayloadt InstanceUpdatePayloadt IpPayloadt from_network_infot InstanceUpdateNotificationR t NotificationPriorityt INFOt notification_baset EventTypet NotificationActiont UPDATEt NotificationPublisherR R R` t emit( R R
R2 R R9 Rf Rg t labelR^ RV Rv Ri t versioned_payloadt notification( ( sL /home/tvault/.virtenv/lib/python2.7/site-packages/nova/notifications/base.pyR[ s> F c C sC t j \ } } | r- | } t j } n | } | } | | f S( sï Get the start and end of the relevant audit usage period
:param current_period: if True, this will generate a usage for the
current usage period; if False, this will generate a usage for the
previous audit period.
( R t last_completed_audit_periodR t utcnow( RS t begint endR\ R] ( ( sL /home/tvault/.virtenv/lib/python2.7/site-packages/nova/notifications/base.pyRY 3 s c s@ t j j d d f d } t t j rf j j } | d k ro t j
} qo n | } g | D] } | d ^ qv } d g } t j j
| | } i } x | D]z }
|
j | k r¾ d |
j } x3 | D]+ } | d |
j k rç | d d } Pqç qç Wt d |
j d
|
j | | <q¾ q¾ W| S( sY Get bandwidth usage information for the instance for the
specified audit period.
t read_deletedt yesc sß j d r\ d j d d k r\ d d } t | t j rL | St j j | Sy t j j SWnb t k
rÚ y0 t
j t j
t d d Wd QXWqÛ t k
rÖ rÐ d S qÛ Xn Xd S( s1 Support for getting network info without objects.Ru Rv s Failed to get nw_infoR
N( Rq R? t
isinstancet
network_modelt NetworkInfot hydrateR t APIt get_instance_nw_infoRD R t save_and_reraise_exceptionRB R R ( t cached_info( t
admin_contextt ignore_missing_network_datat instance_ref( sL /home/tvault/.virtenv/lib/python2.7/site-packages/nova/notifications/base.pyt _get_nwinfo_old_skoolM s$
t addresst uuids net-name-not-found-%sR R Rc Re N( R R R1 R t obj_baset
NovaObjectRu Rv R? R R R t BandwidthUsageListt get_by_uuidst mact dictRc Re ( R R\ R R t nw_infot vift macst uuidst bw_usagesR^ t bR ( ( R R R sL /home/tvault/.virtenv/lib/python2.7/site-packages/nova/notifications/base.pyRZ F s*
&c C sJ i } x= t j | D], \ } } | j d r | | | d <q q W| S( sZ Format image metadata for use in notifications from the instance
system metadata.
t image_i ( R. t iteritemst
startswith( t system_metadatat
image_metat md_keyt md_value( ( sL /home/tvault/.virtenv/lib/python2.7/site-packages/nova/notifications/base.pyR« ~ s
c A K s d } d } d } t j | j } | j } | j d d }
| j d d } t d | j d | j d | j d
| j d | j
d | j d
|
d | j d | d | j
d | j j d | j j | j j d | j j d | j j d | j j d | j d | j d | j d | | j d t | j d | | j d d. d | | j d d. d | | j d d. d | d | j d | j d! | j d" | j d# | | j d$ | | j d% | j d& | j! } | d. k rOg }
xR | D]J } xA | j" D]3 } | d' d( | d( <| d) | d* <|
j# | qWqôW|
| d+ <n t$ | j% } | | d, <| j& | d- <| j' | | S(/ s Get detailed instance information for an instance which is common to all
notifications.
:param:instance: nova.objects.Instance
:param:network_info: network_info provided if not None
:param:system_metadata: system_metadata DB entries for the instance,
if not None
.. note::
Currently unused here in trunk, but needed for potential custom
modifications.
c S s | r t | Sd S( Nt ( t str( t s( ( sL /home/tvault/.virtenv/lib/python2.7/site-packages/nova/notifications/base.pyt
null_safe_str s c S s | r t | Sd S( NR® ( t int( R° ( ( sL /home/tvault/.virtenv/lib/python2.7/site-packages/nova/notifications/base.pyt
null_safe_int s c S s7 t | t j r t j | S| r/ t | Sd Sd S( NR® ( R t datetimeR t strtimeR¯ ( R° ( ( sL /home/tvault/.virtenv/lib/python2.7/site-packages/nova/notifications/base.pyt null_safe_isotime¡ s
R( R® t flavoridt tenant_idt user_idt instance_idR8 t reservation_idt hostnamet
instance_typet instance_type_idt instance_flavor_idt architecturet memory_mbt disk_gbt vcpust root_gbt ephemeral_gbR t nodet availability_zonet cell_namet
created_att
terminated_att
deleted_att launched_att
image_ref_urlt os_typet kernel_idt
ramdisk_idRP t state_descriptiont progresst access_ip_v4t access_ip_v6R R R t vif_mact fixed_ipsR« t metadataN(( R t generate_image_urlt image_reft
get_flavorRq R t
project_idR¹ R R8 R» R¼ R¾ RÀ Ri RÁ RÄ RÅ RÃ R RÆ RÇ RÈ R¯ RÉ R? RÎ RÏ RÐ R5 R6 RÒ RÓ RÔ RÖ R R« Rª R× RX ( R R
Rv Rª t kwR± R³ R¶ RÍ R½ t instance_type_namet instance_flavoridt
instance_infoRÖ R¢ t ipt image_meta_props( ( sL /home/tvault/.virtenv/lib/python2.7/site-packages/nova/notifications/base.pyRW sj
(6 t __doc__R´ t oslo_contextR R t oslo_logR t
oslo_utilsR R R. t nova.confR t nova.contextR t nova.i18nR t
nova.imageR R t nova.networkR R t nova.notifications.objectsR R~ R
Ro R t nova.objectsR R R
R t getLoggert __name__RB t confR R* R3 R? RL R< R> RR R@ R` R[ RY R= RZ R« RW ( ( ( sL /home/tvault/.virtenv/lib/python2.7/site-packages/nova/notifications/base.pyt <module> sN ! 3 )
+ 7