• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Python ioloop.start函数代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Python中tornado.ioloop.start函数的典型用法代码示例。如果您正苦于以下问题:Python start函数的具体用法?Python start怎么用?Python start使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。



在下文中一共展示了start函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。

示例1: main

def main():
    try:
        """
        defining/parsing the options
        """
        define("port", default=8082, help="run on the given port", type=int)
        define("debug", default=False, help="run in debug mode", type=bool)
        tornado.options.parse_command_line()        
        logging.debug(options.logging)
        """
        initalising applications
        """ 
        app = MyApplication(options)

        """
        starting tornado server
        """
        http_server = tornado.httpserver.HTTPServer(app)
        http_server.listen(options.port)
        ioloop = tornado.ioloop.IOLoop.instance()
        tornado.autoreload.add_reload_hook(app.reloadTasks)
        tornado.autoreload.start(ioloop)
        ioloop.start()

    except KeyboardInterrupt:
        pass
    except:
        print traceback.format_exc()
开发者ID:louhibi,项目名称:tornado_app_squeleton,代码行数:28,代码来源:main.py


示例2: run

def run():

    tornado.httpclient.AsyncHTTPClient.configure("tornado.curl_httpclient.CurlAsyncHTTPClient")

    xmpp = XMPPHandler('[email protected]', 'popcorn', 'http://localhost:8080/callback')
    xmpp.register_plugin('xep_0030')

    if xmpp.connect():
        xmpp.process(block=False)

    application = tornado.web.Application([
            tornado.web.URLSpec(r"/send", SendHandler, {'xmpp': xmpp}),
            tornado.web.URLSpec(r"/callback", CallbackProxyHandler, {'callback': "http://localhost:8080/testcallback"}),
            tornado.web.URLSpec(r"/testcallback", TestCallbackHandler),
        ],
        )

    application.listen(8080)

    ioloop = tornado.ioloop.IOLoop.instance()

    try:
        ioloop.start()
    except KeyboardInterrupt:
        print "I'm out"
        xmpp.disconnect()    
开发者ID:whardier,项目名称:jabberhooky,代码行数:26,代码来源:__main__.py


示例3: _actually_run

    def _actually_run(self):

        import logging
        import tornado.options

        logging.getLogger().setLevel(logging.INFO)
        tornado.options.enable_pretty_logging()

        import tornado.web
        import tornado.httpserver
        import tornado.ioloop
        import tornado.autoreload

#        import hashlib
#        import random
#        m = hashlib.md5()
#        m.update((str(random.random()) + str(random.random())).encode('utf-8'))
#        secret = m.digest()
#        print("SECRET:", secret)
        secret = random_key(100)
        secret = "reiujgerjregiuj"

        app = tornado.web.Application(self.handlers, static_path=self.static, cookie_secret=secret)

        http_server = tornado.httpserver.HTTPServer(app)
        http_server.listen(self.port)
        logging.info("waiting for requests on http://%s:%d" % (self.hostname or "localhost", self.port))
        ioloop = tornado.ioloop.IOLoop.instance()
        tornado.autoreload.start(ioloop)
        ioloop.start()
开发者ID:EdwinGriffin,项目名称:TornadoSchoolWebsite,代码行数:30,代码来源:server.py


示例4: main

    def main(self):

        #settings passed to tornado app
        tornado_settings = {
            "template_path": settings.template_path,
            "static_path": settings.static_path,
            "cookie_secret": settings.cookie_secret,
            "login_url": settings.login_url,
        }

        #init a logger
        self.init_logging(settings.log)

        #routes
        routes = self.init_routes()

        self._application = web.Application(routes,**tornado_settings)

        http_server = httpserver.HTTPServer(self._application)
        http_server.listen(settings.port)

        Log.info("Ready and listening")

        ioloop = tornado.ioloop.IOLoop().instance()
        autoreload.start(ioloop)
        try:
            ioloop.start()
        except KeyboardInterrupt:
            pass
开发者ID:uniwolf,项目名称:tornado-bootstrap,代码行数:29,代码来源:server.py


示例5: main

