5

我一直在研究一个长轮询系统。我使用烧瓶 + mongokit + celery + gevent。

当芹菜任务中的过程完成时，gevent.event.set()不起作用。我需要帮助来解决这个问题。（我之所以同时使用 gevent 和 celery，是因为 Notification 系统中有一个庞大的进程需要处理。）

这是我的示例代码。

 #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
 <body>
   <button>Click me</button>
 </body>
 <script>
   $('button').click(function(e) {
    $.ajax({
     'url': '/set',
     'data': 'uid=1',
     'success': function(data) {
       console.log(data);
     }
    });
    e.preventDefault();
  });

      var poll = function() {
  return $.ajax({
           'url': '/poll',
           'method': 'get',
           'async':true,
           'dataType': 'json',
           'timeout': 10000,
           'success': function(data) { 
             console.log(data);
             setTimeout(poll, 50);
           },
           'error':function (req,sta,er){
             setTimeout(poll, 3000);
           }, 
         });
    };
    poll()
 </script>
4

1 回答 1

4

现在，在 Flask 0.9Flask.app_context中添加了，Flask.app_context您可以获得当前的上下文。

请参阅应用程序上下文。

例如，

from 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))
于 2012-07-20T08:34:29.270 回答