Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
triliodata-3-3 / python3-dmapi deb
Repository URL to install this package:
|
Version:
3.3.35 ▾
|
python3-dmapi
/
usr
/
lib
/
python3
/
dist-packages
/
dmapi
/
cmd
/
__pycache__
/
manage.cpython-35.pyc
|
|---|
çáþ\[ ã @ s d Z d d l m 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 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 m Z d d l m Z d d l Z d d l Z d d l j j j 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( m* Z* d d l( m+ Z+ d d l, m- Z- d d l. m/ Z0 d d l( m
Z
d d l1 m2 Z2 d d l( m3 Z3 d d l4 m5 Z6 d d l4 m7 Z8 d d l4 m9 Z: d d l4 m; Z< d d l4 m= Z> d d l4 m? Z@ d d l4 mA ZB d d l4 mC ZD d d l4 mE ZE d d l( mF ZF d d l( mG ZG d d l( mH ZH d d l( mI ZI d d! lJ mK ZK e( jL jM ZM eF jN ZN d" d# d$ g ZO e& jP ZP e& jQ ZQ d% d& ZR d' d( ZS d) d* ZT Gd+ d, d, eU ZV e j d- d. ZW Gd/ d0 d0 eU ZX Gd1 d2 d2 eU ZY Gd3 d4 d4 eU ZZ Gd5 d6 d6 eU Z[ Gd7 d8 d8 eU Z\ d9 eZ d: e[ d; e\ d< eY d= eV d> eX i Z] e j^ e& j_ d? e] Z_ e j` d@ dA dB dC dD dE e_ Za e jb dF dG dH dC dI Zc dJ dK Zd d S)Lz&
CLI interface for nova management.
é )Úprint_functionN)Úcfg)Ú exception)Úlog)Ú encodeutils)Ú importutils)Ú uuidutils)Úurl)Úec2utils)Úcommon)Úconfig)Úcontext)Údb)Ú migration)Úapi)Ú_)Úobjects)Ú aggregate)Ú block_device)Ú
build_request)Ú host_mapping)Úinstance)Úinstance_group)Úkeypair)Úquotas)Ú request_spec)Úquota)Úrpc)Úutils)Úversion)Úironiczoslo_concurrency=INFOz oslo_db=INFOzoslo_policy=INFOc C s! d | k r t j | S| Sd S)zHelper function to convert various volume id types to internal id.
args: [object_id], e.g. 'vol-0000000a' or 'volume-0000000a' or '10'
ú-N)r
Zec2_vol_id_to_uuid)Z object_id© r" ú2/usr/lib/python3/dist-packages/dmapi/cmd/manage.pyÚparam2idH s
r$ c C sa t j | } t j d d | j } t j | j | | j | j | j | j } t j
| S)Nz:.*@z:****@) ÚurlparseÚreÚsubÚnetlocÚ ParseResultÚschemeÚpathÚparamsÚqueryÚfragmentÚ
urlunparse)r ÚparsedZ safe_netlocZ
new_parsedr" r" r# Úmask_passwd_in_urlR s r1 c C s+ t | t t d t j d d S)NzThe above error may show that the database has not been created.
Please create a database using 'nova-manage db sync' before running this command.é )Úprintr ÚsysÚexit)Zcaught_exceptionr" r" r# Ú _db_error\ s
r6 c @ sÓ e Z d Z d Z d Z e d d Z e d d d d d e d
d d d d e d
d d d d d d d d Z e d d d d d d d Z e d d d d d d d d Z
d S)ÚFloatingIpCommandsz Class for managing floating IP.z¦DEPRECATED: Floating IP commands are deprecated since nova-network is deprecated in favor of Neutron. The floating IP commands will be removed in an upcoming release.c C s´ y t j | g SWn t k
r¯ t j | } | j d k rj t d | j } t j d | nA | j d k r¡ t d | j } t j d | n
| j SYn Xd S)z¯Iterate over hosts within an address range.
If an explicit range specifier is missing, the parameter is
interpreted as a specific individual address.
é z@/%s should be specified as single address(es) not in cidr formatÚreasoni@B z]Too many IP addresses will be generated. Please increase /%s to reduce the number generated.N)
ÚnetaddrZ IPAddressÚ
ValueErrorZ IPNetworkÚsizer Ú prefixlenr Z InvalidInputZ
iter_hosts)Ú addressesÚnetr9 r" r" r# Úaddress_to_hostsm s
z#FloatingIpCommands.address_to_hostsz
--ip_rangeÚmetavarz<range>ÚhelpzIP rangez--poolz<pool>z
Optional poolz --interfacez <interface>zOptional interfaceNc sª t j } s t j s* t j f d d | j | D } y t j | | d d Wn: t j k
r¥ } z t
d | d SWYd d } ~ Xn Xd S)z'Creates floating IPs for zone by range.c s. g | ]$ } d t | d d i q S)ÚaddressÚpoolÚ interface)Ústr)Ú.0rC )rE rD r" r# ú
<listcomp> s z-FloatingIpCommands.create.<locals>.<listcomp>Z want_resultFz error: %sr2 N) r
Úget_admin_contextÚCONFZdefault_floating_poolZpublic_interfacer@ r Zfloating_ip_bulk_creater ZFloatingIpExistsr3 )ÚselfÚip_rangerD rE Ú
admin_contextÚipsÚexcr" )rE rD r# Úcreate s zFloatingIpCommands.createc C s< t j } d d | j | D } t j | | d S)z Deletes floating IPs by range.c s s! | ] } d t | i Vq d S)rC N)rF )rG rC r" r" r# ú <genexpr>¢ s z,FloatingIpCommands.delete.<locals>.<genexpr>N)r
rI r@ r Zfloating_ip_bulk_destroy)rK rL rM rN r" r" r# Údelete s zFloatingIpCommands.deletez--hostz<host>ÚHostc C sÞ t j } y4 | d k r- t j | } n t j | | } Wn) t j k
rk t t d d SYn Xxk | D]c } d } | d r© t j | | d } | d } t d | d | d | | d | d f qs Wd S)
z|Lists all floating IPs (optionally by host).
Note: if host is given, only active floating IPs are returned
Nz+No floating IP addresses have been defined.Z fixed_ip_idÚ
instance_uuidz%s %s %s %s %sÚ
project_idrC rD rE )
r
rI r Zfloating_ip_get_allZfloating_ip_get_all_by_hostr ZNoFloatingIpsDefinedr3 r Z fixed_ip_get)rK ÚhostÚctxtZ floating_ipsZ floating_iprT Zfixed_ipr" r" r# Úlist¦ s$
zFloatingIpCommands.list) Ú__name__Ú
__module__Ú __qualname__Ú__doc__Ú descriptionÚ staticmethodr@ ÚargsrP rR rX r" r" r" r# r7 d s $ r7 c O s- t j r t t d d S| | | S)z)Decorator to validate the network plugin.zhERROR: Network commands are not supported when using the Neutron API. Use python-neutronclient instead.é )r Z
is_neutronr3 r )Úfr_ Úkwargsr" r" r# Úvalidate_network_plugin s rc c ) @ s7 e Z d Z d Z d Z e e d d d d d e d d d
d d d d e d
d d d d e d d d d d e d d d d d e d d d d d d d e d d d d d e d d d d d e d d d e d! d d" e d# d d$ d d% e d& d d' d d( e d) d d* d d+ e d, d d- d d. e d/ d d- d d0 e d1 d d2 d d3 e d4 d d d d5 e d6 d d7 d d8 e d9 d d d d: d; d; d; d; d; d; d; d; d; d; d; d; d; d; d; d; d; d; d; d< d= Z e d> d? Z e e d@ d d d dA e d1 d dB d dC d; d; dD dE Z e e d@ d d d dF e dG d dH d dI e dJ d dK d dL e dM dN dO d dP dQ dR d dS e dT dN dO d dU dQ dR d dV d; d; d; d; dW dX Z
d; S)YÚNetworkCommandsz Class for managing networks.zDEPRECATED: Network commands are deprecated since nova-network is deprecated in favor of Neutron. The network commands will be removed in an upcoming release.z--labelrA z<label>rB z Label for network (ex: public)z--fixed_range_v4ÚdestÚcidrz <x.x.x.x/yy>z IPv4 subnet (ex: 10.0.0.0/8)z--num_networksz<number>z Number of networks to createz--network_sizezNumber of IPs per networkz--vlanz <vlan id>zvlan idz --vlan_startÚ
vlan_startz<vlan start id>z
vlan start idz--vpnÚ vpn_startz vpn startz--fixed_range_v6Úcidr_v6zIPv6 subnet (ex: fe80::/64z --gatewayÚgatewayz --gateway_v6z ipv6 gatewayz--bridgez<bridge>z1VIFs on this network are connected to this bridgez--bridge_interfacez<bridge interface>z)the bridge is connected to this interfacez --multi_hostz <'T'|'F'>z
Multi hostz--dns1z
<DNS Address>z First DNSz--dns2z
Second DNSz--uuidz<network uuid>z Network UUIDz --fixed_cidrz,IPv4 subnet for fixed IPs (ex: 10.20.0.0/16)z --project_idz <project id>z
Project idz
--priorityzNetwork interface priorityNc C s¾ | s t j d d t | d k r6 t j | p? | sT t j d d d d t t j D } | d k r | d k | d <t j t j
} | j t j
| d S)
z$Creates fixed IPs for host by range.ÚreqÚlabeléÿ zcidr or cidr_v6c S s1 i | ]' \ } } | r | d k r | | q S)rK r" )rG ÚkÚvr" r" r# ú
<dictcomp> s z*NetworkCommands.create.<locals>.<dictcomp>NÚTÚ
multi_host)r ZNetworkNotCreatedÚlenZ LabelTooLongrX ÚlocalsÚitemsr Ú
import_objectrJ Únetwork_managerZcreate_networksr
rI )rK rl rf Z num_networksZ network_sizerr Úvlanrg rh ri rj Z
gateway_v6ZbridgeZbridge_interfaceÚdns1Údns2rU ZpriorityÚuuidZ
fixed_cidrrb Ú net_managerr" r" r# rP Ô s ( " zNetworkCommands.createc C sÿ d } t | t d t d t d t d t d t d t d t d t d
f y t j t j } Wn% t j k
r¥ t t d YnV XxR | D]J } t | | j | j | j
| j | j | j
| j | j | j f q Wd S)
zList all created networks.z4%-5s %-18s %-15s %-15s %-15s %-15s %-15s %-15s %-15sÚidZIPv4ZIPv6z
start addressZDNS1ZDNS2ZVlanIDÚprojectr{ zNo networks foundN)r3 r r Znetwork_get_allr
rI r ZNoNetworksFoundr} rf ri Z
dhcp_startry rz rx rU r{ )rK Ú_fmtZnetworksÚnetworkr" r" r# rX
s0
zNetworkCommands.listz
--fixed_rangezNetwork to deletez<uuid>zUUID of network to deletec C s | d k r* | d k r* t t d t j t j } d t j k r | d k ri t t d | r t t d | j t j | | d S)zDeletes a network.Nz)Please specify either fixed_range or uuidZNeutronManagerz+UUID is required to delete Neutron Networksz@Deleting by fixed_range is not supported with the NeutronManager) Ú Exceptionr r rv rJ rw Zdelete_networkr
rI )rK Ú fixed_ranger{ r| r" r" r# rR * s zNetworkCommands.deletezNetwork to modifyz --projectz<project name>zProject name to associatez--hostz<host>zHost to associatez--disassociate-projectÚactionÚ
store_trueÚ dis_projectÚdefaultFz!Disassociate Network from Projectz--disassociate-hostÚdis_hostz Disassociate Host from Projectc
C sÆ t j } t j | | } i } | r4 d | d <| rD d | d <| sP | r | s\ | rp d } t | d St j | | d | d S| r | | d <| r« | | d <t j | | d | d S)zAssociate/Disassociate Network with Project and/or Host
arguments: network project host
leave any field blank to ignore it
NrU rV zCERROR: Unexpected arguments provided. Please use separate commands.r2 r} )r
rI r Znetwork_get_by_cidrr3 Znetwork_update)
rK r r~ rV r
r rM r r? Z error_msgr" r" r# Úmodify> s&
zNetworkCommands.modify) rY rZ r[ r\ r] rc r_ rP rX rR r r" r" r" r# rd Ì sl N rd c
@ s e Z d Z d Z e j e j e j e j
e j e
j e j e j e j e j e j j e j f Z d d Z e d d d d Z e d d d
d e j! e d d
d d d e d d d d d d d d d d d d Z" d d Z# e d d e$ d d d d d d e d! d
d d d" d# d d d$ e d% d
d d d& d# d d d' d( d d d) d* Z% e d+ d
d d d, d d- d d. d/ Z& d0 d1 Z' e d2 d d d d3 d d4 d d5 d6 Z( e d7 d d8 d9 d: d d; e d< d d= d9 d d d> e d? d d@ d9 d d dA e dB d
d d# d d dC d dD e d! d
d d# d d dE d d d d dF dG Z) d S)HÚ
DbCommandsz%Class for managing the main database.c C s d S)Nr" )rK r" r" r# Ú__init__ s zDbCommands.__init__ZPropertyÚValuec C s& t j | | g } d | _ x½ t | j D]© \ } } t | t r[ t j | } | rÇ t | t j rÇ d | k rÇ | j
j d } | } x= | D] } | j | | g d } q¡ Wq1 | j | | g q1 Wt j
rt t j | j n t t j | j j d S)a Print a `dict` as a table of two columns.
:param dct: `dict` to print
:param dict_property: name of the first column
:param wrap: wrapping for the second column
:param dict_value: header label for the value (second) column
Úlz\nÚ N)Ú prettytableÚ PrettyTableZalignÚsortedru Ú
isinstanceÚdictÚsixÚ text_typeÚ string_typesÚstripÚsplitÚadd_rowÚPY2r3 r Z safe_encodeZ
get_stringÚdecode) ÚdctZ
dict_propertyÚ
dict_valueÚptrn ro ÚlinesÚcol1Úliner" r" r# Ú _print_dict s $
zDbCommands._print_dictz --versionrA z <version>rB z --local_cellr r zEOnly sync db in the local cell: do not attempt to fan-outto all cellsÚversion2ÚVERSIONÚnargsú?zDatabase versionNFc C sù | r# | r# t t d | } | sì t j } yN t j j | t j j } t j | | } t j
| d | Wd QRXWnf t j k
rª t t d YnB t
k
rë } z" t t d t j | WYd d } ~ Xn Xt j
| S)z0Sync the database up to the most recent version.zªDEPRECATED: The '--version' parameter was deprecated in the Pike cycle and will not be supported in future versions of nova. Use the 'VERSION' positional argument insteadr
Nz5WARNING: cell0 mapping not found - not syncing cell0.a- ERROR: Could not access cell0.
Has the nova_api database been created?
Has the nova_cell0 database been created?
Has "nova-manage api_db sync" been run?
Has "nova-manage cell_v2 map_cell0" been run?
Is [api_database]/connection set in nova.conf?
Is the cell0 database connection URL correct?
Error: %s)r3 r r
ÚRequestContextr Ú CellMappingÚ get_by_uuidÚ
CELL0_UUIDÚ target_cellr Údb_syncr ÚCellMappingNotFoundr r r )rK r Z
local_cellr¢ rW Ú cell_mappingÚcctxtÚer" r" r# Úsyncµ s
*zDbCommands.syncc C s t t j d S)z#Print the current database version.N)r3 r Ú
db_version)rK r" r" r# r Ú s zDbCommands.versionz
--max_rowsÚtypez<number>re Úmax_rowsz<Maximum number of deleted rows to archive. Defaults to 1000.z --verboseÚverboser z,Print how many rows were archived per table.z--until-completeÚuntil_completezfRun continuously until all deleted rows are archived. Use max_rows as a batch size for each iteration.iè c C su t | } | d k r, t t d d S| t j k r\ t t d d t j i d St j } y t j j | Wn) t
j k
r§ t t d d SYn Xi } g } | rÚ | rÚ t j
j t d d xGy t j | \ } } Wn9 t k
r1i } | r-| r-t d
t d PYn Xx> t | j D]* \ } } | j | d | | | 7<qEW| rß| j d d | j d
d t j j | | }
| d |
7<t j j | | } | d
| 7<| séPn! | s
| r t d
t d P| rÝ t j
j d
qÝ W| re| rU| j | t d d t d n t t d t t | S)aU Move deleted rows from production tables to shadow tables.
Returns 0 if nothing was archived, 1 if some number of rows were
archived, 2 if max_rows is invalid, 3 if no connection could be
established to the API DB. If automating, this should be
run continuously while the result is 1, stopping at 0.
r z)Must supply a positive value for max_rowsr` z!max rows must be <= %(max_value)dZ max_valuez®Failed to connect to API DB so aborting this archival attempt. Please check your config file to make sure that CONF.api_database.connection is set and run this command again.é Z Archivingz..Ú.ÚstoppedÚinstance_mappingsZ
request_specsZcompleteZTabler zNumber of Rows ArchivedzNothing was archived.)Úintr3 r r ZMAX_INTr
rI r ÚCellMappingListÚget_allÚdb_excZCantStartEngineErrorr4 ÚstdoutÚwriteÚarchive_deleted_rowsÚKeyboardInterruptrX ru Ú
setdefaultÚInstanceMappingListZ destroy_bulkZ RequestSpecr¡ Úbool) rK r³ r´ rµ rW Ztable_to_rows_archivedZdeleted_instance_uuidsÚrunrn ro Zdeleted_mappingsZ
deleted_specsr" r" r# rÀ Þ sh
z DbCommands.archive_deleted_rowsz--deleterR zQIf specified, automatically delete any records found where instance_uuid is NULL.c C s§ t j | } d } xu t | j D]a \ } } | r( d } | ri t t d d | d | i q( t t d d | d | i q( W| s£ t t d d S) z[Lists and optionally deletes database records where
instance_uuid is NULL.
FTz8Deleted %(records)d records from table '%(table_name)s'.ÚrecordsÚ
table_namezÈThere are %(records)d records in the '%(table_name)s' table where the uuid or instance_uuid column is NULL. Run this command again with the --delete option after you have backed up any necessary data.z9There were no records found where instance_uuid was NULL.N)r Zdb_null_instance_uuid_scanrX ru r3 r )rK rR ÚhitsZ
records_foundrÇ rÆ r" r" r# Únull_instance_uuid_scan. s z"DbCommands.null_instance_uuid_scanc
C s d } i } x | j D]õ } | | } y | | | \ } } Wn9 t k
rz t t d t d | d } } Yn X| j } | r° t t d d | d | d | i | j | d | | d | | | d | f | | <| d k r | | 7} | | k r Pq W| S)
Nr z"Error attempting to run %(method)sÚmethodz8%(total)i rows matched query %(meth)s, %(done)i migratedÚtotalÚmethÚdoner2 )r r )Úonline_migrationsr r3 r r rY r )
rK rW Ú max_countÚranÚ
migrationsZmigration_methÚcountÚfoundrÍ Únamer" r" r# Ú_run_migrationK s0
zDbCommands._run_migrationz --max-countrÏ z%Maximum number of objects to considerc
C s t j } | d k rl y t | } Wn t k
rB d } Yn Xd } | d k r t t d d Sn d } d } t t d | d } i } xg | d k s³ | d k r| j | | } | j | t d d
t | j
D } | s Pq Wt j t d t d t d
g } xB t
| j D]. } | | } | j | | d | d g q?Wt | | rd pd S)Nr2 Fz+Must supply a positive value for max_numberé Té2 z$Running batches of %i until completer c S s g | ] \ } } | q Sr" r" )rG rÓ rÍ r" r" r# rH } s z5DbCommands.online_data_migrations.<locals>.<listcomp>Z Migrationz Total NeededZ Completedéÿÿÿÿ)r
rI rº r; r3 r rÕ ÚupdateÚsumrX Úvaluesr r r Úkeysr )
rK rÏ rW Z unlimitedrÐ Zmigration_inforÑ ÚtrÔ Úinfor" r" r# Úonline_data_migrationsf s:
%
"
z!DbCommands.online_data_migrationsz--resource_classz<class>ÚrequiredTz%Ironic node class to set on instancesz--hostz<host>z(Compute service name to migrate nodes onz--nodez<node>z8Ironic node UUID to migrate (all on the host if omitted)z--allÚ all_hostsz-Run migrations for all ironic hosts and nodesz2Print information about migrations being performedc C s$ | s t t d d St j } | rd | s8 | rL t t d d St j j | d } n¦ | r¶ | r¶ y% t j j | | | } | g } Wq
t j
k
r² g } Yq
XnT | rö y t j j | | } Wq
t j
k
rò g } Yq
Xn t t d d St | d k r0t t d d S| d j
d k rWt t d d SxÆ | D]¾ } t j j | d
| j d d i } t | d k rµt t d
| j d St | d k r^t j j | | | d j }
|
r^| r^t t d d | d j d
| j i q^Wd S)aÔ Migrate flavor information for ironic instances.
This will manually push the instance flavor migration required
for ironic-hosted instances in Pike. The best way to accomplish
this migration is to run your ironic computes normally in Pike.
However, if you need to push the migration manually, then use
this.
This is idempotent, but not trivial to start/stop/resume. It is
recommended that you do this with care and not from a script
assuming it is trivial.
Running with --all may generate a large amount of DB traffic
all at once. Running at least one host at a time is recommended
for batching.
Return values:
0: All work is completed (or none is needed)
1: Specified host and/or node is not found, or no ironic nodes present
2: Internal accounting error shows more than one instance per node
3: Invalid combination of required arguments
z7A resource_class is required for all modes of operationr¶ z3--all with --host and/or --node does not make senser z7Either --all, --host, or --host and --node are requiredr z1No ironic compute nodes found that match criteriar2 z/Compute node(s) specified is not of type ironicÚnodeZdeletedFz:Ironic node %s has multiple instances? Something is wrong.r` z+Migrated instance %(uuid)s on node %(node)sr{ )r3 r r
rI r ÚComputeNodeListZget_by_hypervisor_typeZ ComputeNodeZget_by_host_and_nodenamer ZComputeHostNotFoundÚget_all_by_hostrs Zhypervisor_typeÚ InstanceListÚget_by_filtersZhypervisor_hostnamer Z IronicDriverZ _pike_flavor_migration_for_noder{ ) rK Zresource_classrV râ rá r´ ÚctxZcnsZcnÚinstÚresultr" r" r# Úironic_flavor_migration sZ #
z"DbCommands.ironic_flavor_migration)*rY rZ r[ r\ r Z"migrate_instances_add_request_specÚ keypair_objZmigrate_keypairs_to_api_dbÚ
aggregate_objZmigrate_aggregatesZ%migrate_aggregate_reset_autoincrementÚinstance_group_objZ!migrate_instance_groups_to_api_dbÚbuild_request_objZ+delete_build_requests_with_no_instance_uuidr Z#service_uuids_online_data_migrationÚ
quotas_objZ migrate_quota_limits_to_api_dbZ migrate_quota_classes_to_api_dbÚsa_dbZmigration_migrate_to_uuidÚblock_device_objZBlockDeviceMappingZpopulate_uuidsÚ instance_objZ#populate_missing_availability_zonesrÎ r r^ r¡ r_ ÚargparseÚSUPPRESSr° r rº rÀ rÉ rÕ rß rê r" r" r" r# r p sd G #r c @ sy e Z d Z d Z d d Z e d d d d e j e d d d d
d d d d
d
d d Z d d Z d
S)Ú
ApiDbCommandsz$Class for managing the api database.c C s d S)Nr" )rK r" r" r# r ï s zApiDbCommands.__init__z --versionrA z <version>rB r¢ r£ r¤ r¥ zDatabase versionNc C s6 | r# | r# t t d | } t j | d d S)z0Sync the database up to the most recent version.zªDEPRECATED: The '--version' parameter was deprecated in the Pike cycle and will not be supported in future versions of nova. Use the 'VERSION' positional argument insteadÚdatabaser )r3 r r r« )rK r r¢ r" r" r# r° ò s
zApiDbCommands.syncc C s t t j d d d S)z#Print the current database version.rö r N)r3 r r± )rK r" r" r# r ÿ s zApiDbCommands.version)
rY rZ r[ r\ r r_ ró rô r° r r" r" r" r# rõ ì s rõ c @ s~ e Z d Z d Z d Z e d d Z d d d d d Z e d d d
d d e d
d d d d e d d d d d e d d d d d e d d d d d e d d d d d e d d d d d e d d d d d! e d" d d# e d$ d d# d% d d d d d d d d d& d' Z e d( d d) d d* d+ d, Z
d- d. Z d S)/Ú CellCommandsz-Commands for managing cells v1 functionality.zªDEPRECATED: The cell commands, which configure cells v1 functionality, are deprecated as Cells v1 itself has been deprecated. They will be removed in an upcoming release.c C sÒ y t j | r | d f S| j d d k r_ | j d d d j d \ } } | | f S| j d d k r~ | d f S| j d \ } } | | f SWn- t t j f k
rÍ t d | d
SYn Xd S) a Parses the given server_string and returns a tuple of host and port.
If it's not a combination of host part and port, the port element is an
empty string. If the input is invalid expression, return a tuple of two
empty strings.
r z]:r2 ú[ú:zInvalid server_string: %sNrØ rØ )r r )r: Z
valid_ipv6ÚfindÚreplacer r; ZAddrFormatErrorr3 )Z
server_strrC Úportr" r" r# Ú_parse_server_string
s
$
z!CellCommands._parse_server_stringNc C sN g } | rÞ | j d } x,| D]µ } | j } | j | \ } }
|
sk t d | } t | y t |
}
Wn. t k
r« t d |
} t | Yn X| j t j d | d |
d | d | q" Wnl y t | } Wn. t k
r t d | } t | Yn X| j t j d | d | d | d | | S) z7Returns a list of oslo.messaging.TransportHost objects.ú,zDInvalid broker_hosts value: %s. It should be in hostname:port formatz/Invalid port value: %s. It should be an integerÚhostnamerü ÚusernameÚpasswordz,Invalid port value: %s. Should be an integer) r r rý r r; rº ÚappendÚ messagingÚ
TransportHost) rK r r Ú broker_hostsrÿ rü Útransport_hostsÚhostsrV Zbroker_hostnameZ broker_portÚmsgr" r" r# Ú_create_transport_hosts+ sD
z$CellCommands._create_transport_hostsz--namerA z<name>rB zName for the new cellz --cell_typez<parent|api|child|compute>z/Whether the cell is parent/api or child/computez
--usernamez
<username>z,Username for the message broker in this cellz
--passwordz
<password>z,Password for the message broker in this cellz--broker_hostsz<broker_hosts>z¼Comma separated list of message brokers in this cell. Each Broker is specified as hostname:port with both mandatory. This option overrides the --hostname and --port options (if provided). z
--hostnamez
<hostname>z*Address of the message broker in this cellz--portz<number>z.Port number of the message broker in this cellz--virtual_hostz<virtual_host>z3The virtual host of the message broker in this cellz --woffsetz<float>z--wscaleÚchildc C sÑ | d k r t d d S| j | | | | | } t j } | j j | | | _ d }
| d k rr d }
d | d
|
d t j t | d t
| d
t
|
i } t j } t
j | | d S)NÚparentr
r Úcomputez<Error: cell type must be 'parent'/'api' or 'child'/'compute'r` FTrÔ Ú is_parentÚ
transport_urlZ
weight_offsetZ weight_scale)úparentzchildúapir )r r )r3 r r Úget_transport_urlr ÚextendÚ virtual_hostr% ÚunquoterF Úfloatr
rI r Z cell_create)rK rÔ Z cell_typer r r rÿ rü r ZwoffsetZwscaler r r
rÛ rW r" r" r# rP S s(
zCellCommands.createz --cell_namez <cell_name>zName of the cell to deletec C s t j } t j | | d S)N)r
rI r Z cell_delete)rK Z cell_namerW r" r" r# rR s zCellCommands.deletec
C sØ t j } t j | } d } t | d t | d x | D]~ } t j | j } | j rr | j d n t j
} t | | j | j | j
r d n d | j | j | j | j f qD Wt | d" d S)#Nz+%3s %-10s %-6s %-10s %-15s %-5s %-10sÚIdÚNameÚTypeÚUsernameÚHostnameÚPortÚVHostr! r¶ é
é é é r r r
)r zNamer r r r r ú---ú
----------ú------ú
----------ú---------------ú-----ú
----------)r! r" r# r$ r% r& r' ú---ú
----------ú------ú
----------ú---------------ú-----ú
----------)r( r) r* r+ r, r- r. )r
rI r Z cell_get_allr3 r r r r r r r} rÔ r
r rÿ rü r )rK rW ÚcellsÚfmtÚcellr rV r" r" r# rX s
" zCellCommands.list) rY rZ r[ r\ r] r^ rý r r_ rP rR rX r" r" r" r# r÷ s6 ' 0r÷ c @ sÒ e Z d Z d Z d d Z d d Z e d d d d d
d d d
d d Z e d d d d d d
d d Z d
d d Z d d Z
e d d d d d d d d d e d d d d d! d d" d
d# d$ Z d
d% d& d' Z e d d d d d
d d e d( d d) d d* e d+ d, d- d d. d
d
d% d/ d0 Z
e d1 d d2 d d3 d d d e d4 e d5 d, d- d d6 d e d7 d% d8 d9 Z e d d d d d d d: e d+ d, d- d e d; e d< d, d- d e d= e d> d, d- d? d% d d@ d e dA d
d% d% d% dB dC Z e e dD e d( d d) d e d* e d d d d dE d e dF e d d d d d
d e d e d+ d, d- d e dG d
d
d
d% dH dI Z e d+ d, d- d e dJ d% dK dL Z e dM d, d- d? d% d e dN e d d d d d d d d e dO d% dP dQ Z e d d d d d d d d e dR e d( d d) d dS d e dT e d d d d d
d e dU e d d d d dV d e dW d
d
d
dX dY Z e d d d d d d e dZ d
d[ d\ Z e d d d d d d d d e dZ e d] d d^ d d_ d d d e d` da db Z d
S)cÚCellV2Commandsz Commands for managing cells v2.c C s# | p t j } | s t d | S)Nz]Must specify --transport-url if [DEFAULT]/transport_url is not set in the configuration file.)rJ r r3 )rK r r" r" r# Ú_validate_transport_url s
z&CellV2Commands._validate_transport_urlc C su xn t j j | D]Z } | r4 | j | j k r4 q | j | k sR | j | k r t t d | j d Sq Wd S)NzpThe specified transport_url and/or database_connection combination already exists for another cell with uuid %s.TF)r r» r¼ r{ Údatabase_connectionr r3 r )rK rW r r r4 r1 r" r" r# Ú5_non_unique_transport_url_database_connection_checker§ s zDCellV2Commands._non_unique_transport_url_database_connection_checkerz--transport-urlrA z<transport_url>re r rB z,The transport url for the cell message queueNc C s4 t j j r t d d S| j | } | s3 d St j } y | j } Wn@ t j k
r t t
d t j j
| t j j } Yn Xt j | | ] } y t j d d | Wn< t j k
rü } z t t
d | WYd d } ~ Xn XWd QRX| j | } | d k r#d S| j | d S) a} Simple cellsv2 setup.
This simplified command is for use by existing non-cells users to
configure the default environment. If you are using CellsV1, this
will not work for you. Returns 0 if setup is completed (or has
already been done), 1 if no hosts are reporting (and this cannot
be mapped) and 2 if run in a CellsV1 environment.
z6CellsV1 users cannot use this simplified setup commandr` r2 zCell0 is already setupNr
z Unable to sync cell0 schema: %sr )rJ r/ Úenabler3 r3 r
r¦ Ú
_map_cell0r½ ÚDBDuplicateEntryr r r§ r¨ r© rª r r« ZDBErrorÚ_map_cell_and_hostsÚ
map_instances)rK r rW Z
cell0_mappingr® ÚexÚ cell_uuidr" r" r# Úsimple_cell_setup¶ s.
.
z CellV2Commands.simple_cell_setupz--database_connectionz<database_connection>z¸The database connection url for cell0. This is optional. If not provided, a standard database connection will be used based on the main database connection from the Nova configuration.c C s@ y | j d | Wn% t j k
r; t t d Yn Xd S)a° Create a cell mapping for cell0.
cell0 is used for instances that have not been scheduled to any cell.
This generally applies to instances that have encountered an error
before they have been scheduled.
This command creates a cell mapping for this special cell which
requires a database to store the instance data.
Returns 0 if cell0 created successfully or already setup.
r4 zCell0 is already setupr )r7 r½ r8 r3 r )rK r4 r" r" r# Ú map_cell0Þ s
zCellV2Commands.map_cell0c
C sb d d } | p | } t j } t j | d t j j d d d d d | } | j | S) zXFaciliate creation of a cell mapping for cell0.
See map_cell0 for more.
c S s> t j j } t j | } | j d | _ t j t | S)NZ_cell0)rJ rö Ú
connectionÚsqla_urlZmake_urlr% r rF )r? r r" r" r# Úcell0_default_connectionû s z;CellV2Commands._map_cell0.<locals>.cell0_default_connectionr{ rÔ Zcell0r znone:///r4 )r
r¦ r r§ r© rP )rK r4 rA ZdbcrW r r" r" r# r7 ÷ s
zCellV2Commands._map_cell0c
C s i } t j | | @ } t j j | j d d | d d d d d | d | } Wd QRXxg | D]_ } y> t j | } | j | _ | | _ | j
| _
| j Wqb t j
k
rÀ wb Yqb Xqb Wt | d k sé t | | k rò d } n
| d j } | S) NÚ read_deletedÚyesZsort_keyZ
created_atZsort_dirZascÚlimitÚmarkerr r2 rØ )r
rª r rå ræ ÚelevatedÚInstanceMappingr{ rT r rU rP r½ r8 rs )
rK rW r rD rE Úfiltersr® Ú instancesr Úmappingr" r" r# Ú_get_and_map_instances s&
$
z%CellV2Commands._get_and_map_instancesz --cell_uuidz <cell_uuid>r< rà TzGUnmigrated instances will be mapped to the cell with the uuid provided.z --max-countz <max_count>rÏ záMaximum number of instances to map. If not set, all instances in the cell will be mapped in batches of 50. If you have a large number of instances, consider specifying a custom value and run the command until it exits with 0.c
C sg | d k r` y t | } Wn t k
r6 d } Yn Xd } | d k rl t t d d Sn d } d } t j } d } t j j | | } t j j
| | } t | d k rà d } n' | d j j
d
d } | d j d } x5 | d k r'| j | | | | } | } | só Pqó W| rc| j
d d
} t j | d | d
| j d Sd S)a> Map instances into the provided cell.
Instances in the nova database of the provided cell (nova database
info is obtained from the nova-api database) will be queried from
oldest to newest and if unmapped, will be mapped to the provided cell.
A max-count can be set on the number of instance to map in a single
run. Repeated runs of the command will start from where the last run
finished so it is not necessary to increase max-count to finish. An
exit code of 0 indicates that all instances have been mapped.
Nr2 Fz*Must supply a positive value for max-countrÖ Tr× ZINSTANCE_MIGRATION_MARKERr ú r! rT rU rØ )rº r; r3 r r
r¦ r r§ r¨ rà Zget_by_project_idrs rT rû ÚdestroyrK rG rP )
rK r< rÏ Zmap_allrW Zmarker_project_idr Zmarker_mappingrE Z next_markerr" r" r# r: 0 sB
z CellV2Commands.map_instancesFc C s¯ t j } d } } t j j | } | sB t t d d St } x | D]
} y t j j | | j
}
Wn% t j k
r | j
| j
YqR X| rË t t d d |
j
d |
j j i |
j j } qR W| sõ t t d | S| d k rt j j | | } | d k ret j } t j | d | d | d | d t j j } | j x3 | D]+ } t j | d | d | }
|
j qlW| r«t | | S)
Nz'No hosts found to map to cell, exiting.z0Host %(host)s is already mapped to cell %(uuid)srV r{ z1All hosts are already mapped to cell(s), exiting.rÔ r r4 r )r
r¦ r rã r¼ r3 r ÚsetÚ HostMappingÚ get_by_hostrV r ÚHostMappingNotFoundÚaddr r{ r§ r¨ r Ú
generate_uuidrJ rö r? rP ) rK r rÔ r´ rW Úcell_mapping_uuidr Z
compute_nodesZ
missing_nodesZ compute_noder Z compute_hostr" r" r# r9 s sN
z"CellV2Commands._map_cell_and_hostsz--namez <cell_name>zThe name of the cellz --verboser r z8Output the cell mapping uuid for any newly mapped hosts.c C s0 | j | } | s d S| j | | | d S)aª EXPERIMENTAL. Create a cell mapping and host mappings for a cell.
Users not dividing their cloud into multiple cells will be a single
cell v2 deployment and should specify:
nova-manage cell_v2 map_cell_and_hosts --config-file <nova.conf>
Users running multiple cells can add a cell v2 by specifying:
nova-manage cell_v2 map_cell_and_hosts --config-file <cell nova.conf>
r2 r )r3 r9 )rK r rÔ r´ r" r" r# Úmap_cell_and_hosts¥ s
z!CellV2Commands.map_cell_and_hostsz--uuidz<instance_uuid>r{ zThe instance UUID to verifyz--quietÚquietzDo not print anythingc " s~ f d d } t j } y t j j | | } Wn' t j k
r` | d | d SYn X| j d k r | d | d St j | | j ¹ } y t j j
| | } Wn t j k
rKyM | j d d } t j j
| | } | r| d
| | d d SWn1 t j k
rF| d
| | d d SYn XYn XWd QRX| d | | j j
| j j f d Sd S)aj Verify instance mapping to a cell.
This command is useful to determine if the cellsv2 environment is
properly setup, specifically in terms of the cell, host, and instance
mapping records required.
This prints one of three strings (and exits with a code) indicating
whether the instance is successfully mapped to a cell (0), is unmapped
due to an incomplete upgrade (1), unmapped due to normally transient
state (2), it is a deleted instance which has instance mapping (3),
or it is an archived instance which still has an instance mapping (4).
c s s t | d S)N)r3 )Ústring)rV r" r# ÚsayÐ s z+CellV2Commands.verify_instance.<locals>.sayzVInstance %s is not mapped to a cell (upgrade is incomplete) or instance does not existr2 Nz#Instance %s is not mapped to a cellr` rB rC z+The instance with uuid %s has been deleted.zuExecute `nova-manage db archive_deleted_rows`command to archive this deleted instance andremove its instance_mapping.r¶ z,The instance with uuid %s has been archived.z%However its instance_mapping remains.r8 z Instance %s is in cell: %s (%s)r )r
rI r rG Zget_by_instance_uuidr ZInstanceMappingNotFoundr rª ZInstancer¨ ZInstanceNotFoundrF rÔ r{ ) rK r{ rV rX rW rJ r® r Zel_ctxr" )rV r# Úverify_instance¿ sD
z CellV2Commands.verify_instancezAIf provided only this cell will be searched for new hosts to map.z/Provide detailed output when discovering hosts.z--strictzConsidered successful (exit code 0) only when an unmapped host is discovered. Any other outcome will be considered a failure (exit code 1).z --by-servicer Ú
by_servicez1Discover hosts by service instead of compute nodec sK f d d } t j } t j | | | | } | rG t | Sd S)ax Searches cells, or a single cell, and maps found hosts.
When a new host is added to a deployment it will add a service entry
to the db it's configured to use. This command will check the db for
each cell, or a single one if passed in, and map any hosts which are
not currently mapped. If a host is already mapped nothing will be done.
c s r t | d S)N)r3 )r )r´ r" r# Ú status_fn s z0CellV2Commands.discover_hosts.<locals>.status_fnN)r
r¦ Úhost_mapping_objÚdiscover_hostsrº )rK r< r´ ÚstrictrZ r[ rW r r" )r´ r# r] ý s z CellV2Commands.discover_hostszAdd a new cell to nova API database. DB and MQ urls can be provided directly or can be taken from config. The result is cell uuid.r4 z&The database url for the cell databasez#Output the uuid of the created cellc
C sÎ t j } | p t j } | s5 t t d d S| pD t j j } | sa t t d d S| j | d | | r} d St j
} t j | d | d | d | d | } | j
| rÊ t | d S)
Nz]Must specify --transport-url if [DEFAULT]/transport_url is not set in the configuration file.r2 zaMust specify --database_connection if [database]/connection is not set in the configuration file.r` r{ rÔ r r4 r )r
Ú get_contextrJ r r3 r rö r? r5 r rS r r§ rP )rK rÔ r4 r r´ rW rT r r" r" r# Ú create_cell s,
zCellV2Commands.create_cellz)Show sensitive details, such as passwordsc C sè t j j t j } t d t d t d t d g } t j | } x t | d d d D]l } | j | j
g } | r¤ | j | j | j
g n% | j t | j t | j
g | j | qj Wt | d S) zÀLists the v2 cells in the deployment.
By default only the cell name and uuid are shown. Use the --verbose
option to see transport URL and database connection details.
r ZUUIDz
Transport URLzDatabase ConnectionÚkeyc S s | j S)N)rÔ )Z_cellr" r" r# Ú<lambda>T s z+CellV2Commands.list_cells.<locals>.<lambda>r )r r» r¼ r
rI r r r r rÔ r{ r r r4 r1 r r3 )rK r´ Z
cell_mappingsÚ field_namesrÝ r1 Úfieldsr" r" r# Ú
list_cellsE s
zCellV2Commands.list_cellsz--forcez-Delete hosts that belong to the cell as well.z The uuid of the cell to delete.c C s¤ t j } y t j j | | } Wn- t j k
rT t t d | d SYn Xt j j
| | j } g } | rÅ | s t t d | d St j | | } t j
j | } Wd QRXt j j
| | j } | rWt j | | } t j j | } Wd QRX| r/t t d | d St t d | t t d d
Sx! | D] }
d |
_ |
j q^Wx | D] } | j qW| j d S) a Delete an empty cell by the given uuid.
This command will return a non-zero exit code in the following cases.
* The cell is not found by uuid.
* It has hosts and force is False.
* It has instance mappings.
If force is True and the cell has host, hosts are deleted as well.
Returns 0 in the following cases.
* The empty cell is found and deleted successfully.
* The cell has hosts and force is True and the cell and the hosts are
deleted successfully.
z Cell with uuid %s was not found.r2 z5There are existing hosts mapped to cell with uuid %s.r` Nz9There are existing instances mapped to cell with uuid %s.r¶ zbThere are instance mappings to cell with uuid %s, but all instances have been deleted in the cell.zQSo execute 'nova-manage db archive_deleted_rows' to delete the instance mappings.r8 r )r
rI r r§ r¨ r r¬ r3 r ÚHostMappingListÚget_by_cell_idr} rª rã r¼ rà rå ÚmappedÚsaverM ) rK r< ÚforcerW r Ú
host_mappingsÚnodesr® r¹ rI râ r r" r" r# Ú delete_cell` sH
zCellV2Commands.delete_cellz The uuid of the cell to update.rÔ zSet the cell name.zZSet the cell transport_url. NOTE that running nodes will not see the change until restart!Ú
db_connectionz`Set the cell database_connection. NOTE that running nodes will not see the change until restart!c C s t j } y t j j | | } Wn- t j k
rT t t d | d SYn X| rd | | _ | pp t
j } | p t
j j
} | j | | | | r¡ d S| r° | | _ | r¿ | | _ y | j Wn= t k
r } z t t d | d SWYd d } ~ Xn Xd S)aa Updates the properties of a cell by the given uuid.
If the cell is not found by uuid, this command will return an exit
code of 1. If the provided transport_url or/and database_connection
is/are same as another cell, this command will return an exit code
of 3. If the properties cannot be set, this will return 2.
Otherwise, the exit code will be 0.
NOTE: Updating the transport_url or database_connection fields on
a running system will NOT result in all nodes immediately using the
new values. Use caution when changing these values.
z Cell with uuid %s was not found.r2 r¶ z Unable to update CellMapping: %sr` Nr )r
rI r r§ r¨ r r¬ r3 r rÔ rJ r rö r? r5 r4 ri r )rK r< rÔ r rn rW r r¯ r" r" r# Ú update_cell s. zCellV2Commands.update_cellzThe uuid of the cell.c
C s t j } | rv y t j j | | } Wn- t j k
rZ t t d | d SYn Xt j j
| | j } n t j j | } t d t d t d g } t
j | } xK t | d d d D]1 } | j j | j j | j g } | j | qÑ Wt | d S)
z'Lists the hosts in one or all v2 cells.z Cell with uuid %s was not found.r2 z Cell Namez Cell UUIDr ra c S s | j S)N)rV )Z_hostr" r" r# rb ü s z+CellV2Commands.list_hosts.<locals>.<lambda>r )r
rI r r§ r¨ r r¬ r3 r rf rg r} r¼ r r r r rÔ r{ rV r ) rK r< rW r rk rc rÝ rV rd r" r" r# Ú
list_hostsç s$ !
zCellV2Commands.list_hostsz--hostz<host>rV zThe host to delete.c
C sm t j } y t j j | | } Wn- t j k
rT t t d | d SYn Xy t j j
| | } Wn- t j k
r t t d | d SYn X| j j
| j
k r× t t d d | d | i d St j | | 1 } t j j
| | } t j j | | } Wd QRX| r;t t d
| d Sx! | D] } d | _ | j qBW| j d S)
ao Delete a host in a cell (host mappings) by the given host name
This command will return a non-zero exit code in the following cases.
* The cell is not found by uuid.
* The host is not found by host name.
* The host is not in the cell.
* The host has instances.
Returns 0 if the host is deleted successfully.
z Cell with uuid %s was not found.r2 zThe host %s was not found.r` z:The host %(host)s was not found in the cell %(cell_uuid)s.rV r< r¶ Nz#There are instances on the host %s.r8 r )r
rI r r§ r¨ r r¬ r3 r rO rP rQ r r{ rª rå rã rä rh ri rM )
rK r< rV rW r r r® rI rl râ r" r" r# Ú delete_host s6
zCellV2Commands.delete_host)rY rZ r[ r\ r3 r5 r_ r= r> r7 rK r: r9 rU r rY r] Úaction_descriptionr` re rm ro rp rq r" r" r" r# r2 s & :2 : ! I . r2 Zapi_dbr1 Zcell_v2r Zfloatingr Ú
categoriesÚcategoryÚtitlezCommand categoriesrB zAvailable categoriesÚhandlerz post-mortemr FzAllow post-mortem debuggingc C s/ t j t t g t j t j t j d t j
t t j t d t
j t j j d k r} t t j d St j j d k r t j t d Sy6 t j \ } } } | | | } t j | SWnR t k
r*t j rd d l } | j n t t d t j d SYn Xd S) z4Parse options and call the appropriate class/method.Zdefault_log_levelsÚnovar r zbash-completionNzAn error has occurred:
%sr2 ) rJ Zregister_cli_optsÚ category_optÚpost_mortem_optr Ú
parse_argsr4 ÚargvÚloggingÚ set_defaultsZget_default_log_levelsÚ_EXTRA_DEFAULT_LOG_LEVELSÚsetupr Z register_allrt rÔ r3 r Zversion_string_with_packageÚ
cmd_commonZprint_bash_completionÚ
CATEGORIESZ
get_action_fnr Úcleanupr Z post_mortemÚpdbr Ú tracebackÚ
format_exc)ÚfnZfn_argsZ fn_kwargsÚretr r" r" r# ÚmainO s0
r )er\ Ú
__future__r ró Ú functoolsr& r4 r Ú decoratorr: Z oslo_configr Zoslo_dbr r½ Zoslo_logr r| Zoslo_messagingr Z
oslo_utilsr r r r r Zsix.moves.urllib.parseÚmovesÚurllibÚparser% Zsqlalchemy.enginer r@ Z nova.api.ec2r
Znova.cmdr r Z nova.confrw r r
r Znova.dbr Znova.db.sqlalchemyr rð Z nova.i18nr r Z nova.objectsr rì r rñ r rî r r\ r rò r rí r rë r rï r r r r r Z nova.virtr ÚconfrJ ZQUOTASr~ r_ rr r$ r1 r6 Úobjectr7 rc rd r rõ r÷ r2 r ÚpartialZadd_command_parsersZ
SubCommandOptrx ZBoolOptry r r" r" r" r# Ú<module> s
^
¤ÿ }ÿ ÿ