def main():
    pika_client = PikaClient()
    database={}
    database['g'] = 'f'
    database['gg'] = 'ff'
    database['ggg'] = 'gff'
    global g_port;
    
    application = tornado.web.Application(
    [(r'/sensor/.*', SensorHandler,dict(database=database)),(r'/.*',MainHandler,dict(database=database))],
#        [(r'/index.html',MainHandler)],
#        [(r'/tom/*',SensorHandler),(r'/index.html',MainHandler)],
#        **{'pika_client': pika_client, 'debug': True}

        #     **{'pika_client': pika_client, 'debug': True}
        #     [(r'/tom/*', Fib)],
             **{'pika_client': pika_client, 'debug': True}
    )
    try:
        port = int(sys.argv[1])  # $ python tornadoweb_pika.py 80
    except:
        port = 8000 
    g_port = port
    application.listen(port)
    ioloop = tornado.ioloop.IOLoop.instance()
    ioloop.add_timeout(time.time() + .1, pika_client.connect)
    ioloop.start()
开发者ID:aaravindanarun,项目名称:random_bits,代码行数:27,代码来源:front.py


示例6: run_service

def run_service(port, address='0.0.0.0', configuration=None):
    ioloop = tornado.ioloop.IOLoop.instance()
    app = create_service()
    app.listen(port, address)
    app.logger.info('Started THC service on %s:%s', address, port)

    def discovered_service(index, fullname, host, port, txtRecord):
        app.logger.info('Found service: %[email protected]%s:%s', fullname, host, port)

    def lost_service(index, name, regtype, domain):
        app.logger.info('Lost service: %s.%[email protected]%s', name, regtype, domain)

    app.mdns = mdns_util.MDNS(ioloop)
    app.mdns.register('TurretHostController', '_thc_http._tcp', 'local', port)
    app.logger.info('Registered THC service.')

    app.mdns.discover('_thc_http._tcp', discovered_service, lost_service)
    app.logger.info('Listening for neighboring services.')

    try:
        ioloop.start()
    except KeyboardInterrupt:
        app.logger.info('Cancelling service discovery.')
        app.mdns.disable_discovery('_thc_http._tcp')
        app.logger.info('Cancelling service broadcast.')
        app.mdns.unregister('TurretHostController', '_thc_http._tcp', 'local',
                            port)

        app.logger.info('Shutting down.')
开发者ID:nickcoutsos,项目名称:python-turret-host-controller,代码行数:29,代码来源:server.py


示例7: main

def main():
    parse_command_line()
    http_server = tornado.httpserver.HTTPServer(Application())
    http_server.listen(options.port)
    ioloop = tornado.ioloop.IOLoop().instance()
    autoreload.start(ioloop)
    ioloop.start()
开发者ID:ErDmKo,项目名称:pyparser,代码行数:7,代码来源:server.py


示例8: main

def main():
	options.parse_command_line()
	# set up database connection
	client = pymongo.MongoClient(options.dbhost, options.dbport)
	database = client[options.dbname]
	# list of handlers
	handlers = []
	# generate list
	for handler in settings.handlers:
		# import the handler we need
		handler_class = __import__(handler)
		# register the URLS with the handler
		for routes in handler_class.routes:
			# each handler exports a urls list and class
			endpoint, class_name = routes
			url = ('/api' + endpoint, class_name, dict(database=database))
			# append to our handlers list
			handlers.append(url)

	ioloop = tornado.ioloop.IOLoop.instance()
	# register our handlers with our application and give it our settings
	application = tornado.web.Application(handlers, **settings.settings)
	http_server = tornado.httpserver.HTTPServer(application)
	# listen on port defined in options
	http_server.listen(options.port)
	#start ioloop
	ioloop.start()
开发者ID:mattgen88,项目名称:tornado-demo,代码行数:27,代码来源:app.py


示例9: run

def run():
    logging.basicConfig(level=logging.DEBUG)
    tornado.options.parse_command_line()
    http_server = tornado.httpserver.HTTPServer(Application())
    http_server.listen(options.port)
    ioloop = tornado.ioloop.IOLoop.instance()
    ioloop.start()
开发者ID:zzzombat,项目名称:motorchan,代码行数:7,代码来源:application.py


