σ mάJ]c@`smdZddlmZmZmZmZddlZejeƒZ ddl Z ddl Z ddl Z ddl Z ddlmZddlmZddlmZddlmZdd lmZmZmZmZdd lmZdd lmZd d lm Z m!Z!d dl m"Z"m#Z#dZ$de%fd„ƒYZ&de&fd„ƒYZ'defd„ƒYZ(dS(uΤ Provide basic Bokeh server objects that use a Tornado ``HTTPServer`` and ``BokeTornado`` Tornado Application to service Bokeh Server Applications. There are two public classes in this module: :class:`~bokeh.server.server.BaseServer` This is a lightweight class to explicitly coordinate the components needed to run a Bokeh server (A :class:`~bokeh.server.tornado.BokehTornado` instance, and Tornado ``HTTPServer`` and a Tornado ``IOLoop``) :class:`~bokeh.server.server.Server` This higher-level convenience class only needs to be configured with Bokeh :class:`~bokeh.application.application.Application` instances, and will automatically create and coordinate the lower level Tornado components. i(tabsolute_importtdivisiontprint_functiontunicode_literalsN(t HTTPServer(tIOLoopi(t __version__(t Application(tBooltInttListtString(tDEFAULT_SERVER_PORT(tOptionsi(t bind_socketstcreate_hosts_whitelist(t BokehTornadot(DEFAULT_WEBSOCKET_MAX_MESSAGE_SIZE_BYTESu BaseServeruServert BaseServercB`s‰eZdZd„Zed„ƒZd„Zed„Zd„Z d„Z d„Z d d„Z d d d „ZeZd „Zd „ZRS(u4 Explicitly coordinate the level Tornado components required to run a Bokeh server: * A Tornado ``IOLoop`` to run the Bokeh server machinery. * a ``BokehTornado`` Tornado application that defines the Bokeh server machinery. * a Tornado ``HTTPServer`` to direct HTTP requests All three of these components must be passed to ``BaseServer``, which will initialize the ``BokehTornado`` instance on the ``io_loop``. The ``http_server`` must have been previously created and initialized with the ``BokehTornado`` instance. cC`sAt|_t|_||_||_||_|jj|ƒdS(u7 Create a ``BaseServer`` instance. Args: io_loop (IOLoop) : A Tornado ``IOLoop`` to run the Bokeh Tornado application on. tornado_app (BokehTornado) : An instance of the Bokeh Tornado application that generates Bokeh Documents and Sessions. http_server (HTTPServer) : A Tornado ``HTTPServer`` to service HTTP requests for Bokeh applications. Should have already be configured with the ``tornado_app`` when created. N(tFalset_startedt_stoppedt_httpt_loopt_tornadot initialize(tselftio_loopt tornado_appt http_server((s2lib/python2.7/site-packages/bokeh/server/server.pyt__init__Vs      cC`s|jS(uG The Tornado ``IOLoop`` that this Bokeh Server is running on. (R(R((s2lib/python2.7/site-packages/bokeh/server/server.pyRqscC`s0|j stdƒ‚t|_|jjƒdS(u Install the Bokeh Server and its background tasks on a Tornado ``IOLoop``. This method does *not* block and does *not* affect the state of the Tornado ``IOLoop`` You must start and stop the loop yourself, i.e. this method is typically useful when you are already explicitly managing an ``IOLoop`` yourself. To start a Bokeh server and immediately "run forever" in a blocking manner, see :func:`~bokeh.server.server.BaseServer.run_until_shutdown`. uAlready startedN(RtAssertionErrortTrueRtstart(R((s2lib/python2.7/site-packages/bokeh/server/server.pyR!xs  cC`s@|j stdƒ‚t|_|jj|ƒ|jjƒdS(uK Stop the Bokeh Server. This stops and removes all Bokeh Server ``IOLoop`` callbacks, as well as stops the ``HTTPServer`` that this instance was configured with. Args: fast (bool): Whether to wait for orderly cleanup (default: True) Returns: None uAlready stoppedN(RRR RtstopR(Rtwait((s2lib/python2.7/site-packages/bokeh/server/server.pyR"‰s cc`s|jjƒV|jjƒdS(u Stop listening on ports. The server will no longer be usable after calling this function. Returns: None N(Rtclose_all_connectionsR"(R((s2lib/python2.7/site-packages/bokeh/server/server.pytunlistenœscC`sy|js|jƒntj|jƒtjtj|jƒy|jjƒWnt k rjt dƒnX|j ƒdS(u Run the Bokeh Server until shutdown is requested by the user, either via a Keyboard interrupt (Ctrl-C) or SIGTERM. Calling this method will start the Tornado ``IOLoop`` and block all execution in the calling process. Returns: None u Interrupted, shutting downN( RR!tatexittregistert_atexittsignaltSIGTERMt_sigtermRtKeyboardInterrupttprintR"(R((s2lib/python2.7/site-packages/bokeh/server/server.pytrun_until_shutdown§s   cC`s|jj||ƒS(uk 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 (Rt get_session(Rtapp_patht session_id((s2lib/python2.7/site-packages/bokeh/server/server.pyR/½scC`sS|dk r|jj|ƒSg}x*|jjD]}||jj|ƒ7}q/W|S(ui Gets all currently active sessions for applications. Args: app_path (str, optional) : The configured application path for the application to return sessions for. If None, return active sessions for all applications. (default: None) Returns: list[ServerSession] N(tNoneRt get_sessionst app_paths(RR0t all_sessionstpath((s2lib/python2.7/site-packages/bokeh/server/server.pyR3Ξs utabcC`s”|jdƒstdƒ‚nd}|jd k rN|jdkrN|j}nd||j|j|f}ddlm}||d|d |ƒd S( uΫ Opens an app in a browser window or tab. This method is useful for testing or running Bokeh server applications on a local machine but should not call when running Bokeh server for an actual deployment. Args: app_path (str) : the app path to open The part of the URL after the hostname:port, with leading slash. browser (str, optional) : browser to show with (default: None) For systems that support it, the **browser** argument allows specifying which browser to display in, e.g. "safari", "firefox", "opera", "windows-default" (see the ``webbrowser`` module documentation in the standard lib for more details). new (str, optional) : window or tab (default: "tab") If ``new`` is 'tab', then opens a new tab. If ``new`` is 'window', then opens a new window. Returns: None u/uapp_path must start with a /u localhostuuhttp://%s:%d%s%si(tviewtbrowsertnewN(t startswitht ValueErrortaddressR2tporttprefixtbokeh.util.browserR7(RR0R8R9taddress_stringturlR7((s2lib/python2.7/site-packages/bokeh/server/server.pytshowβs cC`sC|jr dSt|_tjdƒ|js?|jdtƒndS(NuShutdown: cleaning upR#(t _atexit_ranR tlogtdebugRR"R(R((s2lib/python2.7/site-packages/bokeh/server/server.pyR(s     cC`s+td|fƒ|jj|jjƒdS(Nu!Received signal %d, shutting down(R-Rtadd_callback_from_signalR"(Rtsignumtframe((s2lib/python2.7/site-packages/bokeh/server/server.pyR+sN(t__name__t __module__t__doc__RtpropertyRR!R R"R%R.R/R2R3RBRRCR(R+(((s2lib/python2.7/site-packages/bokeh/server/server.pyRDs      % tServercB`sYeZdZddd„Zed„ƒZed„ƒZed„ƒZed„ƒZ RS(u§ A high level convenience class to run a Bokeh server. This class can automatically coordinate the three the base level components required to run a Bokeh server: * A Tornado ``IOLoop`` to run the Bokeh server machinery. * a ``BokehTornado`` Tornado application that defines the Bokeh server machinery. * a Tornado ``HTTPServer`` to direct HTTP requests This high level ``Server`` class has some limitations. In particular, it is not possible to set an explicit ``io_loop`` and ``num_procs`` other than 1 at the same time. To do that, it is necessary to use ``BaseServer`` and coordinate the three components above explicitly. c `sρtjdttjfƒddlm}ddlm‰t |ƒr[t ||ƒƒ}nt |t ƒrzi|d6}nxt |j ƒƒD]k\}}t |ƒrΎt ||ƒƒ||gsics`s|]}|jVqdS(N(t safe_to_fork(RQtapp((s2lib/python2.7/site-packages/bokeh/server/server.pys rsutUser application code has run before attempting to start multiple processes. This is considered an unsafe operation.uŠSetting both num_procs and io_loop in Server is incompatible. Use BaseServer to coordinate an explicit IOLoop and multi-process HTTPServeruwin32u&num_procs > 1 not supported on Windowsuxheaderstextra_websocket_originsR>tindext websocket_max_message_size_bytesN(2RDtinfoRttornadotversiont#bokeh.application.handlers.functionRNt-bokeh.application.handlers.document_lifecycleROtcallableRRPtlisttitemstallt _handlerstaddt _ServerOptsR=t_portR<t_addressR>t_prefixRVt_indext num_procstvaluesRR2t RuntimeErrortsystplatformt setdefaultt use_xheadersRRtallow_websocket_originRtwebsocket_max_message_sizeRR!t add_socketst ExceptiontcloseRtcurrenttsuperRMR(Rt applicationsRthttp_server_kwargstkwargsRNtktvtoptstsocketsRURRts((ROs2lib/python2.7/site-packages/bokeh/server/server.pyR.s`+                  cC`s|jS(u> A path to a Jinja2 template to use for index at "/" (Rg(R((s2lib/python2.7/site-packages/bokeh/server/server.pyRVscC`s|jS(uG The configured URL prefix to use for all Bokeh server paths. (Rf(R((s2lib/python2.7/site-packages/bokeh/server/server.pyR>€scC`s|jS(u[ The configured port number that the server listens on for HTTP requests. (Rd(R((s2lib/python2.7/site-packages/bokeh/server/server.pyR=«scC`s|jS(uW The configured address that the server listens on for HTTP requests. (Re(R((s2lib/python2.7/site-packages/bokeh/server/server.pyR<³sN( RIRJRKR2RRLRVR>R=R<(((s2lib/python2.7/site-packages/bokeh/server/server.pyRMs oRccB`s³eZeddddƒZedd ddƒZededdƒZeddddƒZ edd ddƒZ e edd dd ƒZ e dedd ƒZededd ƒZRS( tdefaultithelpu The number of worker processes to start for the HTTP server. If an explicit ``io_loop`` is also configured, then ``num_procs=1`` is the only compatible value. Use ``BaseServer`` to coordinate an explicit ``IOLoop`` with a multi-process HTTP server. A value of 0 will auto detect number of cores. Note that due to limitations inherent in Tornado, Windows does not support ``num_procs`` values greater than one! In this case consider running multiple Bokeh server instances behind a load balancer. uD The address the server should listen on for HTTP requests. uH The port number the server should listen on for HTTP requests. uu9 A URL prefix to use for all Bokeh server paths. u> A path to a Jinja2 template to use for the index "/" uτ 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" is used. uγ Whether to have the Bokeh server override the remote IP and URI scheme and protocol for all requests with ``X-Real-Ip``, ``X-Forwarded-For``, ``X-Scheme``, ``X-Forwarded-Proto`` headers (if they are provided). ux Set the Tornado ``websocket_max_message_size`` value. NOTE: This setting has effect ONLY for Tornado>=4.5 N(RIRJR RhR R2R<R R=R>RVR RoRRRnRRp(((s2lib/python2.7/site-packages/bokeh/server/server.pyRcΑs              (u BaseServeruServer()RKt __future__RRRRtloggingt getLoggerRIRDR&R)RkRYttornado.httpserverRttornado.ioloopRtRt applicationRtcore.propertiesRR R R t resourcesR t util.optionsR tutilRRRRt__all__tobjectRRMRc(((s2lib/python2.7/site-packages/bokeh/server/server.pyts*"     "Φ§