Описание тега aiohttp

Описание тега Вопросы с тегом
Use this tag for questions about AIOHTTP – a client/server framework for asyncio Python.
1 ответ

Что не так с этим асинхронным кодом aiohttp?

Для следующего кода, использующего aiohttp: async def send(self, msg, url): async with aiohttp.ClientSession() as session: async with session.post(url, data=msg) as response: self._msg = response.read() async def recv(self): return await self._msg Э…
13 сен '17 в 23:55
1 ответ

Как получить параметры строки запроса из URL в Aiohttp?

Я пытался получить параметры строки запроса из URL с помощью aiohttp, но этот код не работает: async def call_answer(request): print("request", request) params = request.rel_url.query print("parameters +++++", params["call_id"]) conn = psycopg2.conn…
26 май '18 в 05:21
2 ответа

Запуск сервера aiohttp с помощью gunicorn

Я пытаюсь запустить сервер на основе aiohttp, используя Gunicorn. Вот команда: gunicorn aiohttpdemo_polls:app --bind 127.0.0.1:8080 Возвращает: Failed to find application: 'aiohttpdemo_polls' Но когда я запускаю его, используя python -m, как показан…
13 ноя '17 в 14:11
1 ответ

Как проверить aiohttp и peewee-async?

Я хочу запустить 2 асинхронных теста для своего класса базы данных с aiohttp и peewee-async. @unittest_run_loop async def test_create_instance(self): instance = await self.model.create_instance({}) self.assertTrue(isinstance(instance, dict)) self.as…
12 сен '17 в 15:38
1 ответ

Как определить количество запросов в секунду с помощью aiohttp?

Я пытаюсь создать симулятор веб-трафика, используя aiohttp, В следующем примере кода асинхронно выполняется 10 тыс. Запросов. Я хочу знать, сколько из них происходит одновременно, поэтому я могу сказать, что это моделирует 10 тысяч пользователей, за…
02 фев '17 в 19:25
1 ответ

aiohttp-graphql AsyncioExecutor GraphQLLocatedError: объект 'NoneType' не вызывается

Я начинаю с asyncio + GraphQL, но не могу заставить работать даже самый простой пример: from aiohttp import web from aiohttp_graphql import GraphQLView from graphql.execution.executors.asyncio import AsyncioExecutor from graphql import GraphQLSchema…
13 янв '19 в 12:59
1 ответ

Даже используя asyncio и aiohttp, методы ждут ответа на запрос

Привет, у меня есть следующая проблема, я хочу выполнить метод getlastItemFromGivenInterval, дать ему кратко пройти, не дожидаясь ответа на запрос, и дать контекст asyncio.sleep(60) для выполнения всей процедуры еще раз за 60-секундные периоды време…
30 дек '18 в 15:32
1 ответ

Получение нескольких URL-адресов с помощью aiohttp в python

В предыдущем вопросе пользователь предложил следующий подход для извлечения нескольких URL-адресов (вызовов API) с aiohttp: import asyncio import aiohttp url_list = ['https://api.pushshift.io/reddit/search/comment/?q=Nestle&size=30&after=153…
07 авг '18 в 11:44
1 ответ

aiohttp как войти в журнал доступа?

Я пытаюсь получить базовый регистратор для работы aiohttp, но нет просто сообщений журнала, которые регистрируются. Примечание_ регистрация пользовательских сообщений работает как положено. async def main_page(request: web.Request): return "hello wo…
10 окт '16 в 10:40
1 ответ

Семафор / несколько блокировок пула в asyncio для 1 прокси - aiohttp

У меня есть 5000 000 URL. и хочу получить ответ каждого асинхронно. import aiohttp import asyncio @asyncio.coroutine def worker(url): response = yield from aiohttp.request('GET', url, connector=aiohttp.TCPConnector(share_cookies=True, verify_ssl=Fal…
09 фев '15 в 09:08
3 ответа

Закрытие цикла событий asyncio в Python вызывает исключение в конце

Для запросов https с использованием asyncio и aiohttp в Python 3.4 в Windows мне нужно использовать 2 цикла событий. ProactorEventLoop для запуска команд оболочки и цикл событий по умолчанию для запросов HTTPS. К сожалению, ProactorEventLoop не рабо…
25 апр '14 в 03:09
1 ответ

Случайные ошибки тайм-аута при использовании heroku + gunicorn + aiohttp

Я разработал сервис, который действует как шлюз для перенаправления запросов в разные микро-сервисы. Для этого я использовал aiohttp для обработки запросов на перенаправление, gunicorn (w/ aiohttp.worker.GunicornWebWorker) и Heroku в качестве хоста.…
10 фев '17 в 17:29
0 ответов

Создание неблокирующего сервиса restful с помощью aiohttp

Требование: веб-сервис для поддержки инициализации функции обучения модели машинного обучения и возврата к успеху, который занимает около 4 часов. Для поддержки функции прогнозирования на ранее обученных моделях. Обе вышеперечисленные функции должны…
22 ноя '18 в 11:54
1 ответ

Интеграция автобана |Python с aiohttp

Я пытаюсь интегрировать aiohttp веб-сервер в архитектуре системы Crossbar+Autobahn. Подробнее, когда aiohttp Сервер получает определенный вызов API, он должен опубликовать сообщение на маршрутизаторе Crossbar. Я видел этот пример на официальных репо…
19 июл '17 в 10:56
1 ответ

Разница во времени между открытием нового потока для запуска запросов и aiohttp.ClientSession для асинхронного ввода-вывода?

Я понял, что aiohttp поддерживает асинхронный ввод-вывод, поэтому он полностью однопоточный. Но run_in_executor вроде запускает новый поток. Но я тестировал для задачи с 1000 загрузок, кажется, разница довольно незначительная. Но я предполагаю, что …
25 ноя '18 в 13:47
1 ответ

Как настроить кодировку статических файлов в aiohttp?

Как я могу убедиться, что мои статические файлы, используемые во время разработки, используют utf-8? У меня есть статический обработчик, например, так: app.router.add_static('/static', MY_STATIC_DIR) Но я заметил, что символы utf-8 отображаются в бр…
11 янв '18 в 20:35
1 ответ

Передача больших файлов асинхронно во фляге

Каков наилучший подход для передачи больших файлов асинхронно во Flask? Я прочитал эту статью. Но я хочу знать, есть ли способ сделать это без сельдерея. заранее спасибо
14 янв '17 в 23:33
1 ответ

Как мне получить aiohttp-swagger для распознавания переменных запроса GET?

Я хотел бы использовать aiohttp-swagger в моем проекте Python, но я не могу понять, как он обрабатывает переменные полезной нагрузки GET URL и POST. У меня есть этот пример кода на основе примера быстрого запуска здесь. Единственное изменение, котор…
26 июл '18 в 16:01
0 ответов

Asyncio + Aiohttp socket.send() поднял исключение

У меня очень простой файловый сервер, использующий Aiohttp: import os.path from os import listdir import asyncio from aiohttp import web import aiohttp_jinja2 import jinja2 @aiohttp_jinja2.template('template2.html') @asyncio.coroutine def get(reques…
14 май '15 в 18:33
1 ответ

aiohttp - Webssocket - msg в буфере после ws.close()?

Я получаю обновления о состоянии некоторых финансовых рынков с сервера веб-сокетов. Однако из-за ограничений, налагаемых сервером, я должен периодически создавать новое соединение ws. Первое сообщение из вновь установленного соединения - это начальн…
30 мар '18 в 05:24