示例10: __call__

    def __call__(self,*args,**options):
        from thepian.conf import structure
        from os.path import join
        
        sys.path.append(structure.PROJECT_DIR)
        
        from thepian.conf import ensure_target_tree
        ensure_target_tree(structure.PROJECT_DIR)
        #TODO part add_themaestro functionality

        import logging
        LOG_FILENAME = join(structure.PROJECT_DIR,'testing.log')
        logging.basicConfig(filename=LOG_FILENAME,level=logging.DEBUG)
                
        from mediaserver import Application, HTTPServer
        import tornado.httpserver
        import tornado.ioloop
        import tornado.autoreload
        
        # print "js dir =", structure.JS_DIR
        # tornado.options.parse_command_line()
        ioloop = tornado.ioloop.IOLoop.instance()

        sock_path = join(structure.PROJECT_DIR,"mediasite.sock")
        port_no = structure.MEDIASERVER_PORT
        if port_no:
            http_server = tornado.httpserver.HTTPServer(Application(ioloop=ioloop))
            http_server.listen(port_no)
        else:
            http_server = HTTPServer(Application(ioloop=ioloop))
            http_server.listen(0,address = sock_path)
        
        tornado.autoreload.start(io_loop=ioloop)
        ioloop.start()
开发者ID:thepian,项目名称:themaestro,代码行数:34,代码来源:trialrun.py


示例11: run_proxy

def run_proxy(bind, debug=False):
    #  /proxy/[?](?P<url>.*) # r'/proxy/[?](.*)' # r'/proxy/(.*)'
    handler = [(r'/proxy/', ProxyHandler, {})]
    app = tornado.web.Application(handler, debug=debug)
    app.listen(bind[1], bind[0])
    ioloop = tornado.ioloop.IOLoop.instance()
    ioloop.start()
开发者ID:passiweinberger,项目名称:nostradamIQ,代码行数:7,代码来源:proxy.py


示例12: main

def main():
    app = LetSpotify()
    http_server = tornado.httpserver.HTTPServer(app)
    http_server.listen(options.port)
    ioloop = tornado.ioloop.IOLoop.instance()

    app.db = momoko.Pool(
        dsn=settings['dsn'],
        size=5,
        raise_connect_errors=False,
        reconnect_interval=50,
        ioloop=ioloop,
    )

    future = app.db.connect()
    ioloop.add_future(future, lambda f: ioloop.stop())
    ioloop.start()
    future.result()  # raises exception on connection error

    Service.users = Users(app.db)
    Service.facebook = FacebookAPI(app.db)
    Service.rooms = Rooms(app.db)
    Service.login_token = LoginToken(app.db)

    ioloop.start()
开发者ID:LetSpotify,项目名称:letspotify-server,代码行数:25,代码来源:app.py


示例13: __init__

 def __init__(self):
     self.handlers = routs
     ioloop = tornado.ioloop.IOLoop.instance()
     self.settings = dict(
         debug=config.debug,
         template_path=config.template_path,
         static_path=config.static_path,
         cookie_secret=config.cookie_secret,
         login_url=config.login_url
     )
     super(Application, self).__init__(self.handlers, **self.settings)
     self.db_async = momoko.Pool(
         dsn=config.get_db_url(options.db_name,
                               options.db_user_name,
                               options.db_host,
                               options.db_port,
                               options.db_password),
         size=1,
         ioloop=ioloop,
         cursor_factory=DictCursor
     )
     future = self.db_async.connect()
     ioloop.add_future(future, lambda x: ioloop.stop())
     ioloop.start()
     future.result()
开发者ID:spaun299,项目名称:wood_stuff_shop,代码行数:25,代码来源:run.py


示例14: main

def main():
    try:
        # create an api for the webserver
        api = HotTubAPI();
        app = tornado.web.Application(
            handlers=[
                (r"/images/(.*)", tornado.web.StaticFileHandler, {"path":"./images"}),
                (r"/css/(.*)", tornado.web.StaticFileHandler, {"path":"./css"}),
                (r"/js/(.*)", tornado.web.StaticFileHandler, {"path":"./js"}),
                (r"/*", IndexHandler),
                (r"/twilio.api", TwilioHandler, dict(api=api)),
                (r"/ws", WebSocketHandler, dict(api=api))
            ]
        )
        server = tornado.httpserver.HTTPServer(app)
        port = 9999
        server.listen(port,address="0.0.0.0")
        print "Tornado listening on port: %s" % port

        ioloop = tornado.ioloop.IOLoop.instance()
        set_ping(ioloop, timedelta(seconds=2))
        ioloop.start()
    except KeyboardInterrupt:
        print '^C received, shutting down server'
        api.close()
        server.stop();
开发者ID:pwschuurman,项目名称:hottub_controller,代码行数:26,代码来源:webserver.py


示例15: start_server

