题
如果我想同时运行一些不一定使用路由(可能是守护进程服务)的功能,同时运行应用程序服务器,如何运行给定的模块?
例如:
#some other route functions app.post(...)
#some other concurrent functions
def alarm():
'''
Run this service every X duration
'''
ALARM = 21
try:
while 1:
#checking time and doing something. Then finding INTERVAL
gevent.sleep(INTERVAL)
except KeyboardInterrupt,e:
print 'exiting'
之后我必须像这样使用上面的吗 主要的 ?
gevent.joinall(gevent.spawn(alarm))
app.run(....)
或者
gevent.joinall((gevent.spawn(alarm),gevent.spawn(app.run)))
目标是像守护进程服务一样运行这些警报,完成它们的工作并暂停,而其余服务操作照常工作。服务器也应该同时启动。如果我不在正确的轨道上,请纠正我。
解决方案
Gevent 带有它自己的 WSGI 服务器,所以确实没有必要使用 app.run
. 。服务器是:
两者都提供相同的接口。
您可以使用这些来实现您想要的:
import gevent
import gevent.monkey
gevent.monkey.patch_all()
import requests
from gevent.pywsgi import WSGIServer
# app = YourBottleApp
def alarm():
'''
Run this service every X duration
'''
ALARM = 21
while 1:
#checking time and doing something. Then finding INTERVAL
gevent.sleep(INTERVAL)
if __name__ == '__main__':
http_server = WSGIServer(('', 8080), app)
srv_greenlet = gevent.spawn(http_server.serve_forever)
alarm_greenlet = gevent.spawn(alarm)
try:
gevent.joinall([srv_greenlet, alarm_greenlet])
except KeyboardInterrupt:
http_server.stop()
print 'Quitting'
不隶属于 StackOverflow