Не происходит асинхронное выполнение запросов. Получение запросов
from flask import request, render_template
from app import app_flask, token_flask, forms
from analytical import database
@app_flask.route('/api', methods=['POST'])
async def api_request():
token_api = request.json['token']
repository_path = request.json['repository_path']
instance_db_client = database.DataBaseHandler()
print('db-', type(instance_db_client.get_report))
return await instance_db_client.get_report(repository_path, token_api)
@app_flask.route('/', methods=['GET', 'POST'])
async def main_page():
if request.method == 'GET':
form = forms.RepositoryPathForm()
return render_template('index.html', form=form), 200
elif request.method == 'POST':
form = forms.RepositoryPathForm()
repository_path = request.form['link_repository']
instance_db_client = database.DataBaseHandler()
json, code = await instance_db_client.get_report(repository_path, token_flask)
return render_template('index.html', form=form, json=json), code
@app_flask.errorhandler(404)
async def page_not_found(error):
return 'Страницы не существует!!', 404
Обращение к постороннему серверу, предполагаю где то тут ошибка
async def link(self):
try:
async with aiohttp.ClientSession() as session:
async with session.post(url=self.url, headers=self.headers, json=self.json) as resp:
data = json.loads(await resp.read())
return data
except requests.exceptions.ConnectionError as e:
logger.error(f'ERROR500! Ошибка ссоединения с сервером. Исключение: {e}')
resp_json.query_info.code = 500
resp_json.query_info.error_desc = 'ConnectionError'
resp_json.query_info.error_message = str(e)
Тестирую на сервере debian, запущено через nginx и gunicorn. Для теста запускаю gunicorn с одним worker'ом. Программа выполняется в синхронном режиме, пока запрос не пройдет другие запросы не принимает. Возможно что то нужно настроить в gunicorn или nginx, но я к сожалению не нашел. При запуске в отладочном режиме выдает ошибку (но продолжает работать)
Exception ignored in: <function _ProactorBasePipeTransport.__del__ at 0x00000285CD08FF40>
Traceback (most recent call last):
File "C:\Users\vi812\AppData\Local\Programs\Python\Python310\lib\asyncio\proactor_events.py", line 116, in __del__
self.close()
File "C:\Users\vi812\AppData\Local\Programs\Python\Python310\lib\asyncio\proactor_events.py", line 108, in close
self._loop.call_soon(self._call_connection_lost, None)
File "C:\Users\vi812\AppData\Local\Programs\Python\Python310\lib\asyncio\base_events.py", line 750, in call_soon
self._check_closed()
File "C:\Users\vi812\AppData\Local\Programs\Python\Python310\lib\asyncio\base_events.py", line 515, in _check_closed
raise RuntimeError('Event loop is closed')
RuntimeError: Event loop is closed