Импортировать экземпляр flask-socketio из файла верхнего уровня? - PullRequest
Новая
       13

Импортировать экземпляр flask-socketio из файла верхнего уровня?

0 голосов
/ 03 июня 2019

У меня есть файл run.py на верхнем уровне моего каталога, где я инициализирую колбу-сокет. Этот файл выглядит так: 

# /run.py
#!/usr/bin/env python

import os
from src.config import app_config
from dotenv import load_dotenv, find_dotenv
from flask_socketio import SocketIO
from src.app import create_app

load_dotenv(find_dotenv())

env_name = os.getenv('FLASK_ENV')
app = create_app(env_name)
socketio = SocketIO(app, async_mode=None)

if __name__ == '__main__':
  port = os.getenv('PORT')
  # run app
  socketio.run(app, host='0.0.0.0', port=port)

Мой файл app.py находится под src/app.py и выглядит следующим образом: 

def create_app(env_name):
  """
  Create app
  """

  # app initiliazation
  app = Flask(__name__)
  app.config.from_object(app_config[env_name])

  # initializing bcrypt and db
  bcrypt.init_app(app)
  db.init_app(app)

  app.register_blueprint(message_blueprint, url_prefix='/api/v1/message')

  return app

Я пытаюсь импортировать экземпляр socketio в /src/views/MessageView.py

Мой MessageView.py файл выглядит так: 

from ..models import db
from __main__ import socketio
from ..shared.Authentication import Auth
from threading import Lock
from flask import Flask, render_template, session, request, \
        copy_current_request_context, g, Blueprint, json, Response
from flask_socketio import SocketIO, emit, join_room, leave_room, \
        close_room, rooms, disconnect

message_api = Blueprint('message_api', __name__)
thread = None
thread_lock = Lock()

def background_thread():
    """Example of how to send server generated events to clients."""
    count = 0
    while True:
        socketio.sleep(10)
        count += 1
        socketio.emit('my_response',
                      {'data': 'Server generated event', 'count': count},
                      namespace='/test')


@message_api.route('/')
def index():
    return render_template('index.html', async_mode=socketio.async_mode)


@socketio.on('my_event', namespace='/test')
def test_message(message):
    session['receive_count'] = session.get('receive_count', 0) + 1
    emit('my_response',
         {'data': message['data'], 'count': session['receive_count']})


@socketio.on('my_broadcast_event', namespace='/test')
def test_broadcast_message(message):
    session['receive_count'] = session.get('receive_count', 0) + 1
    emit('my_response',
         {'data': message['data'], 'count': session['receive_count']},
         broadcast=True)


@socketio.on('join', namespace='/test')
def join(message):
    join_room(message['room'])
    session['receive_count'] = session.get('receive_count', 0) + 1
    emit('my_response',
         {'data': 'In rooms: ' + ', '.join(rooms()),
          'count': session['receive_count']})


@socketio.on('leave', namespace='/test')
def leave(message):
    leave_room(message['room'])
    session['receive_count'] = session.get('receive_count', 0) + 1
    emit('my_response',
         {'data': 'In rooms: ' + ', '.join(rooms()),
          'count': session['receive_count']})


@socketio.on('close_room', namespace='/test')
def close(message):
    session['receive_count'] = session.get('receive_count', 0) + 1
    emit('my_response', {'data': 'Room ' + message['room'] + ' is closing.',
                         'count': session['receive_count']},
         room=message['room'])
    close_room(message['room'])


@socketio.on('my_room_event', namespace='/test')
def send_room_message(message):
    session['receive_count'] = session.get('receive_count', 0) + 1
    emit('my_response',
         {'data': message['data'], 'count': session['receive_count']},
         room=message['room'])


@socketio.on('disconnect_request', namespace='/test')
def disconnect_request():
    @copy_current_request_context
    def can_disconnect():
        disconnect()

    session['receive_count'] = session.get('receive_count', 0) + 1
    # for this emit we use a callback function
    # when the callback function is invoked we know that the message has been
    # received and it is safe to disconnect
    emit('my_response',
         {'data': 'Disconnected!', 'count': session['receive_count']},
         callback=can_disconnect)


@socketio.on('my_ping', namespace='/test')
def ping_pong():
    emit('my_pong')


@socketio.on('connect', namespace='/test')
def test_connect():
    global thread
    with thread_lock:
        if thread is None:
            thread = socketio.start_background_task(background_thread)
    emit('my_response', {'data': 'Connected', 'count': 0})


@socketio.on('disconnect', namespace='/test')
def test_disconnect():
    print('Client disconnected', request.sid)

Последние два дня я провела в интернете, пытаясь найти способ исправить это. Я получаю ошибку: 

ImportError: cannot import name 'socketio'

Я пробовал относительный импорт, а также monkey_patching. Но каждый раз ошибка все же происходит. Будем весьма благодарны за любые идеи о том, как решить проблему.

P.S. Я адаптирую пример, который Мигель имеет в своем репозитории с колбой, расположенном здесь: ссылка . В его примере все находится в одном файле, который будет работать в базовом приложении, однако для приложения с 50+ конечными точками API, что не является оптимальным решением.

1 Ответ

1 голос
/ 03 июня 2019

Почему у вас есть объект SocketIO в модуле run.py верхнего уровня?Поскольку это расширение Flask, лучше иметь его вместе со всеми другими расширениями в src / app.py: 

from flask_socketio import SocketIO

socketio = SocketIO()

def create_app(env_name):
  """
  Create app
  """

  # app initiliazation
  app = Flask(__name__)
  app.config.from_object(app_config[env_name])

  # initializing bcrypt and db
  bcrypt.init_app(app)
  db.init_app(app)

  # initialize socketio
  socketio.init_app(app)

  app.register_blueprint(message_blueprint, url_prefix='/api/v1/message')

  return app

Тогда в run.py вы можете импортировать этот объект: 

from src.app import create_app, socketio

# ...

env_name = os.getenv('FLASK_ENV')
app = create_app(env_name)

# ...

if __name__ == '__main__':
  port = os.getenv('PORT')
  # run app
  socketio.run(app, host='0.0.0.0', port=port)

И таким же образом вы можете импортировать его в свой модуль MessageView.py: 

from src.app import socketio

socketio.on('whatever')
def do_something(data):
    pass

У меня есть полный пример приложения, который использует эту структуру здесь: https://github.com/miguelgrinberg/Flask-SocketIO-Chat.

...