Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb/__pycache__/main.cpython-39.pyc
Ðазад
a ]�h�S � @ s^ d Z ddlZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z ddl m Z ddlmZ ddlmZ dd lmZ dd lmZ dd lmZ dd lmZmZ zdd lmZ W n e y� dd l mZ Y n0 z ddl Z W n e �y ddl Z Y n0 e� e!�Z"dZ#G dd� d�Z$G dd� d�Z%G dd� d�Z&G dd� d�Z'G dd� d�Z(dS )a. .. testsetup:: from pyroute2 import NDB ndb = NDB(sources=[{'target': 'localhost', 'kind': 'IPMock'}]) .. testsetup:: netns from types import MethodType from pyroute2 import NDB ndb = NDB(sources=[{'target': 'localhost', 'kind': 'IPMock'}]) def add_mock_netns(self, netns): return self.add_orig(target=netns, kind='IPMock', preset='netns') ndb.sources.add_orig = ndb.sources.add ndb.sources.add = MethodType(add_mock_netns, ndb.sources) .. testcleanup:: * for key, value in tuple(globals().items()): if key.startswith('ndb') and hasattr(value, 'close'): value.close() NDB is a high level network management module. IT allows to manage interfaces, routes, addresses etc. of connected systems, containers and network namespaces. In a nutshell, NDB collects and aggregates netlink events in an SQL database, provides Python objects to reflect the system state, and applies changes back to the system. The database expects updates only from the sources, no manual SQL updates are expected normally. .. aafig:: :scale: 80 :textual: +----------------------------------------------------------------+ +----------------------------------------------------------------+ | +----------------------------------------------------------------+ | | | | | | | kernel | |-+ | |-+ +----------------------------------------------------------------+ | | ^ | ^ | `netlink events` | | | | | `inotify events` | | | | | `...` | | | | v v | v | +--------------+ +--------------+ +--------------+ | source | | source | | source |<--\ +--------------+ +--------------+ +--------------+ | | | | | | | | | \-----------------------+-----------------------/ | | | parsed netlink events | `NDB._event_queue` | | | v | +------------------------+ | | `NDB.__dbm__()` thread | | +------------------------+ | | | v | +-----------------------------+ | | `NDB.schema.load_netlink()` | | | `NDB.objects.*.load*()` | | +-----------------------------+ | | | v | +----------------------+ | | SQL database | | | `SQLite` | | | `PostgreSQL` | | +----------------------+ | | | | | V | +---------------+ | +---------------+ | | +---------------+ | | `RTNL_Object.apply()` | | NDB object: | | |-------------------------/ | `interface` | | | | `address` | | | | `route` | |-+ | `...` |-+ +---------------+ .. container:: aafig-caption object names on the diagram are clickable The goal of NDB is to provide an easy access to RTNL info and entities via Python objects, like `pyroute2.ndb.objects.interface` (see also: :ref:`ndbinterfaces`), `pyroute2.ndb.objects.route` (see also: :ref:`ndbroutes`) etc. These objects do not only reflect the system state for the time of their instantiation, but continuously monitor the system for relevant updates. The monitoring is done via netlink notifications, thus no polling. Also the objects allow to apply changes back to the system and rollback the changes. On the other hand it's too expensive to create Python objects for all the available RTNL entities, e.g. when there are hundreds of interfaces and thousands of routes. Thus NDB creates objects only upon request, when the user calls `.create()` to create new objects or runs `ndb.<view>[selector]` (e.g. `ndb.interfaces['eth0']`) to access an existing object. To list existing RTNL entities NDB uses objects of the class `RecordSet` that `yield` individual `Record` objects for every entity (see also: :ref:`ndbreports`). An object of the `Record` class is immutable, doesn't monitor any updates, doesn't contain any links to other objects and essentially behaves like a simple named tuple. .. aafig:: :scale: 80 :textual: +---------------------+ | | | | | `NDB() instance` | | | | | +---------------------+ | | +-------------------+ +-------------------+ | +-------------------+ | |-----------+--------------------------+ | | | | | | | | | | | | | `View()` | | | | | | | |-+ | | | |-+ | | +-------------------+ | | +------------------+ +------------------+ | | | | | | | | | `.dump()` | | `.create()` | | `.summary()` | | `.__getitem__()` | | | | | | | | | +------------------+ +------------------+ | | | | v v +-------------------+ +------------------+ | | +------------------+ | | | +------------------+ | | | `RecordSet()` | | `Interface()` | | | | | | `Address()` | | | | | | `Route()` | | | +-------------------+ | `Neighbour()` | | | | | `Rule()` | |-+ | | ... |-+ v +------------------+ +-------------------+ +-------------------+ | +-------------------+ | | | `filter()` | | | | `select()` | | | | `transform()` | | | | `join()` | |-+ | ... |-+ +-------------------+ | v +-------------------+ +-------------------+ | +-------------------+ | | | | | | | | | | | `Record()` | | | | | |-+ | |-+ +-------------------+ .. container:: aafig-caption object names on the diagram are clickable Here are some simple NDB usage examples. More info see in the reference documentation below. Print all the interface names on the system, assume we have an NDB instance `ndb`: .. testcode:: for interface in ndb.interfaces.dump(): print(interface.ifname) .. testoutput:: lo eth0 Print the routing information in the CSV format: .. testcode:: for record in ndb.routes.summary().format('csv'): print(record) .. testoutput:: 'target','tflags','table','ifname','dst','dst_len','gateway' 'localhost',0,254,'eth0','',0,'192.168.122.1' 'localhost',0,254,'eth0','192.168.122.0',24, 'localhost',0,255,'lo','127.0.0.0',8, 'localhost',0,255,'lo','127.0.0.1',32, 'localhost',0,255,'lo','127.255.255.255',32, 'localhost',0,255,'eth0','192.168.122.28',32, 'localhost',0,255,'eth0','192.168.122.255',32, .. note:: More on report filtering and formatting: :ref:`ndbreports` Print IP addresses of interfaces in several network namespaces as: .. testcode:: netns nslist = ['netns01', 'netns02', 'netns03'] for nsname in nslist: ndb.sources.add(netns=nsname) report = ndb.addresses.summary() report.select_records(target=lambda x: x.startswith('netns')) report.select_fields('address', 'ifname', 'target') for line in report.format('json'): print(line) .. testoutput:: netns [ { "address": "127.0.0.1", "ifname": "lo", "target": "netns01" }, { "address": "127.0.0.1", "ifname": "lo", "target": "netns02" }, { "address": "127.0.0.1", "ifname": "lo", "target": "netns03" } ] Add an IP address on an interface: .. testcode:: with ndb.interfaces['eth0'] as eth0: eth0.add_ip('10.0.0.1/24') # ---> <--- NDB waits until the address setup Change an interface property: .. testcode:: with ndb.interfaces['eth0'] as eth0: eth0.set( state='up', address='00:11:22:33:44:55', ) # ---> <--- NDB waits here for the changes to be applied # the commit() is called automatically by the # context manager's __exit__() � N)�config)� basestring� )� AuthManager��ShutdownException)�cmsg)� DBProvider)� TaskManager)� Transaction)� SourcesView�View)�urlparse))� interfacesr )� addressesr )�routesr )� neighboursr )Z af_bridge_fdbZfdb)�rulesr )�netnsr )Zaf_bridge_vlansZvlansc @ sv e Zd Zddd�Zdejfdd�Zedd� �Zedd � �Z d d � Z d d � Z dd� Z dd� Z dd� Zdd� Zdd� ZdS )�LogNc C s< d | _ d| _|pt| �| _t�d| j �| _ | �d�| _d S )NFzpyroute2.ndb.%s�main)�logger�state�id�log_id�logging� getLogger�channelr )�selfr � r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb/main.py�__init__I s z Log.__init__c C s, |d u r| j d uS | j d ur:t| j j�D ]}| j �|� q(|dv rh| jrd| j �d� | j �t�� � d S |dv rzt� � }nt|dkr�t� � }tj }n\t |t �r�t |�}|js�|jr�t�|j�}q�|jdkr�tjj|j�d�d�}q�td��n|}||u�rd }t�|�}|�|� | j �|� | j �|� d S ) N)�offFr )�on�stderr�debug�syslog�:)�addressz logging scheme not supportedz0%(asctime)s %(levelname)8s %(name)s: %(message)s)r �tuple�handlers� removeHandlerr �setLevel� addHandlerr � NullHandler� StreamHandler�DEBUG� isinstancer r �scheme�path� FileHandler� SysLogHandler�netloc�split� ValueError� Formatter� setFormatter)r �target�level�handler�url�fmt� formatterr r r �__call__P s> � z Log.__call__c C s | j dd� d S )Nr# �r; �rA �r r r r r# y s zLog.onc C s | j dd� d S )Nr" rB rC rD r r r r" } s zLog.offc C sT | j j}| j j}g }|j�� D ]}|�|�r |�|� q |D ] }|j|= q<~~~d S �N)r �manager�name� loggerDict�keys� startswith�append)r rF rG Z purge_listr r r r �close� s z Log.closec C s t �d| j|f �S )Nzpyroute2.ndb.%s.%s)r r r )r rG r r r r � s z Log.channelc O s | j j|i |��S rE )r r% �r �argv�kwargr r r r% � s z Log.debugc O s | j j|i |��S rE )r �inforM r r r rP � s zLog.infoc O s | j j|i |��S rE )r �warningrM r r r rQ � s z Log.warningc O s | j j|i |��S rE )r �errorrM r r r rR � s z Log.errorc O s | j j|i |��S rE )r �criticalrM r r r rS � s z Log.critical)N)�__name__� __module__� __qualname__r! r �INFOrA �propertyr# r" rL r r% rP rQ rR rS r r r r r H s ) r c @ s e Zd Zdd� ZdS )�DeadEndc O s t d��d S )Nzshutdown in progressr rM r r r �put� s z DeadEnd.putN)rT rU rV rZ r r r r rY � s rY c @ s@ e Zd Zdd� Zddd�Zdd� Zddd �Zd d � Zd d � ZdS )� EventQueuec O s t j|i |�� | _| _d S rE )�queue�Queue�_bypass�_queuerM r r r r! � s zEventQueue.__init__Nc C s | j �||f�S rE )r_ rZ �r �msg�sourcer r r rZ � s zEventQueue.putc C s t � | _d S rE )rY r_ rD r r r �shutdown� s zEventQueue.shutdownc C s | j �||f�S rE )r^ rZ r` r r r �bypass� s zEventQueue.bypassc O s | j j|i |��S rE )r^ �getrM r r r re � s zEventQueue.getc C s | j �� S rE )r^ �qsizerD r r r rf � s zEventQueue.qsize)N)N) rT rU rV r! rZ rc rd re rf r r r r r[ � s r[ c @ s e Zd Zdd� ZdS )� AuthProxyc C s< || _ || _tD ]&\}}t| j || jd�}t| ||� qd S )N�� auth_managers)Z_ndbZ_auth_managers�NDB_VIEWS_SPECSr �setattr)r Zndbri �vtable�vname�viewr r r r! � s zAuthProxy.__init__N)rT rU rV r! r r r r rg � s rg c @ sn e Zd Zedd� �Zd d d �Zd d d �Zd d� Zdd� Zdd� Z dd� Z dd� Z dd� Z dd� Z d dd �ZdS ) �NDBc C s d| j S )Nz %s/nsmanager)� localhostrD r r r � nsmanager� s z NDB.nsmanagerNrp �sqlite3�:memory:TFc C sP |dkr d}|| _ d | _| p0tjtj�d�dd�| _tt| �d�| _ d | _ d | _ t � � | _t � � | _t �� | _tdd�| _d | _|r�t|t�r�| � |� n>t|ttf�r�| j |� n$t|t�r�| j f i |�� ntd ��|d u �r(tj r�d d d �g}n0| j d dd�g}t j � d��r@|� | j!dd �� nt|ttf��s@t"d��|D ] } d| v�rD| j | d< �qf�qDt#dddd�| j �$d��} t%| | gd�| _&i | _'|| _(t)�*| j+� | j�,� d | _-t.t/|��||||dd�| _t0| �| _1t j2| j1j3dd�| _ d| j _4| j �5� | j�6� | j-d u�r | j-�t7D ]&\} } t8| | | gd�}t9| | |� �q$d S )N�postgresZpsycopg2�cT)Z use_errno)r �d )�maxsizezwrong log spec formatrp ZIPMock)r; �kind�localr )r; rx Z nlm_generator�linuxrq z sources format not supportedr; �zobj:listzobj:readz obj:modify�authrh �false)�provider�spec� rtnl_debug� db_cleanup� auto_netnsZrecordset_pipez NDB main loop)r; rG ):rp �schema�ctypes�CDLL�utilZ find_library�libcr r �log�_db� _dbm_thread� threading�EventZ _dbm_ready� _dbm_shutdown�Lock� _global_lockr[ � _event_queueZ messengerr1 r r) �list�dict� TypeErrorr Z mock_iproute�sys�platformrJ rK rq r8 r r r �sourcesZ_call_registryZ_nl�atexit�registerrL �clearZ _dbm_error�strr r � task_manager�Thread�run�daemon�start�waitrj r rk )r r� rp Z db_providerZdb_specr� r� r� r� r� r �amrl rm rn r r r r! � s� � �� � � � � z NDB.__init__c C s t | |||�S rE )r )r �table�chainri r r r � _get_view- s z NDB._get_viewc C s | S rE r rD r r r � __enter__0 s z NDB.__enter__c C s | � � d S rE )rL )r �exc_type� exc_value� tracebackr r r �__exit__3 s z NDB.__exit__c C s t | j�d��S )N� transaction)r r� r rD r r r �begin6 s z NDB.beginc C s | � tdddd�| j�d���S )NTFr{ r| )� auth_proxyr r� r rD r r r �readonly9 s ��z NDB.readonlyc C s t | |g�S rE )rg )r � auth_managerr r r r� A s zNDB.auth_proxyc C s� | j �� | j�� r"W d � d S | j�� ttd�rDt�| j� n,ztj� | jdi f� W n t yn Y n0 | j � � | j � td t� �f� | j�� | j�� W d � n1 s�0 Y d S )N� unregisterr )r� r� �is_set�set�hasattrr� r� rL Z _exithandlers�remover8 r� rc rd r r r� �joinr� rD r r r rL D s z NDB.closec C s | j �|� d S rE )r� Z db_backup)r r r r r �backupX s z NDB.backupc C s. | j �� D ] }|d ur |j|v r |�� q d S rE )r� �valuesrx Zrestart)r �kindsrb r r r �reload[ s z NDB.reload) Nrp rr rs TFFFN)NN)N)rT rU rV rX rq r! r� r� r� r� r� r� rL r� r� r r r r ro � s* � _ ro ))�__doc__r� r� Z ctypes.utilr �logging.handlersr� r� Zpyroute2r Zpyroute2.commonr r� r �eventsr �messagesr r� r r� r r� r rn r r r � ImportError� urllib.parser\ r] r rT r� rj r rY r[ rg ro r r r r �<module> sB ^
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка