Using message_queue=redis doesn't work

[liuqijie6]

I'm currently trying to use gunicorn + flask-scoketIO for multiple jobs
but using message_queue=redis doesn't work

socketIo config

scoketIO server

test result: not print 123, not entering func

[miguelgrinberg]

The SocketIO constructor is missing the app argument. How does this work at all?

[liuqijie6]

Is it the same as what you said when I write this way?
but not working
app.py

[miguelgrinberg]

No, it is not the same. Please make the change I suggested exactly as I put it in my example.

[liuqijie6]

I use scoketIO's factory pattern. If you write as you said, it will lead to a circular import error.

[liuqijie6]

@miguelgrinberg If I comment out message_queue it works fine.

[miguelgrinberg]

The app argument is required. If you get a circular import you have to fix that. You can't omit this argument. Tried to say this several times already and you keep ignoring it.

[liuqijie6]

I try. but dont work.

init.py

__all__ = ["create_app", "BASE_DIR", "flask_func"]

import os
import sys


def flask_func():
    from flask import Flask
    return Flask(__name__)


def create_app():
    from routers import index
    from units.extensions import (executor, cors, cache)
    from routers.soketIo.socketIo_server import socket_io

    app = flask_func()

    """ flask 配置
    https://dormousehole.readthedocs.io/en/latest/config.html
    """
    app.config['EXECUTOR_PROPAGATE_EXCEPTIONS'] = True
    app.config['EXECUTOR_MAX_WORKERS'] = 5
    app.config['EXECUTOR_TYPE'] = 'thread'
    app.config['JSON_AS_ASCII'] = True
    # app.config['JSONIFY_PRETTYPRINT_REGULAR'] = True
    # app.config['UPLOAD_FOLDER'] = f'{os.path.dirname(__file__)}/static/'
    """flask 蓝图注册"""
    app.register_blueprint(index)

    """flask 扩展"""
    executor.init_app(app)
    cors.init_app(app)
    socket_io.init_app(app)
    cache.init_app(app)

    return app

app.py

__all__ = ["app"]

import eventlet

eventlet.monkey_patch()
from __init__ import create_app
from units.extensions import socket_io
from config import CONFIG

app = create_app()

if __name__ == "__main__":
    print(app.url_map)
    host, port = CONFIG.get("web_server", "host"), CONFIG.get("web_server", "port")
    socket_io.run(app, host=host, port=port, debug=False, log_output=True)

units/extensions.py

# __all__ = ["executor", "cors", "socket_io", "cache"]
""" flask 扩展"""

from flask_executor import Executor
from flask_cors import CORS
from flask_socketio import SocketIO, join_room, leave_room, send
from flask_caching import Cache
from config import CONFIG

cache_config = {
    # "DEBUG": True,  # some Flask specific configs
    "CACHE_TYPE": "FileSystemCache",  # Flask-Caching related configs
    "CACHE_DEFAULT_TIMEOUT": 300,
    "CACHE_DIR": "cache",
    "CACHE_THRESHOLD": 2000,  # number of 'files' before start auto-delete

}

executor = Executor()
cors = CORS()
password, host, port = CONFIG.get("redis", "password"), CONFIG.get("redis", "host"), CONFIG.get("redis", "port")

from __init__ import flask_func

socket_io = SocketIO(app=flask_func(), cors_allowed_origins='*',
                     async_mode="eventlet",  # eventlet  gevent # threading
                     engineio_logger=True,
                     logger=True,
                     # message_queue=f'redis://:{password}@{host}:{port}/0',
                     message_queue=f'redis://127.0.0.1:6379/0',
                     )
cache = Cache(config=cache_config)

output, but no print.

[miguelgrinberg]

I think you need to spend some time working with simpler application structures. When I said that you have to pass the app instance I did not mean that you have to create a different app instance and use that. I meant that you need to pass the main application instance, the one that you use for your Flask application routes.

I suggest you work with some simpler examples to understand how to structure your Flask application, because what you are doing is extremely messy and prone to errors.

Start from https://github.com/miguelgrinberg/Flask-SocketIO-Chat for example. Then if you want to see something a bit more advanced, try https://github.com/miguelgrinberg/flack.

[liuqijie6]

thanks

[liuqijie6]

https://github.com/miguelgrinberg/Flask-SocketIO-Chat

I have a question . Why don't you write SocketIO(app) here as you said above?

Currently my writing is very similar to this。

[miguelgrinberg]

This is standard for all Flask extensions. You initialize them with no arguments, then pass the arguments in the init_app() call.