File: //usr/lib/fm-agent/library/__pycache__/container_discovery.cpython-39.pyc
a
��i- � @ sP d dl Z d dlZd dlZd dlmZmZ e �d�Zdd� Z d dd�Z
d d
� Z dS ) � N)�UnixHTTPConnection�
json_loadsZ
Containersc C sR t j�d�sdS z(td�} | jddddid� | �� W n tyL Y dS 0 d S )
N�/var/run/docker.sockz no-docker�GETz/containers/json�Host� localhost��headersz
no-permission�success)�os�path�existsr �request� getresponse� Exception)�conn� r �0/usr/lib/fm-agent/library/container_discovery.py� check_access
s r Fc
C s� t d�}|jddddid� |�� �� }t|�}t|�s<g S i }| �d�rt| �d�}|D ]\} }
|�|
g �� | � qXg } |D �]v} | d d d � }
| d
}|�
|
�}|s�|d kr�q||r�|s�|d
| d
k}|� | � |r�d |d
< |} �nd| d< | d }g }||v �r|� || � || d< i }dg| D ]�} zv|j
�
| �}|�sTt�d| � W �q*|�| |j�
| i ���pni }t�d|
t|�� �| � t|d|j�}||f|| < W n8 t�y� t�� d d� \}}t�|� Y �q*Y n0 �q*|| d< | � | � q|| S )Nr r �/containers/json?all=truer r r Zdocker_image_mapping�Id� �State�runningT�updated�dockerZcontainer_platform�Image� applicationsz#Unknown/unloaded docker plugin '%s'z Container %s: %d textkeys for %s�label� � app_metadata)r r r �readr �len� has_section�items�
setdefault�append�get�update�extend�plugins�logger�errorZget_metadata_docker�config�info�keys�getattr�textkeyr �sys�exc_info�logging� exception)r- r* �existing_containers�rebuildr �r�jZ app_mappingr$ ZappZimage�
containers� container�short_id�stateZexisting_containerZ
changed_stateZ app_imager r �plugin�metadataZ plugin_label�t�er r r �discover_docker_containers sr
��
�
rB c C s^ t d�}|jddddid� |�� �� }t|�}|D ]$}|d d d� }|| kr4| S q4d S ) Nr r r r r r r r )r r r r! r )� container_idr r8 Zcontainer_listr; r< r r r �find_docker_containerd s
rD )F) r4 �os.pathr r2 �
agent_utilr r � getLoggerr+ r rB rD r r r r �<module> s
L