@H_502_1@我一直在研究长轮询系统.我用烧瓶mongokit芹菜gevent.
@H_502_1@当进入芹菜任务时,完成gevent.event.set()不能正常工作.所以我想帮助解决这个问题.(我之所以与celery同时使用gevent,在Notification系统中有很大的处理过程)
@H_502_1@这是我的示例代码.
@H_502_1@
#server.py
@celery.task()
def doing_task(uid,message):
notification = Notification() # this is a notification Model
notification.add(request.args.get('to'),some_notification)
app.event.set()
app.event.clear()
@app.route('/main')
def main():
return render_template('main.html')
@app.route('/set')
def set():
doing_task.delay(request.args.get('uid'),'Notify')
return 'OK'
@app.route('/poll')
def poll():
uid = request.args.get('uid')
app.event.wait()
if is_authorized(uid): #uid 1 is a authorized account
return Notification().get(uid)
#main.html
最佳答案
现在,在Flask 0.9中添加了Flask.app_context,使用Flask.app_context可以获得当前的上下文.
@H_502_1@见Application Context.
@H_502_1@例如,
@H_502_1@
原文链接：https://www.f2er.com/python/439332.htmlfrom flask import Flask
from celery import Celery
app = Flask(__name__)
celery = Celery(__name__)
@celery.task
def hello():
# Also,you are able to deal with current request as use test_request_context
with app.app_context():
print current_app
with app.test_request_context() as request:
print('Hello {0!r}'.format(request))