Flask Socket.IO Redisエラーが発生しましたが、RabbitMQを使用しています

Question

Flaskでアプリケーションを作成しています。メッセージブローカーとしてもRabbitMQを使用しています。私はまた、SocketIOを使ってセロリのワーカーのステータスをクライアントに報告します。アプリを実行しているときに次のエラーが表示されます。

なぜこのエラーが発生するのか教えてください。

app.py

app = Flask(__name__) 
app.config['SECRET_KEY'] = '' 

app.config.update(
CELERY_BROKER_URL = 'amqp://localhost//', 
CELERY_RESULT_BACKEND='amqp://localhost//' 
) 

socketio = SocketIO(app, message_queue='amqp://') 
celery = make_celery(app) 


@app.route('/') 
def my_form(): 
    return render_template("form.html") 

はJavaScript

var socket = io.connect(location.protocol + '//' + document.domain + ':' + location.port); 

make_celeryモジュール

def make_celery(app): 
    celery = Celery(app.import_name, backend=app.config['CELERY_RESULT_BACKEND'], 
        broker=app.config['CELERY_BROKER_URL']) 
    celery.conf.update(app.config) 
    TaskBase = celery.Task 
    class ContextTask(TaskBase): 
     abstract = True 
     def __call__(self, *args, **kwargs): 
      with app.app_context(): 
       return TaskBase.__call__(self, *args, **kwargs) 
    celery.Task = ContextTask 
    return celery 

Answer 1

おっと、エラーメッセージが別のモジュールから貼り付けコピー/されている、と私は更新を忘れてしまいましたそれ。メッセージには、「Kombuはgeventで動作するように猿のパッチを当てたソケットライブラリが必要です。

基本的に、これは猿のパッチがなければ、ソケット操作が発行されたときにgeventがブロックされるということです。この詳細については、http://www.gevent.org/gevent.monkey.htmlを参照してください。