Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
Repository URL to install this package:
|
Version:
5.0.6.dev18 ▾
|
ó
}eµcc @ s» d Z d d l Z d d l Z d d l 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 Z d d
l m 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, d d l- m. Z. d d l m/ Z/ d d l0 m1 Z1 d d l0 m2 Z2 d d l0 m3 Z3 d d l0 m4 Z4 d d l5 m6 Z6 d d! l5 m7 Z7 d d" l5 m8 Z8 d d# l5 m9 Z9 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; mA ZA e jB d' ZC e; jD jE ZE e jF eG ZH e
jI ZJ e
jI ZK d( ZL d d) ZN d* ZO d d eP d+ ZQ d d, ZR d- ZS d. ZT d/ ZU d0 ZV eV eS d d1 ZW d d2 ZX d d3 ZY d4 ZZ d5 Z[ d6 Z\ d7 ZS e[ d8 Z] e\ d9 Z^ e\ d: Z_ eS d; Z` e\ d d< Za e\ d= Zb e\ d> Zc e\ eP d? Zd e\ eP d@ Ze e\ dA Zf e\ dB Zg eS dC Zh e[ dD Zi e jj dE dF dG ek e[ dH Zl d S(I s% Implementation of SQLAlchemy backend.iÿÿÿÿN( t api( t exception( t enginefacade( t update_match( t utils( t log( t excutils( t importutils( t timeutils( t uuidutils( t range( t and_( t Boolean( t NoSuchTableError( t compiles( t Integer( t MetaData( t or_( t aliased( t contains_eager( t
joinedload( t noload( t undefer( t Table( t sql( t asc( t cast( t desc( t
UpdateBase( t false( t func( t null( t true( t models( t _( t
safe_utilss osprofiler.sqlalchemyc C s t j t S( s" The backend is this module itself.( t syst modulest __name__( ( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt get_backendD s c C s5 t t | j } | d k r1 | | d <n | S( Nt
connection( t dictt listt itemst None( t
conf_groupR( t kw( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt _get_db_confH s
c C sY t j t | j t j t | j t rU t j d t j d n d S( Nc S s t j t | d S( Nt db( t profiler_sqlalchemyt add_tracingt sa( t eng( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt <lambda>V s c S s t j t | d S( NR0 ( R1 R2 R3 ( R4 ( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyR5 X s ( t main_context_managert configureR/ t databaset api_context_managert api_databaseR1 t append_on_engine_create( t conf( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyR7 N s
c C s | d k r | j } n i } d | k r7 t | d <n> d | k rP t | d <n% d | k r_ n t t d | t j | | j | | } t j
j | rÿ | rÿ | d k rç | j t
| j | j k | j t k } qÿ | j d | j } n | S( s9 Query helper that accounts for context's `read_deleted` field.
:param context: ContegoserverContext of the query.
:param model: Model to query. Must be a subclass of ModelBase.
:param args: Arguments to query. If None - model is used.
:param read_deleted: If not None, overrides context's read_deleted field.
Permitted values are 'no', which does not return
deleted values; 'only', which only returns deleted
values; and 'yes', which does not filter deleted
values.
:param project_only: If set and context is user-type, then restrict
query to match the context's project_id. If set to
'allow_none', restriction includes project_id = None.
t not deletedt onlyt yess$ Unrecognized read_deleted value '%s't
allow_nonet
project_idN( R, t read_deletedt Falset Truet
ValueErrorR" t sqlalchemyutilst model_queryt sessiont dmapit contextt is_user_contextt filterR RB R t filter_by( RK t modelt argsRC t project_onlyt query_kwargst query( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRH [ s(
c C sì t | t j d t j t d j t d } | d k rQ d d g } n xY | D]Q } | d k rp qX n d | k r | j t | } qX | j t | } qX Wx8 d d g D]* } | | k rº | j t | } qº qº W| S( NRQ s security_groups.rulest
info_cachet metadatat system_metadatat security_groupss extra.( RT RW ( RH R! t InstanceRE t optionsR R, R R ( RK t columns_to_joinRS t columnt col( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt _build_instance_get s
c s" t j f d } | S( sÅ Decorator to use a reader.allow_async db context manager.
The db context manager will be picked from the RequestContext.
Wrapped function must have a RequestContext in the arguments.
c s< t | } | j j j | | | | SWd QXd S( N( t get_context_managert readert allow_asynct using( RK RP t kwargst ctxt_mgr( t f( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt wrapped¨ s ( t functoolst wraps( Rd Re ( ( Rd s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt' pick_context_manager_reader_allow_async¡ s c C s t | p t S( sw Get a database context manager object.
:param context: The request context that can contain a context manager
( t _context_manager_from_contextR6 ( RK ( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyR^ ¯ s c C s, | r( y | j SWq( t k
r$ q( Xn d S( N( t
db_connectiont AttributeError( RK ( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRi µ s
c s" t j f d } | S( sE Decorator to require *any* user or admin context.
This does no authorization for user or project access matching, see
:py:func:`Contegoserver.context.authorize_project_context` and
:py:func:`Contegoserver.context.authorize_user_context`.
The first argument to the wrapped function must be the context.
c s! t j j | d | | S( Ni ( RJ RK t require_context( RP Rb ( Rd ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt wrapperÇ s ( Rf Rg ( Rd Rm ( ( Rd s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRl ¼ s c C s t | | d | S( NRZ ( t _instance_get_by_uuid( RK t uuidRZ ( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt instance_get_by_uuidÍ s c C sC t | d | j d | j } | s? t j d | n | S( NRZ Ro t instance_id( R] RN t firstR t InstanceNotFound( RK Ro RZ t result( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRn Ô s
c C s, t j } | j t t j d | | S( sf Create a database context manager object.
: param connection: The database connection string
R( ( R t transaction_contextR7 R/ t CONFR8 ( R( Rc ( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt create_context_managerß s c s" t j f d } | S( sZ Decorator to select synchronous or asynchronous reader mode.
The kwarg argument 'use_slave' defines reader mode. Asynchronous reader
will be used if 'use_slave' is True and synchronous reader otherwise.
If 'use_slave' is not specified default value 'False' will be used.
Wrapped function must have a context in the arguments.
c s t j } t j | | | } | d } | j d t } | rX t | j } n t | j } | j | | | SWd QXd S( NRK t use_slave(
R# t get_wrapped_functiont inspectt getcallargst getRD R^ t async_R_ Ra ( RP Rb t wrapped_funct
keyed_argsRK Rx t reader_mode( Rd ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRm ñ s
( Rf Rg ( Rd Rm ( ( Rd s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt select_db_reader_modeé s c s" t j f d } | S( s· Decorator to use a writer db context manager.
The db context manager will be picked from the RequestContext.
Wrapped function must have a RequestContext in the arguments.
c s9 t | } | j j | | | | SWd QXd S( N( R^ t writerRa ( RK RP Rb Rc ( Rd ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRe s ( Rf Rg ( Rd Re ( ( Rd s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt pick_context_manager_writer s c s" t j f d } | S( s· Decorator to use a reader db context manager.
The db context manager will be picked from the RequestContext.
Wrapped function must have a RequestContext in the arguments.
c s9 t | } | j j | | | | SWd QXd S( N( R^ R_ Ra ( RK RP Rb Rc ( Rd ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRe s ( Rf Rg ( Rd Re ( ( Rd s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt pick_context_manager_reader s c s" t j f d } | S( sà Decorator to use a reader.allow_async db context manager.
The db context manager will be picked from the RequestContext.
Wrapped function must have a RequestContext in the arguments.
c s< t | } | j j j | | | | SWd QXd S( N( R^ R_ R` Ra ( RK RP Rb Rc ( Rd ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRe " s ( Rf Rg ( Rd Re ( ( Rd s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRh s c C s t | | } t | t j j d | j d t | j d k r t | t j j t
t j j | k t j j | d k j d t n d S( Nt idt synchronize_sessions tvault-contegot host(
t service_getRH R! t ServiceRN t soft_deleteRD t binaryt ComputeNodeRM R t
service_idR ( RK R t service( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt service_destroy- s c C sI t | t j j d | } | j } | sE t j d | n | S( NR
R ( RH R! R RN Rr R t ServiceNotFound( RK R RS Rt ( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyR < s
c C sI t | t j j d | } | j } | sE t j d | n | S( NRo R ( RH R! R RN Rr R R ( RK t service_uuidRS Rt ( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt service_get_by_uuidG s
c C s | j j t j j t j t j j j t j j j | j t j j
d k j t j j t k j
t j j } t | S( Ni ( RI RS R! R R R t mint versionRM t in_R> t forced_downR t group_byR) ( RK t binariest min_versions( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt service_get_minimum_versionR s c C s= t | t j } | d k r3 | j d | } n | j S( Nt disabled( RH R! R R, RN t all( RK R RS ( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt service_get_all^ s c C s4 t | t j d d j d t j d | j S( NRC R= R t topic( RH R! R RN RD R ( RK R ( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt service_get_all_by_topich s c C s@ t | t j d d j d t j d | j d | j S( NRC R= R R R ( RH R! R RN RD Rr ( RK R R ( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt service_get_by_host_and_topicp s c C sC t | t j j d | } | s9 | j d t } n | j S( NR R ( RH R! R RN RD R ( RK R t include_disabledRS ( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt service_get_all_by_binaryy s c C s t | t j d d j d d } | s? | j d t } n | j t j t j j t j j k j t j j | k j
d } | j S( NRC R= R s tvault-contegoR R ( RH R! R RN RD t joinR R RM t hypervisor_typet distinctR ( RK t hv_typeR¡ RS ( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt# service_get_all_computes_by_hv_type s c C s[ t | t j d d j d | j d | j } | sW t j d | d | n | S( NRC R= R R ( RH R! R RN Rr R t HostBinaryNotFound( RK R R Rt ( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt service_get_by_host_and_binary s c C s( t | t j d d j d | j S( NRC R= R ( RH R! R RN R ( RK R ( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt service_get_all_by_host s c C sU t | t j d d j d | j d d j } | sQ t j d | n | S( NRC R= R R s tvault-contego( RH R! R RN Rr R t ComputeHostNotFound( RK R Rt ( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt service_get_by_compute_host£ s c C s° t j } | j | y | j | j Wn| t j k
r« } d | j k r~ t j d | j
d d | j
d n t j d | j
d d | j
d n X| S( NR R R ( R! R t updatet saveRI t db_exct DBDuplicateEntryt columnsR t ServiceBinaryExistsR| t ServiceTopicExists( RK t valuest service_reft e( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt service_create° s
t max_retriesi t retry_on_deadlockc C sT t | | } d | k rC | d | j k rC t j | _ qC n | j | | S( Nt report_count( R Rº R t utcnowt last_seen_upR ( RK R R´ Rµ ( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt service_update¿ s
(m t __doc__t collectionst copyt datetimeRf Rz R$ t oslo_dbR t oslo_db_apiR R¯ t oslo_db.sqlalchemyR R R RG t oslo_logR t loggingt
oslo_utilsR R R R t sixt six.movesR
t
sqlalchemyR3 R R t sqlalchemy.excR
t sqlalchemy.ext.compilerR R R R t sqlalchemy.ormR R R R R t sqlalchemy.schemaR R t sqlalchemy.sql.expressionR R R R t sqlalchemy.sqlR R R R t
dmapi.confRJ t
dmapi.contextt dmapi.db.sqlalchemyR! t
dmapi.i18nR" R# t
try_importR1 R< Rv t getLoggerR& t LOGRu R6 R9 R' R, R/ R7 RD RH R] Rh R^ Ri Rl Rp Rn Rw R R R R R R R R R R R¢ R§ R© Rª R¬ R· t
wrap_db_retryRE R½ ( ( ( s; /usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt <module> s´ .