def start_server(args):
    app = Flask(__name__)
    app.config['SECRET_KEY'] = 'secret'
    app.jinja_env.globals['static'] = static

    blueprint.url_prefix = args.url_prefix
    app.register_blueprint(blueprint)

    # app.run(port=args.port, debug=args.debug)

    wsgi_app = tornado.wsgi.WSGIContainer(app)
    condajs_ws = sockjs.tornado.SockJSRouter(views.CondaJsWebSocketRouter, '/condajs_ws')
    routes = condajs_ws.urls
    routes.append((r".*", tornado.web.FallbackHandler, dict(fallback=wsgi_app)))
    application = tornado.web.Application(routes, debug=args.debug)

    try:
        application.listen(args.port)
    except OSError as e:
        print("There was an error starting the server:")
        print(e)
        return

    ioloop = tornado.ioloop.IOLoop.instance()
    if not args.debug:
        callback = lambda: webbrowser.open_new_tab('http://localhost:%s' % args.port)
        ioloop.add_callback(callback)
    ioloop.start()
开发者ID:conda,项目名称:conda-ui,代码行数:28,代码来源:__init__.py


示例16: __init__

    def __init__(self):
        handlers = [
            (r"/", AllLists),
            (r"/create/", CreateLists),
        ]
        settings = dict(
            todo_title=u"ToDo",
            template_path=os.path.join(os.path.dirname(__file__), "templates"),
            static_path=os.path.join(os.path.dirname(__file__), "static"),
            xsrf_cookies=True,
            cookie_secret=base64.b64encode(uuid.uuid4().bytes + uuid.uuid4().bytes),
            login_url="/auth/login",
            debug=True,
        )

        super(Application, self).__init__(handlers, **settings)

        ioloop = tornado.ioloop.IOLoop.instance()
        self.db = momoko.Pool(
            dsn='dbname=todo user={0} password={1} '
                'host=localhost port=5432'.format(USERNAME, PASSWORD),
            size=1,
            ioloop=ioloop,
            cursor_factory=psycopg2.extras.RealDictCursor
        )

        future = self.db.connect()
        ioloop.add_future(future, lambda f: ioloop.stop())
        ioloop.start()
        future.result()
开发者ID:VKotsovskyi,项目名称:tornadoapp,代码行数:30,代码来源:todo.py


示例17: serve

 def serve(self):
     self.app.listen(8888)
     ioloop = tornado.ioloop.IOLoop.instance()
     update_cb = tornado.ioloop.PeriodicCallback(
         self.update_status, 100, ioloop)
     update_cb.start()
     ioloop.start()
开发者ID:maklaut,项目名称:yandex-tank-api,代码行数:7,代码来源:webserver.py


示例18: main

def main():
    global server_state

    parse_command_line()

    ioloop = tornado.ioloop.IOLoop.instance()

    application = ExproxymentApplication()

    if options.soft_sticky and options.hard_sticky:
        raise Exception("can't be both soft_sticky and hard_sticky")

    if options.backends:
        backends = parse_backends(options.backends)
        backends = [Backend(host['host'], host['port'])
                    for host in backends]
        server_state.set_backends(backends)

    if options.weights:
        weights = parse_weights(options.weights)
        server_state.weights = weights

    HealthDaemon(ioloop).start()
    application.listen(options.port)

    logger.info("Starting on :%d", options.port)
    ioloop.start()
开发者ID:ketralnis,项目名称:exproxyment,代码行数:27,代码来源:server.py


示例19: main

def main():
    tornado.options.parse_command_line()
    ioloop = tornado.ioloop.IOLoop.instance()
    http_server = tornado.httpserver.HTTPServer(GovLove(ioloop))
    http_server.listen(options.port)
    tornado.autoreload.start()
    ioloop.start()
开发者ID:govdata,项目名称:govdata-core,代码行数:7,代码来源:run.py


示例20: main

def main():
    """ main program, start local server """
    app = make_app()
    app.listen(8080)
    ioloop = tornado.ioloop.IOLoop.instance()
    signal.signal(signal.SIGINT, lambda sig, frame: ioloop.add_callback_from_signal(on_shutdown))
    ioloop.start()
开发者ID:HenryZhang990,项目名称:ds-1007-project,代码行数:7,代码来源:run.py



注:本文中的tornado.ioloop.start函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Python ioloop.stop函数代码示例发布时间:2022-05-27
下一篇:
Python ioloop.install函数代码示例发布时间:2022-05-27
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap