Форум программистов, компьютерный форум, киберфорум
Python: Flask
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.82/11: Рейтинг темы: голосов - 11, средняя оценка - 4.82
1303 / 843 / 409
Регистрация: 12.03.2018
Сообщений: 2,305

Уничтожить поток, в котором запущено приложение Flask

29.10.2019, 12:04. Показов 2509. Ответов 3

Студворк — интернет-сервис помощи студентам
Продолжение темы Когда нужно закрывать соединение между сокетами

Вместо использования собственного протокола и передачи данных по сокету было предложено использовать json-rpc для обмена информацией между процессами.

Имеется следующий код:

Flask приложение:
Кликните здесь для просмотра всего текста
Python
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
#!/usr/bin/env python
# -*- coding: utf-8 -*-
 
import itertools
import json
 
from flask import Flask, request, Response, g, _app_ctx_stack
import requests
from flask_jsonrpc import proxy
 
app = Flask(__name__)
app.config['PROPAGATE_EXCEPTIONS'] = True
 
def byte_gen():
    for i in itertools.cycle(range(256)):
        yield i
 
number = byte_gen()
 
def get_number():
    return next(number)
 
HEADER = {'ContentType': 'application/json'}
 
@app.route('/get-data', methods=['POST'])
def get():
    data = request.get_json()
 
    session = get_session()
    proxy = get_proxy()
 
    payload = {
         'jsonrpc': '2.0',
         'method': 'get',
         'params': {},
         'id': str(get_number())
     }
 
    # r = session.post('http://localhost:5001/api',
    #                  data=json.dumps(payload),
    #                  headers=HEADER)
 
    r = proxy.get(data['signals'])
 
    print r['result'][0]
 
    return Response(json.dumps(r['result'][0]), 200, HEADER)
 
@app.route('/set-data', methods=['POST'])
def set_():
    data = request.get_json()  # {"signal": "signal_name", "value": value}
 
    proxy = get_proxy()
 
    r = proxy.set(data['signal'], data['value'])
 
    print r
 
    return Response(json.dumps({'success': True}, 200, HEADER))
 
def get_session():
    """
    :rtype: requests.Session
    """
    if 'session' not in g:
        g.session = requests.Session()
    return g.session
 
@app.teardown_appcontext
def close_session(exception):
    session = g.pop('session', None)
    if session is not None:
        session.close()
 
def get_proxy():
    """
    :rtype: proxy.ServiceProxy
    """
    if 'proxy' not in g:
        g.proxy = proxy.ServiceProxy('http://localhost:5001/api')
    return g.proxy
 
@app.teardown_appcontext
def close_proxy(exception):
    g.pop('proxy', None)
 
if __name__ == '__main__':
    app.run()

Принимает два запроса:
1) get-data. Пример параметров (json): {'signals': ['signal1', 'signal2']}
2) set-data. Пример параметров (json): {'signal': 'signal1', 'value': True}

Источником данных для веб-сервера является другое приложение П (см. первую тему).

В П по нажатию на кнопку создается поток, в котором запускается http сервер (Flask) для организации обмена с помощью json-rpc + запускается процесс работы с некоторыми данными (в коде отсутствует).

Код приложения П:
Кликните здесь для просмотра всего текста
Python
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
import threading
import socket
import pickle
from datetime import datetime
from flask import Flask
# import jsonrpc
import flask_jsonrpc
from Tkinter import *
 
class Window(Tk):
    # GUI для имитации действий пользователя
 
    def __init__(self):
        Tk.__init__(self)
        self.status = 'stop'
        self.btntext = StringVar(value='Start')
        btn = Button(textvariable=self.btntext,
                     width=30, height=10, command=self.on_btn)
        btn.pack()
        self.protocol("WM_DELETE_WINDOW", self.on_closing)
 
    def on_closing(self):
        if self.status == 'start':
            _stop()
        self.destroy()
 
    def on_btn(self):
        if self.status == 'stop':
            _start()
            self.status = 'start'
            self.btntext.set('Stop')
        else:
            _stop()
            self.status = 'stop'
            self.btntext.set('Start')
 
 
