Flask + Flask_SocketIO = RuntimeError: Работа вне контекста запроса

У меня есть следующий основной файл.

from flask import Flask, render_template, request
from flask_socketio import SocketIO, emit, send
import gpio_control
from gevent import monkey
monkey.patch_all()


simplyfishy = Flask(__name__)
simplyfishy.config['SECRET_KEY'] = 'ARG'
socketio = SocketIO(simplyfishy, async_mode='gevent')

@simplyfishy.route('/')
def index():
    return render_template('home.html')


@socketio.on('message')
def handle_message(message):
    emit(message, {'data': 'main!'})


if __name__ == '__main__':
    socketio.run(simplyfishy, host='0.0.0.0')

Это файл gpio_control

import RPi.GPIO as GPIO
from pushbullet import Pushbullet
from flask_socketio import emit

# Set the GPIO mode to Broadcom
GPIO.setmode(GPIO.BCM)

# Create a dictionary for sensors ans their status
float_switches = {
    24: {'name': 'Float Switch 1', 'state': GPIO.LOW},
    25: {'name': 'Float Switch 2', 'state': GPIO.LOW}
}

# Setup float switches
for float_switch in float_switches:
    GPIO.setup(float_switch, GPIO.IN, pull_up_down=GPIO.PUD_UP)


# Define callback function for event detection
def floatsw(channel):
    from __main__ import simplyfishy
    with simplyfishy.app_context():
        if GPIO.input(channel):
            print(float_switches[channel]['name'] + " deactivated!")
            emit('float_sw', {'data': 'deactivated!'})
        else:
            print(float_switches[channel]['name'] + " activated!")
            # pb.push_note("Simply Fishy", "Sump water level is low")
            emit('float_sw', {'data': 'activated!'})


GPIO.add_event_detect(24, GPIO.BOTH, callback=floatsw, bouncetime=1000)
GPIO.add_event_detect(25, GPIO.BOTH, callback=floatsw, bouncetime=1000)

Что я хотел бы сделать, так это, как вы видите, я хочу отправить обновление на страницу фляги, показывающее, что переключатель либо активирован, либо деактивирован в режиме реального времени. Однако, когда я запускаю поплавковый переключатель, я получаю следующее

Float Switch 1 activated!
Traceback (most recent call last):
  File "/home/pi/simplyfishy/gpio_control.py", line 61, in floatsw
    emit('float_sw', {'data': 'activated!'})
  File "/home/pi/.local/lib/python2.7/site-packages/flask_socketio/__init__.py", line 688, in emit
    namespace = flask.request.namespace
  File "/home/pi/.local/lib/python2.7/site-packages/werkzeug/local.py", line 347, in __getattr__
    return getattr(self._get_current_object(), name)
  File "/home/pi/.local/lib/python2.7/site-packages/werkzeug/local.py", line 306, in _get_current_object
    return self.__local()
  File "/home/pi/.local/lib/python2.7/site-packages/flask/globals.py", line 37, in _lookup_req_object
    raise RuntimeError(_request_ctx_err_msg)
RuntimeError: Working outside of request context.

Я гуглил и смотрел на другие примеры, но я не могу понять, что не так. Я не думаю, что @socketio.on('message') в основном файле даже нужен, но, может быть, это так, и мне нужно вызвать его из моего gpio_control, чтобы отправить его на страницу? Я чувствую, что мне не хватает потока или чего-то простого с этим. Очень ценю помощь!

РЕДАКТИРОВАТЬ: следующий код обновлен и исправлено появление сообщения об ошибке. Однако при этом у меня есть круговая зависимость. Я так думаю из-за следующего сообщения об ошибке.

ImportError: невозможно импортировать имя simplefishy в консоль. Что из того, что показал мне Google, было бы проблемой циклической зависимости.


python flask flask-socketio
person DexDeadly    schedule 09.04.2018    source источник

Ответы (1)


arrow_upward
3
arrow_downward

Проблема в том, что два вызова emit() в вашей функции floatsw() не получили достаточно информации, поэтому они пытаются получить недостающие данные из контекста запроса. Поскольку эта функция вызывается без контекста запроса, вы получаете ошибку.

Два недостающих бита информации — это получатель эмиссии и пространство имен. Похоже, вы не используете специальное пространство имен для этого приложения, поэтому вы можете устранить отсутствующее пространство имен, добавив namespace='/' в качестве аргумента в эти два эммита.

Что касается получателя, вы можете добавить broadcast=True для отправки всем подключенным клиентам или использовать room=<sid>, где <sid> — идентификатор сеанса клиента, которому вы хотите отправить сообщение. Вы также можете использовать имя любой пользовательской комнаты, которую вы создали здесь.

Подводя итог, можно сказать, что быстрый и грязный способ избежать ошибки состоит в том, чтобы изменить ваши эмиссии следующим образом:

def floatsw(channel):
    with simplyfishy.app_context():
        if GPIO.input(channel):
            print(float_switches[channel]['name'] + " deactivated!")
            emit('float_sw', {'data': 'deactivated!'}, namespace='/', broadcast=True)
        else:
            print(float_switches[channel]['name'] + " activated!")
            # pb.push_note("Simply Fishy", "Sump water level is low")
            emit('float_sw', {'data': 'activated!'}, namespace='/', broadcast=True)

Затем вам может понадобиться разработать стратегию, позволяющую избежать широковещательной рассылки и ориентироваться только на определенных клиентов.

Изменить: в пример добавлен контекст приложения.

person Miguel    schedule 09.04.2018
comment
Спасибо, я попробовал, и я получаю следующее. gist.github.com/SimplySynced/5d7784d3d0e95865f5f799dfc52d137c — то же самое, но строка показывает обновленную информацию. Нужно ли добавлять информацию о фляге, а также app.app_contex в файл gpio_control? - person DexDeadly; 10.04.2018
comment
О, извините, я сказал вам исключить контекст запроса, но да, вам все еще нужен контекст приложения. Позвольте мне обновить вопрос. - person Miguel; 10.04.2018
comment
Спасибо, однако теперь я получаю Traceback (последний последний вызов): Файл /home/pi/simplyfishy/gpio_control.py, строка 54, в floatsw с simplefishy.app_context(): NameError: глобальное имя 'simplyfishy' не определено Traceback ( последний последний вызов): Файл /home/pi/simplyfishy/gpio_control.py, строка 54, в floatsw с simplefishy.app_context(): NameError: глобальное имя 'simplyfishy' не определено - person DexDeadly; 11.04.2018
comment
Я считаю, что это потому, что я не определил SimplyFishy. Он определен в моем файле SimplyFishy.py, но не в файле gpio_control.py. Нужно ли импортировать приложение во второй файл. Например, из SimplyFishy импортировать current_app как SimplyFishy? - person DexDeadly; 11.04.2018
comment
Вы хотите импортировать его как from __main__ import simplyfishy. Чтобы избежать циклических зависимостей, вам может понадобиться поместить этот импорт в функцию floatsw(). - person Miguel; 11.04.2018
comment
Спасибо, Мигель, кажется, я больше не получаю ошибку! Теперь поработайте над java во внешнем интерфейсе! - person DexDeadly; 12.04.2018