o Ìv›a2€ã @sþdZddlZddlZddlZddlmZddlmZddlm Z m Z m Z ddl m Z ddlmZddlmZmZzddlZWneyZZzd Ze d  e¡¡WYdZ[ndZ[wwd Zd d ddœgZgd¢ZGdd„deƒZGdd„dejƒZdd„ZdS)zDocker plugin.éN)Údeepcopy)Úlogger)ÚiterkeysÚ itervaluesÚ nativestr)ÚgetTimeSinceLastUpdate)Ú GlancesPlugin)Ú sort_statsÚglances_processesTz?Error loading Docker Python Lib. Docker plugin is disabled ({})FÚ cpu_percentzContainer CPU consumption in %ú%)ÚnameÚ descriptionZy_unit)ÚcpuÚioÚmemoryÚnetworkcs¸eZdZdZd%‡fdd„ Z‡fdd„Zdd„Zd d „Zd d „Zd d„Z e j e j dd„ƒƒZ dd„Zdd„Zdd„Zdd„Zdd„Zdd„Z‡fdd„Zd%dd „Zd!d"„Zd#d$„Z‡ZS)&ÚPluginz\Glances Docker plugin. stats is a dict: {'version': {...}, 'containers': [{}, {}]} NcsPtt|ƒj||td||_||_d|_| ¡|_i|_ |  ¡|j   d¡dS)zInit the plugin.)ÚargsÚconfigÚitems_history_listTrN) ÚsuperrÚ__init__rrrZ display_curseÚconnectÚ docker_clientÚ thread_listÚupdateZ refresh_timerÚset)Úselfrr©Ú __class__©ú@/usr/lib/python3/dist-packages/glances/plugins/glances_docker.pyrPs þ zPlugin.__init__cs*t|jƒD]}| ¡qtt|ƒ ¡dS)z+Overwrite the exit method to close threads.N)rrÚstoprrÚexit)rÚtrr!r"r$ks z Plugin.exitcCsdS)zReturn the key of the list.r r!©rr!r!r"Úget_keyrszPlugin.get_keyc Csnz t|jdƒ}Wnty%}zt d |¡¡g}WYd}~nd}~ww|D] }tD]}| |¡q,q(|S)z~Overwrite the default export method. - Only exports containers - The key is the first container name Ú containersz&docker plugin - Docker export error {}N)rÚstatsÚKeyErrorrÚdebugÚformatÚexport_exclude_listÚpop)rÚretÚeÚ containerÚir!r!r"Ú get_exportvs€þ ÿzPlugin.get_exportc CsJzt ¡}W|Sty$}zt d |¡¡d}WYd}~|Sd}~ww)zConnect to the Docker server.z.docker plugin - Can not connect to Docker ({})N)ÚdockerZfrom_envÚ ExceptionrÚerrorr,)rr/r0r!r!r"r‰s ü€üzPlugin.connectcCs*| d¡}t|ƒdkr dS|d ¡dkS)z×Return the all tag of the Glances/Docker configuration file. # By default, Glances only display running containers # Set the following key to True to display all containers all=True ÚallrFÚtrue)Zget_conf_valueÚlenÚlower)rZall_tagr!r!r"Ú_all_tag–s  zPlugin._all_tagc CsT| ¡}ts |jdur|jS|jdkrz |j ¡|d<Wn-tyJ}z!t d  |j |¡¡d|jvr8|jd=g|jd<|jWYd}~Sd}~wwz|jj j |  ¡dpWg}Wn$ty}}zt d  |j |¡¡g|jd<|jWYd}~Sd}~ww|D]%}|j|jvr¥t d  |j |jdd …¡¡t|ƒ}||j|j<| ¡q€tt|jƒƒtd d „|Dƒƒ}|D]}t d   |j |dd …¡¡|j| ¡|j|=q¸g|d<|D]>}| t|jƒ¡sæqÚ| t|jƒ¡rïqÚi}| ¡|d <t|jƒ|d<t|jƒg|d<|j|d<|jj|d<|jdd|d<g|d<|jd dd¡r6|d |jd dg¡¡|jd dd¡rN|d |jd dg¡¡|dsWd|d<|ddvrê|  |j|j|jj¡|d<|d dd¡|d<| !|j|j|jj¡|d<|d dd¡|d<|d dd¡dur¥|d|dd8<| "|j|j|jj¡|d <|d  d!d¡|d"<|d  d#d¡|d$<| #|j|j|jj¡|d%<|d% d&d¡|d'<|d% d(d¡|d)<n(i|d<d|d<i|d<d|d*<i|d <d|d"<d|d$<i|d%<d|d'<d|d)<|d $|¡qÚn|jd+kr" t%|ƒ|_|jS),z+Update Docker stats using the input method.NZlocalÚversionz*{} plugin - Cannot get Docker version ({})r()r7z+{} plugin - Cannot get containers list ({})z*{} plugin - Create thread for container {}é cSsg|]}|j‘qSr!)Úid)Ú.0Úcr!r!r"Ú Üsz!Plugin.update..z,{} plugin - Stop thread for old container {}Úkeyr ZNamesZIdZImageÚStateÚStatusÚCommandZConfigZ EntrypointZCmd)ÚrunningZpausedrÚtotalr rÚusageÚ memory_usageÚcacherÚiorZio_rÚiowZio_wrÚrxZ network_rxÚtxZ network_txZmemory_percentZsnmp)&Zget_init_valueÚimport_error_tagrr)Z input_methodr<r5rr6r,Z plugin_namer(Úlistr;r>rr+ÚThreadDockerGrabberÚstartrrr#Zis_showrr Zis_hider'ZimageZtagsZattrsÚgetÚextendÚget_docker_cpuÚget_docker_memoryÚ get_docker_ioÚget_docker_networkÚappendr ) rr)r0r(r1r%Znonexisting_containersÚ container_idZcontainer_statsr!r!r"r£s¦    €ù  €ü  €       À B z Plugin.updatec Cs|ddi}i}i}zS|dd dd¡|d<|dd dd¡|d<|d dd¡|d <|d dd¡|d <d |dvrL|dd durL|dd |d <nt|ddd pVgƒ|d <Wn!ty|}zt d  ||¡¡t |¡WYd}~|Sd}~wwz|d|d}|d |d }|||d d|d<W|Sty½}zt d ||¡¡t |¡WYd}~|Sd}~ww)zÈReturn the container CPU usage. Input: id is the full container id all_stats is the output of the stats method of the Docker API Output: a dict {'total': 1.49} rGgZ cpu_statsZ cpu_usageZ total_usageNZ precpu_statsZsystem_cpu_usageÚsystemZ online_cpusZnb_coreZ percpu_usagez;docker plugin - Cannot grab CPU usage for container {} ({})gY@z>docker plugin - Cannot compute CPU usage for container {} ({}))rSr9r*rr+r,Ú TypeError) rrZÚ all_statsr/Zcpu_newZ precpu_newr0Z cpu_deltaZsystem_cpu_deltar!r!r"rU2s^ ÿ ÿÿÿ ÿ€ ÿ€ïÿ ÿú ÿ€úzPlugin.get_docker_cpuc Csòi}zSd|ddvr|ddd|d<nd|ddvr)|ddd|d<nd|d<|dd dd¡|d<|d dd¡|d<|dd|d<|dd |d <W|Sttfyx}zt d  ||¡¡t |¡WYd}~|Sd}~ww) zøReturn the container MEMORY. Input: id is the full container id all_stats is the output of the stats method of the Docker API Output: a dict {'rss': 1015808, 'cache': 356352, 'usage': ..., 'max_usage': ...} ZrssZ memory_statsr)Z total_rssNrJZ max_usagerHÚlimitz;docker plugin - Cannot grab MEM usage for container {} ({}))rSr*r\rr+r,)rrZr]r/r0r!r!r"rVgs, ÿÿû€ûzPlugin.get_docker_memoryc CsŠi}z|d}Wn"ty*}zt d ||¡¡t |¡|WYd}~Sd}~wwt|dƒsFi|_z||j|<Wn ttfyEYnw||jvr`z||j|<W|Sttfy_Y|Swz=td |¡ƒ|d<|dd|j|dd|d <|dd |j|dd |d <|dd|d <|dd |d <Wn ty½}zt d ||¡¡t |¡WYd}~nd}~ww||j|<|S)azReturn the container network usage using the Docker API (v1.0 or higher). Input: id is the full container id Output: a dict {'time_since_update': 3000, 'rx': 10, 'tx': 65}. with: time_since_update: number of seconds elapsed between the latest grab rx: Number of bytes received tx: Number of bytes transmitted Znetworksz;docker plugin - Cannot grab NET usage for container {} ({})NÚnetcounters_oldz docker_net_{}Útime_since_updateZeth0Zrx_bytesrMZtx_bytesrNZ cumulative_rxZ cumulative_txzIdocker plugin - Cannot grab network interface usage for container {} ({})) r*rr+r,Úhasattrr_ÚIOErrorÚUnboundLocalErrorr)rrZr]Z network_newZ netcountersr0r!r!r"rX‡sJ   €û ÿ  ëë""€ý zPlugin.get_docker_networkc Cs¼i}z|d}Wn"ty*}zt d ||¡¡t |¡|WYd}~Sd}~wwt|dƒsFi|_z||j|<Wn ttfyEYnw||jvr`z||j|<W|Sttfy_Y|Swz9|d}|j|d}dd„|Dƒdd }d d„|Dƒdd } d d„|Dƒdd } d d„|Dƒdd } Wn tt tt fy¹}zt d ||¡¡WYd}~|Sd}~wwt d  |¡ƒ|d<|| |d<| | |d<||d<| |d<||j|<|S)aqReturn the container IO usage using the Docker API (v1.0 or higher). Input: id is the full container id Output: a dict {'time_since_update': 3000, 'ior': 10, 'iow': 65}. with: time_since_update: number of seconds elapsed between the latest grab ior: Number of bytes read iow: Number of bytes written Z blkio_statsz@docker plugin - Cannot grab block IO usage for container {} ({})NÚiocounters_oldZio_service_bytes_recursivecSó g|] }|d ¡dkr|‘qS©ÚopÚread©r:©r?r2r!r!r"rAïó z(Plugin.get_docker_io..rÚvaluecSre©rgÚwriterirjr!r!r"rAðrkcSrerfrirjr!r!r"rAñrkcSrermrirjr!r!r"rAòrkz docker_io_{}r`rKrLZcumulative_iorZcumulative_iow) r*rr+r,rardrbrcr\Ú IndexErrorÚAttributeErrorr) rrZr]Zio_newZ iocountersr0Znew_io_service_bytes_recursiveZold_io_service_bytes_recursiverKrLZior_oldZiow_oldr!r!r"rWÁsV   €û ÿ  ãã €ò   zPlugin.get_docker_iocCst tjd¡S)z:Return the user ticks by reading the environment variable.Ú SC_CLK_TCK)ÚosÚsysconfÚ sysconf_namesr&r!r!r"Úget_user_ticksszPlugin.get_user_tickscCs |jdS)zZReturn stats for the action. Docker will return self.stats['containers'] r()r)r&r!r!r"Úget_stats_actions zPlugin.get_stats_actioncs<tt|ƒ ¡d|jvrdS|jdD]ˆ}iidœ|j|| ¡<d|vrYd|dvrY|j|dd|dd|dd}|d krL|j|dddd }||j|| ¡dd <d |vr›d |d vr›|j|d d |d d|dd|dd}|d krŽ|j|d d |d ddd}||j|| ¡dd <qdS)zUpdate stats views.r(F)rÚmemrrGr Z_cpu)ÚheaderÚ action_keyZDEFAULT)rxÚ decorationrrHr^Z_mem)Úmaximumrxryrw)r{rxT)rrÚ update_viewsr)Zviewsr'Z get_alert)rr2Zalertrr!r"r|s6  þ  ý þ€zPlugin.update_viewsc Cs¶g}|jrd|jvst|jdƒdks| ¡r|Sd d¡}| | |d¡¡d t|jdƒ¡}| | |¡¡d |jdd ¡}| | |¡¡| | ¡¡| | ¡¡t|jd urh|jj d d d dnd tt |jddd„ddƒƒ}djd|d}| | |¡¡d d¡}| | |¡¡d d¡}| | |¡¡d d¡}| | |¡¡d d¡}| | |¡¡d d¡}| | |¡¡d d¡}| | |¡¡d d¡}| | |¡¡d d ¡}| | |¡¡d! d"¡}| | |¡¡|jdD]U}| | ¡¡| | |j ||d#¡¡|  |d¡}d |ddd$…¡}| | ||¡¡z d% |d&d'¡}Wnt yNd d(¡}Ynw| | ||j|dd&d)d*¡¡zd | |d+d,¡¡}Wnt y}d d(¡}Ynw| | ||j|dd-d)d*¡¡zd | |d+d.¡¡}Wnt y¬d d(¡}Ynw| | |¡¡d/}d0D]5} z| t|d1| |d1d2ƒ¡|} d | ¡}Wnt yäd d(¡}Ynw| | |¡¡q¹|jrød3} d4}nd5} d6}d7D]7} z| t|d8| |d8d2| ƒ¡|} d | ¡}Wnt y+d d(¡}Ynw| | |¡¡qþ|d"d urHd d9 |d"¡¡}nd d(¡}| |j|d:d;¡q|S)Rs z"Plugin.msg_curse..)rBr ú {:{width}}ÚName©Úwidthz{:>10}rDz{:>6}zCPU%z{:>7}ZMEMz/MAXzIOR/szIOW/szRx/szTx/sz {:8}rE)r1Ú max_widthé z{:>6.1f}rrGÚ_rz)ÚitemrBÚoptionrrHrwr^ÚB)rKrLrr`éÚéÚb)rMrNrú T)Z splittable)r)r9Z is_disabledr,rYZcurse_add_lineZcurse_new_lineÚminrZ get_int_valueÚmaxÚ _msg_nameÚcontainer_alertr*Z get_viewsZ auto_unitÚintZbyteÚjoin) rrr…r/ÚmsgZname_max_widthr1ÚstatusZunitÚrrlZto_bitr!r!r"Ú msg_curse5sÚÿÿþ  ýþ ÿÿü          ÿÿ þÿ þÿ&ÿ*ÿ zPlugin.msg_cursecCsF|d}t|ƒ|krd|| dd…}n|d|…}dj||dS)zBuild the container name.r r‡r‹Nrrƒ)r9r,)rr1r…r r!r!r"r’¨s   zPlugin._msg_namecCs(|dkrdS|dkr dS|dkrdSdS)zAnalyse the container status.rFZOKZexitedZWARNINGZdeadZCRITICALZCAREFULr!)rr—r!r!r"r“±szPlugin.container_alert)NN)Ú__name__Ú __module__Ú __qualname__Ú__doc__rr$r'r3rr;rZ_check_decoratorZ_log_result_decoratorrrUrVrXrWrurvr|r™r’r“Ú __classcell__r!r!rr"rJs,    5 :B  's rcsTeZdZdZ‡fdd„Zdd„Zedd„ƒZejdd„ƒZdd d „Z d d „Z ‡Z S)rQzD Specific thread to grab docker stats. stats is a dict csJtt|ƒ ¡t ¡|_||_|jdd|_i|_ t   d  |jj ¡¡dS)zLInit the class. container: instance of Docker-py Container T)Údecodez.docker plugin - Create thread for container {}N)rrQrÚ threadingZEventÚ_stopperÚ _containerr)Ú _stats_streamÚ_statsrr+r,r )rr1rr!r"rÄs  zThreadDockerGrabber.__init__cCsRz|jD]}||_t d¡| ¡rWdSqWdSt d¡| ¡YdS)z_Grab the stats. Infinite loop, should be stopped by calling the stop() method gš™™™™™¹?z+docker plugin - Exception thrown during runN)r£r¤ÚtimeÚsleepÚstoppedrr+r#)rr2r!r!r"ÚrunÓs  ÿý zThreadDockerGrabber.runcCs|jS)z Stats getter.©r¤r&r!r!r"r)âszThreadDockerGrabber.statscCs ||_dS)z Stats setter.Nr©)rrlr!r!r"r)çs NcCs"t d |jj¡¡|j ¡dS)zStop the thread.z-docker plugin - Close thread for container {}N)rr+r,r¢r r¡r)rZtimeoutr!r!r"r#ìszThreadDockerGrabber.stopcCs |j ¡S)z%Return True is the thread is stopped.)r¡ZisSetr&r!r!r"r§ñs zThreadDockerGrabber.stopped)N) ršr›rœrrr¨Úpropertyr)Úsetterr#r§ržr!r!rr"rQ½s    rQcCs2d}d}tj d¡rd}d}t|d||d|S)Nr rIrr()ZsortedbyZsortedby_secondary)r Zsort_keyÚ startswithÚsort_stats_processes)r)Zsort_byZsort_by_secondaryr!r!r"r ös þr )rrrr r¥ÚcopyrZglances.loggerrZglances.compatrrrZ glances.timerrZglances.plugins.glances_pluginrZglances.processesr r­r r4r5r0rOZwarningr,rr-rZThreadrQr!r!r!r"Ús<     €ýþw 9