def _start():
    print('Starting')
 
    class Thread(threading.Thread):
        # НЕ ИСПОЛЬЗУЕТСЯ
 
        def __init__(self, group=None, target=None, name=None,
                     args=(), kwargs=None, verbose=None):
            threading.Thread.__init__(self, group, target, name,
                                      args, kwargs, verbose)
 
        def set_app(self, value):
            self.app = value
 
        def set_jsonrpc(self, value):
            self.jsonrpc = value
 
    app = Flask(__name__)
    jsonrpc = flask_jsonrpc.JSONRPC(app, '/api')
 
    SocketThread = threading.Thread(target=threadProc,
                                    args=(app, jsonrpc),
                                    name='MyServer')
    SocketThread.start()
 
def _stop():
    print('Stopping')
 
    thread = None
    for th in threading.enumerate():
        if th.name == 'MyServer':
            thread = th
            break
 
    if thread is not None:
        thread.join()
 
RuntimeValues = {
    'z1_sw1': False,
    'z1_sw2': False,
    'z1_led': False
}
 
HEADER = {'ContentType': 'application/json'}
 
def threadProc(app, jsonrpc):
    """
    :param Flask app:
    :param flask_jsonrpc.JSONRPC jsonrpc:
    """
    @jsonrpc.method('get')
    def get(signals):
        dct = {}
        for signal in signals:
            value = RuntimeValues.get(signal, None)
            if value is not None:
                dct[signal] = value
 
        return (dct, 200, HEADER)
 
    @jsonrpc.method('set')
    def set_(signal, value):
        global RuntimeValues  # for test
        if signal in RuntimeValues:
            RuntimeValues[signal] = value
 
    # thread = threading.current_thread()
 
    app.run(port=5001)
 
if __name__ == '__main__':
    w = Window()
    w.mainloop()

Словарь RuntimeValues имитирует данные, которые обрабатывает приложение.

Вопрос. При нажатии на кнопку "Stop" приложение виснет, т.к. вызывается метод thread.join(). Можно ли как-то принудительно убить сервер Flask в П?
Пробовал сделать через multiprocessing.Process, т.к. он имеет метод terminate, но при запуске процесса всегда вылетает исключение EOFError.
Python 2.7
0
Лучшие ответы (1)
IT_Exp
Эксперт
34794 / 4073 / 2104
Регистрация: 17.06.2006
Сообщений: 32,602
Блог
29.10.2019, 12:04
Ответы с готовыми решениями:

Как автоматически разносить звук по устройствам в зависимости от Экрана на котором запущено приложение?
Господа, приветствую! Подскажите есть ли софт, способный реализовать следующую задачу: чтобы вывод звука шел через тот монитор на...

Создайте многопоточное приложение, в котором основной поток поручает выполнение задач рабочим потокам
Задание : Создайте многопоточное приложение, в котором основной поток поручает выполнение отдельных задач рабочим потокам: Каждый...

Как уничтожить поток?
procedure TForm1.FormClose(Sender: TObject; var Action: TCloseAction); begin Threads.MyThreads.Free;//Не канает. пишит _...

3
Просто Лис
Эксперт Python
 Аватар для Рыжий Лис
5973 / 3735 / 1099
Регистрация: 17.05.2012
Сообщений: 10,791
Записей в блоге: 9
29.10.2019, 17:47
Эм… Так приложение П должно быть клиентом, а не сервером.

Добавлено через 47 секунд
Пусть приложение П само цепляется к веб-серверу и отправляет данные.
1
1303 / 843 / 409
Регистрация: 12.03.2018
Сообщений: 2,305
29.10.2019, 18:17  [ТС]
Рыжий Лис, почему? Ведь приложение П для веб-сервера является источником данных => если приложение должно быть сервером? Нет? Т.к., если приложение П не работает, то и от веб-сера толку нет, т.к. данные негде брать. (я провожу аналогию с БД)
0
Просто Лис
Эксперт Python
 Аватар для Рыжий Лис
5973 / 3735 / 1099
Регистрация: 17.05.2012
Сообщений: 10,791
Записей в блоге: 9
29.10.2019, 18:25
Лучший ответ Сообщение было отмечено ioprst как решение

