B ‹æ@\¼Sã@sdZddlmZmZmZmZddlZe e¡Z ddl Z ddl m Z ddl mZddlmZddlmZddlmZd dlmZd d lmZd d lmZd d lmZd dlmZd dlmZd dlm Z m!Z!d dl"m#Z#d dl$m%Z%dZ&dZ'dZ(dZ)dZ*dZ+dZ,Gdd„deƒZ-dS)z1 Provides the Bokeh Server Tornado application. é)Úabsolute_importÚdivisionÚprint_functionÚunicode_literalsN)Úpformat)Úgen)ÚPeriodicCallback)Ú Application)ÚStaticFileHandleré)Ú Resources)Úsettings)Úimport_optionalé)ÚApplicationContext)ÚServerConnection)Úper_app_patternsÚtoplevel_patterns)Ú RootHandler)Ú StaticHandlerihBiˆi˜:i@)Ú BokehTornadocseZdZdZddde ¡e ¡deee e e dde f‡fdd„ Z dd„Zedd „ƒZed d „ƒZed d „ƒZedd„ƒZedd„ƒZedd„ƒZedd„ƒZd,dd„Zdd„Zd-dd„Zdd„Zdd„Zd d!„Zd"d#„Zejd$d%„ƒZd&d'„Z d(d)„Z!d*d+„Z"‡Z#S).ram A Tornado Application used to implement the Bokeh Server. Args: applications (dict[str,Application] or Application) : A map from paths to ``Application`` instances. If the value is a single Application, then the following mapping is generated: .. code-block:: python applications = { '/' : applications } When a connection comes in to a given path, the associate Application is used to generate a new document for the session. prefix (str, optional) : A URL prefix to use for all Bokeh server paths. (default: None) extra_websocket_origins (list[str], optional) : A list of hosts that can connect to the websocket. This is typically required when embedding a Bokeh server app in an external web site using :func:`~bokeh.embed.server_document` or similar. If None, ``["localhost"]`` will be assumed (default: None) extra_patterns (seq[tuple], optional) : A list of tuples of (str, http or websocket handler) Use this argument to add additional endpoints to custom deployments of the Bokeh Server. If None, then ``[]`` will be used. (default: None) secret_key (str, optional) : A secret key for signing session IDs. Defaults to the current value of the environment variable ``BOKEH_SECRET_KEY`` sign_sessions (bool, optional) : Whether to cryptographically sign session IDs Defaults to the current value of the environment variable ``BOKEH_SIGN_SESSIONS``. If ``True``, then ``secret_key`` must also be provided (either via environment setting or passed as a parameter value) generate_session_ids (bool, optional) : Whether to generate a session ID if one is not provided (default: True) keep_alive_milliseconds (int, optional) : Number of milliseconds between keep-alive pings (default: 37000) Pings normally required to keep the websocket open. Set to 0 to disable pings. check_unused_sessions_milliseconds (int, optional) : Number of milliseconds between checking for unused sessions (default: 17000) unused_session_lifetime_milliseconds (int, optional) : Number of milliseconds for unused session lifetime (default: 15000) stats_log_frequency_milliseconds (int, optional) : Number of milliseconds between logging stats (default: 15000) mem_log_frequency_milliseconds (int, optional) : Number of milliseconds between logging memory information (default: 0) Enabling this feature requires the optional dependency ``psutil`` to be installed. use_index (bool, optional) : Whether to generate an index of running apps in the ``RootHandler`` (default: True) redirect_root (bool, optional) : When there is only a single running application, whether to redirect requests to ``"/"`` to that application automatically (default: True) If there are multiple Bokeh applications configured, this option has no effect. websocket_max_message_size_bytes (int, optional): Set the Tornado ``websocket_max_message_size`` value. (default: 20*1024*1024) NOTE: This setting has effect ONLY for Tornado>=4.5 Any additional keyword arguments are passed to ``tornado.web.Application``. NTc s d|_t|tƒrd|i}|dkr$d}| d¡}|r:d|}||_|dkrRtdƒ‚n(|dkrft d¡n|tkrzt d|¡||_ | dkr’tdƒ‚n| t kr¦t d| ¡| |_ | dkr¾tdƒ‚n| t krÒt d | ¡| |_ | dkrêtd ƒ‚n| tkrþt d | ¡| |_| dkrtd ƒ‚n>| dkrVtd ƒdkr@t d¡d} n| tkrVt d| ¡| |_|dkrptdƒ‚n|tkrŒt d||d¡|dkr tƒ|_n t|ƒ|_||_||_||_t dt|jƒ¡tƒ|_x(| ¡D]\}}t||d|j|<qàW|pg}g}x| ¡D] \}}g}xVt D]N}|dkrF|d}n ||d}|j|}| !||dd|j|if¡q.Wd}x&|D]}|d "d¡rŠ|d}qŠW|sºt#dƒ‚x|D]}||dd<qÀW| $|¡|j%dk r|dkrüd}n|d}|j|}| !|t&d|j%if¡qWxŠ|t'D]~}|dt(krŠ| r°|j|j|dœ}|j|df|dd…|f}| !|¡n&|j|df|dd…}| !|¡q4Wt d¡x*t)|dd  *d!¡D]}t d"|¡qÔWt+t,|ƒj-|fd#|i|—ŽdS)$Nú/Úrz$keep_alive_milliseconds must be >= 0zKeep-alive ping disabledz0Keep-alive ping configured every %d millisecondsz.check_unused_sessions_milliseconds must be > 0z/Check for unused sessions every %d millisecondsz(Unused sessions last for %d millisecondsz,stats_log_frequency_milliseconds must be > 0z$Log statistics every %d millisecondsz+mem_log_frequency_milliseconds must be >= 0Úpsutilz†Memory logging requested, but is disabled. Optional dependency 'psutil' is missing. Try 'pip install psutil' or 'conda install psutil'z&Log memory usage every %d millisecondsz2websocket_max_message_size_bytes must be postitivez>Torndado websocket_max_message_size set to %d bytes (%0.2f MB)g0Az3These host origins can connect to the websocket: %r)ZurlrÚapplication_contextz/wszCouldn't find websocket pathr Zbokeh_websocket_pathz /static/(.*)Úpath)Ú applicationsÚprefixZ use_redirectz Patterns are:é<)ÚwidthÚ z Zwebsocket_max_message_size).Ú_loopÚ isinstancer ÚstripÚ_prefixÚ ValueErrorÚlogÚinfoÚDEFAULT_KEEP_ALIVE_MSÚ_keep_alive_millisecondsÚDEFAULT_CHECK_UNUSED_MSÚ#_check_unused_sessions_millisecondsÚDEFAULT_UNUSED_LIFETIME_MSÚ%_unused_session_lifetime_millisecondsÚDEFAULT_STATS_LOG_FREQ_MSÚ!_stats_log_frequency_millisecondsrZwarningÚDEFAULT_MEM_LOG_FREQ_MSÚ_mem_log_frequency_millisecondsÚ(DEFAULT_WEBSOCKET_MAX_MESSAGE_SIZE_BYTESÚsetÚ_websocket_originsÚ _secret_keyÚ_sign_sessionsÚ_generate_session_idsÚdebugÚlistÚdictÚ _applicationsÚitemsrrÚappendÚendswithÚ RuntimeErrorÚextendZ static_pathr rrrÚsplitÚsuperrÚ__init__)ÚselfrrZextra_websocket_originsZextra_patternsÚ secret_keyÚ sign_sessionsÚgenerate_session_idsZkeep_alive_millisecondsZ"check_unused_sessions_millisecondsZ$unused_session_lifetime_millisecondsZ stats_log_frequency_millisecondsZmem_log_frequency_millisecondsZ use_indexZ redirect_rootZ websocket_max_message_size_bytesÚkwargsÚkÚvZ all_patternsÚkeyÚappZ app_patternsÚpZrouteZwebsocket_pathÚrÚdataZ prefixed_patÚline)Ú __class__©ú3lib/python3.7/site-packages/bokeh/server/tornado.pyrC¥s                              $      "  zBokehTornado.__init__cCs’||_x|j ¡D] }|j|_qWtƒ|_t|j|jƒ|_|j dkrVt|j |j ƒ|_ nd|_ t|j |j ƒ|_|jdkrˆt|j|jƒ|_nd|_dS)zN Start a Bokeh Server Tornado Application on a given Tornado IOLoop. rN)r!r;Úvaluesr3Ú_clientsrÚ _log_statsr/Ú _stats_jobr1Ú_log_memÚ_mem_jobÚ_cleanup_sessionsr+Ú _cleanup_jobr)Ú _keep_aliveÚ _ping_job)rDÚio_loopZ app_contextrRrRrSÚ initialize6s      zBokehTornado.initializecCs t|jƒS)zw A list of all application paths for all Bokeh applications configured on this Bokeh server instance. )r3r;)rDrRrRrSÚ app_pathsSszBokehTornado.app_pathscCs|jS)z` The Tornado IOLoop that this Bokeh Server Tornado Application is running on. )r!)rDrRrRrSr^[szBokehTornado.io_loopcCs|jS)z^ A URL prefix for this Bokeh Server Tornado Application to use for all paths )r$)rDrRrRrSrcszBokehTornado.prefixcCs|jS)zK A list of websocket origins permitted to connect to this server. )r4)rDrRrRrSÚwebsocket_originskszBokehTornado.websocket_originscCs|jS)zy A secret key for this Bokeh Server Tornado Application to use when signing session IDs, if configured. )r5)rDrRrRrSrErszBokehTornado.secret_keycCs|jS)zà Whether this Bokeh Server Tornado Application has been configured to cryptographically sign session IDs If ``True``, then ``secret_key`` must also have been configured. )r6)rDrRrRrSrFzszBokehTornado.sign_sessionscCs|jS)z{ Whether this Bokeh Server Tornado Application has been configured to automatically generate session IDs. )r7)rDrRrRrSrGƒsz!BokehTornado.generate_session_idscCs,|rtd||jtjdStd|jtjdS)aJ Provide a :class:`~bokeh.resources.Resources` that specifies where Bokeh application sessions should load BokehJS resources from. Args: absolute_url (bool): An absolute URL prefix to use for locating resources. If None, relative URLs are used (default: None) Zserver)ÚmodeZroot_urlZpath_versioner)r r$rZappend_version)rDZ absolute_urlrRrRrSÚ resources‹s zBokehTornado.resourcescCs\|j ¡|jdk r|j ¡|j ¡|jdk r<|j ¡x|j ¡D] }| ¡qHWdS)a Start the Bokeh Server application. Starting the Bokeh Server Tornado application will run periodic callbacks for stats logging, cleanup, pinging, etc. Additionally, any startup hooks defined by the configured Bokeh applications will be run. N)rWÚstartrYr[r]r;rTZ run_load_hook)rDÚcontextrRrRrSrd™s      zBokehTornado.startcCsfx|j ¡D] }| ¡q W|j ¡|jdk r:|j ¡|j ¡|jdk rX|j ¡|j  ¡dS)z¬ Stop the Bokeh Server application. Args: wait (bool): whether to wait for orderly cleanup (default: True) Returns: None N) r;rTZrun_unload_hookrWÚstoprYr[r]rUÚclear)rDÚwaitrerRrRrSrf«s        zBokehTornado.stopcCst||||ƒ}|j |¡|S)N)rrUÚadd)rDZprotocolZsocketrÚsessionÚ connectionrRrRrSÚnew_connectionÃs zBokehTornado.new_connectioncCs|j |¡| ¡dS)N)rUÚdiscardZdetach_session)rDrkrRrRrSÚ client_lostÈs zBokehTornado.client_lostcCs&||jkrtd|ƒ‚|j| |¡S)ak Get an active a session by name application path and session ID. Args: app_path (str) : The configured application path for the application to return a session for. session_id (str) : The session ID of the session to retrieve. Returns: ServerSession z,Application %s does not exist on this server)r;r%Ú get_session)rDÚapp_pathZ session_idrRrRrSroÌs  zBokehTornado.get_sessioncCs&||jkrtd|ƒ‚t|j|jƒS)a  Gets all currently active sessions for an application. Args: app_path (str) : The configured application path for the application to return sessions for. Returns: list[ServerSession] z,Application %s does not exist on this server)r;r%r9Úsessions)rDrprRrRrSÚ get_sessionsßs  zBokehTornado.get_sessionsccs:t d¡x |j ¡D]}| |j¡VqWt d¡‚dS)NzRunning session cleanup job)r&Útracer;rTrZr-rZReturn)rDrLrRrRrSrZñs zBokehTornado._cleanup_sessionscCs˜t d¡t ¡tjkrdSt dt ¡t|j ƒ¡x^|j   ¡D]P\}}t |j ƒ}d}x|D]}|jdkr\|d7}q\Wt dt ¡|t|ƒ|¡q@WdS)NzRunning stats log jobz[pid %d] %d clients connectedrrz,[pid %d] %s has %d sessions with %d unused)r&rsÚgetEffectiveLevelÚloggingÚDEBUGr8ÚosÚgetpidÚlenrUr;r<r9rqZconnection_count)rDrprLrqZ unused_countÚsrRrRrSrVøs     zBokehTornado._log_statsc sÌddl}| t ¡¡}t dt ¡| ¡jd| ¡jd¡t  ¡t j krPdSddl }ddl m}ddlm}ddlm}xJd |fd |fd |fgD]0\}‰‡fd d „| ¡Dƒ}t d|t|ƒ¡q”WdS)Nrz5[pid %d] Memory usage: %0.2f MB (RSS), %0.2f MB (VMS)ir )ÚDocument)ÚModelr)Ú ServerSessionZ DocumentsZSessionsZModelscsg|]}t|ˆƒr|‘qSrR)r")Ú.0Úx)ÚtyprRrSú sz)BokehTornado._log_mem..z uncollected %s: %d)rZProcessrwrxr&r'Z memory_infoZrssZvmsrtrurvÚgcZdocumentr{Zmodelr|rjr}Z get_objectsr8ry) rDrZprocessr‚r{r|r}ÚnameZobjsrR)r€rSrX s(    zBokehTornado._log_memcCs&t d¡x|jD] }| ¡qWdS)NzRunning keep alive job)r&rsrUZ send_ping)rDÚcrRrRrSr\s  zBokehTornado._keep_alive)N)T)$Ú__name__Ú __module__Ú __qualname__Ú__doc__r Zsecret_key_bytesrFr(r*r,r.r0r2rCr_Úpropertyr`r^rrarErGrcrdrfrlrnrorrrÚ coroutinerZrVrXr\Ú __classcell__rRrR)rQrSrCsF`        r).rˆZ __future__rrrrruZ getLoggerr…r&rwZpprintrZtornadorZtornado.iolooprZ tornado.webr ZTornadoApplicationr Z applicationrcr r Zutil.dependenciesrZcontextsrrkrZurlsrrZviews.root_handlerrZviews.static_handlerrr*r(r0r.r,r2Ú__all__rrRrRrRrSÚ s4