Решение

Просто это странно. Я понимаю, что приложение П работает в локалке на соседнем компе, но если чуть масштабировать, то веб-сервер не сможет пробить NAT и установить соединение.

Если реализовывать приложение как клиент, то упрощается написание. П открывает соединение с веб-сервером по нажатию кнопки и льёт данные (бесконечным потоком или по запросу). Так же безблезненно разрывает соединение с сервером по нажатию кнопки.

Да, немного усложняется архитектура сервера (организовать очередь, например для поступившего запроса и ещё не отправленному П). Если данные будут литься непрерывно, это надо где-то хранить (в бд).
1
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
BasicMan
Эксперт
29316 / 5623 / 2384
Регистрация: 17.02.2009
Сообщений: 30,364
Блог
29.10.2019, 18:25
Помогаю со студенческими работами здесь

Если приложение запущено, то показать MessageBox и закрыть приложение
Доброго времени. Плохо разбираюсь в с# и прощу помощи написать кусочек кода. Мысль такая "Если приложение Form1 запущена, то...

Когда клиент отсоединяется нужно поток уничтожить (остановить)
Здравствуйте. У меня вопрос связан с потоками C#. Пример: Есть функция, которая для каждого клиента создает поток в котором работает с...

Можно ли как то уничтожить поток до полного завершения всех его операций?
Объясните пожалуйста некоторые моменты. Вот например есть след. класс class Producer: public QThread { Q_OBJECT private: ...

Сообщение "приложение остановлено" постоянно, даже когда приложение вообще не запущено
Собственно ,сабж в топике

Запущено ли другое приложение ?
Как программно узнать запущено ли приложение tratata.exe ? Может ссылочку кинете какю-нибудь.


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
4
Ответ Создать тему
Новые блоги и статьи
Оттенки серого
Argus19 18.03.2026
Оттенки серого Нашёл в интернете 3 прекрасных модуля: Модуль класса открытия диалога открытия/ сохранения файла на Win32 API; Модуль класса быстрого перекодирования цветного изображения в оттенки. . .
SDL3 для Desktop (MinGW): Рисуем цветные прямоугольники с помощью рисовальщика SDL3 на Си и C++
8Observer8 17.03.2026
Содержание блога Финальные проекты на Си и на C++: finish-rectangles-sdl3-c. zip finish-rectangles-sdl3-cpp. zip
Символические и жёсткие ссылки в Linux.
algri14 15.03.2026
Существует два типа ссылок — символические и жёсткие. Ссылка в Linux — это запись в каталоге, которая может указывать либо на inode «файла-ИСТОЧНИКА», тогда это будет «жёсткая ссылка» (hard link),. . .
[Owen Logic] Поддержание уровня воды в резервуаре количеством включённых насосов: моделирование и выбор регулятора
ФедосеевПавел 14.03.2026
Поддержание уровня воды в резервуаре количеством включённых насосов: моделирование и выбор регулятора ВВЕДЕНИЕ Выполняя задание на управление насосной группой заполнения резервуара,. . .
делаю науч статью по влиянию грибов на сукцессию
anaschu 13.03.2026
прикрепляю статью
SDL3 для Desktop (MinGW): Создаём пустое окно с нуля для 2D-графики на SDL3, Си и C++
8Observer8 10.03.2026
Содержание блога Финальные проекты на Си и на C++: hello-sdl3-c. zip hello-sdl3-cpp. zip Результат:
Установка CMake и MinGW 13.1 для сборки С и C++ приложений из консоли и из Qt Creator в EXE
8Observer8 10.03.2026
Содержание блога MinGW - это коллекция инструментов для сборки приложений в EXE. CMake - это система сборки приложений. Здесь описаны базовые шаги для старта программирования с помощью CMake и. . .
Как дизайн сайта влияет на конверсию: 7 решений, которые реально повышают заявки
Neotwalker 08.03.2026
Многие до сих пор воспринимают дизайн сайта как “красивую оболочку”. На практике всё иначе: дизайн напрямую влияет на то, оставит человек заявку или уйдёт через несколько секунд. Даже если у вас. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru