3
ответа

Что отличает asyncio.ensure_future и asyncio.AbstractEventLoop.create_task? [Дубликат]

Попытка понять разницу между asyncio.ensure_future () и asyncio.AbstractEventLoop.create_task () в Python 3.6. Оба создают будущее: из документации: create_task (coro): ...
вопрос задан: 31 March 2016 20:15
3
ответа

Можно ли использовать функцию async внутри процесса? [Дубликат]

Могу ли я использовать функцию Asyncio в процессе, например, я хочу запустить одну функцию как процесс, а внутри нее две функции Async
вопрос задан: 19 March 2015 21:57
3
ответа

Python 3.6, модуль Asyncio [дубликат]

У меня проблема с блокировкой портов в python 3.6.5 с использованием Asyncio. В приведенном ниже коде принимают TCP-соединения и несколько потоков. Моя проблема в том, что я не могу ее убить, если нет активного TCP ...
вопрос задан: 16 December 2014 17:25
2
ответа

RuntimeError при запуске сопрограммы из __init__

Вот пример кода. класс Foo: def __init __ (self): self._run_coro () def _run_coro (self): async def init (): bar = # некоторые операции ввода-вывода self.bar = bar ...
вопрос задан: 28 March 2019 14:12
2
ответа

Неблокирующий запуск параллельных сопрограмм в Python

Я хочу выполнять задачи асинхронно и одновременно. Если задача 1 выполняется при получении задачи 2, задача 2 запускается сразу, не дожидаясь завершения задачи 2. Кроме того, я хотел бы избежать ...
вопрос задан: 18 January 2019 13:53
2
ответа

python3 asyncio ждет при обратном вызове

Я пытаюсь выяснить, как использовать rospy actionlib и asyncio, чтобы ждать асинхронно в результате действия. Для этого я попытался написать генератор выполнения действий, но теперь этого не удалось. ...
вопрос задан: 13 July 2018 16:36
2
ответа

скрипач не может захватить запрос aiohttp [duplicate]

Здесь я не смог использовать скрипач, чтобы захватить HTTP-запрос, запущенный aiohttp. Ниже мой код (то же самое с официальным документом) импортирует asyncio async def fetch (session, url): async with session.get (url) as ...
вопрос задан: 8 October 2011 05:14
1
ответ

Почему все задачи выполняются в asyncio.wait (), когда я четко указываю, что хочу выполнить только первую?

Я пытаюсь получить некоторые данные из OpenSubtitles, используя asyncio, а затем загрузить файл, информация которого содержится в этих данных. Я хочу получить эти данные и скачать файл одновременно ...
вопрос задан: 14 April 2019 11:59
1
ответ

Может ли неблокирующий сокет вызвать BlockingIOError из устройства чтения / записи?

Может ли sock.recv когда-либо вызывать BlockingIOError от читателя? Например, ниже sock.setblocking (False) def reader () try: (data, addr) = sock.recvfrom (512), за исключением BlockingIOError: ...
вопрос задан: 11 April 2019 06:04
1
ответ

Максимизировать количество параллельных запросов (aiohttp)

tl; dr: как мне увеличить количество http запросов, которые я могу отправлять параллельно? Я получаю данные из нескольких URL-адресов с библиотекой aiohttp. Я проверяю его производительность, и я заметил, что где-то в ...
вопрос задан: 21 March 2019 10:02
1
ответ

C-Python asyncio: запуск discord.py в потоке

Мне нужно запустить discord.py в отдельном потоке, так как я не могу заблокировать свой основной поток. Это игровой сервер C / Python 3.7 (Ubuntu 18) C code: int pysDiscord_Init; ... PyObject * psv_discord; ...
вопрос задан: 7 March 2019 11:49
1
ответ

Оптимизирован ли run_in_executor для работы в цикле с сопрограммами?

Мне кажется, что метод run_in_executor () библиотеки asyncio принадлежит объекту цикла. В частности, какая будет разница, если я выберу второй поток наряду с асинхронным ...
вопрос задан: 6 March 2019 16:32
1
ответ

лямбды в асинцио

В документации Python 3.7.2 для asyncio eventloop говорится в документации по функции call_later: необязательные позиционные аргументы будут переданы обратному вызову при его вызове. Если ты ...
вопрос задан: 25 February 2019 15:25
1
ответ

aiohttp и asyncio, как получить ответ от http-запроса и websocket одновременно?

Я пытаюсь получить данные с двух конечных точек одновременно. Но если websocket прекратит посылать сообщения, я не получу данные из запроса от "https://www.blabla.com". Каков наилучший способ решения этой проблемы ...
вопрос задан: 18 January 2019 22:36
1
ответ

Как добавить параметры запросов, когда запрос выполняется в async def loop loop executor?

Как добавить параметры, такие как verify и прокси, в ниже приведенный ниже request.get? В не асинхронной настройке я просто делал бы request.get (url, proxies = 'some_proxy', verify = False), но я не знаю, как поставить ...
вопрос задан: 18 January 2019 15:38
1
ответ

asyncio: мультиплексирование сообщений по одному соединению через веб-сокет

Я использую Python 3.6, asyncio и библиотеку websockets. Я пытаюсь создать клиент для службы на основе веб-сокета, которая работает следующим образом: клиент может отправлять запросы JSON с пользовательским идентификатором, ...
вопрос задан: 18 January 2019 15:06
1
ответ

Asyncio vs. Gevent [закрыто]

Предыстория Однажды я работал над системой Python2, в которой было много синхронного кода ввода / вывода, написанного синхронно, и которое масштабировалось с использованием потоков. В какой-то момент мы не смогли масштабировать его дальше, и поняли, что м
вопрос задан: 18 January 2019 13:06
1
ответ

Параллельные GET-запросы aiohttp приводят к ClientConnectorError (8, «имя узла или имя сервера указано или не известно»)

Я озадачен проблемой, по-видимому связанной с asyncio + aiohttp, когда при отправке большого количества одновременных запросов GET более 85% запросов вызывают aiohttp.client_exceptions ....
вопрос задан: 16 January 2019 02:53
1
ответ

asyncio DatagramProtocol не печатает на консоль, но делает это в возвышенном текстовом окне [duplicate]

У меня есть следующий минимальный клиентский код: class Client (asyncio.DatagramProtocol): def connection_made (self, transport): print (transport) self._transport = transport req = {...
вопрос задан: 31 January 2016 01:53
1
ответ

Как установить атрибут класса с await в __init__

Как я могу определить класс с await в конструкторе или теле класса? Например, что я хочу: импортировать asyncio # некоторый код класса Foo (объект): async def __init __ (self, settings): self ....
вопрос задан: 14 October 2015 18:18
1
ответ

Установка Jupyter Notebook AttributeError asyncio.py [дубликат]

Я на Ubuntu 14.04 x64 с Python3.4.3 Я пытаюсь установить jupyter notebook: sudo apt-get -y install python3-pip sudo apt-get -y install python3-dev sudo pip3 install --upgrade pip sudo -H pip3. ..
вопрос задан: 15 June 2015 20:39
1
ответ

Почему цикл событий asyncio подавляет KeyboardInterrupt в Windows?

У меня есть действительно маленькая тестовая программа, которая ничего не делает, кроме выполнения цикла событий asyncio: import asyncio asyncio.get_event_loop (). Run_forever () Когда я запускаю эту программу в Linux и ...
вопрос задан: 16 December 2014 16:25
1
ответ

используйте ошибку aiohttp и asyncio: ValueError: слишком много дескрипторов файлов в select () [duplicate]

Я использую aiohttp и ASYNCIO для подготовки программы, которая запускает ошибку процесса с информацией: ValueError: слишком много дескрипторов файлов в select () Как я могу решить этот метод? импортировать aiohttp ...
вопрос задан: 15 August 2012 19:50
0
ответов

Python Asyncio Await Tasks

Требуется: Python 3.7 или более поздняя версия. Две функции main1 и main2 определены ниже. Один создает задачи и затем ждет их всех в конце; Еще один создай и жди каждого по очереди. В то время как main1 занимает 2 секунды ...
вопрос задан: 11 April 2019 10:16
0
ответов

различать отмену экранированной задачи и текущей задачи

При чтении: https://docs.python.org/3/library/asyncio-task.html#asyncio.Task.cancel кажется, что перехват CancelledError используется для двух целей. Один потенциально мешает вашей задаче ...
вопрос задан: 2 April 2019 00:39
0
ответов

Подсчет активных задач в цикле событий заданного типа

Я знаю, что могу использовать asyncio.all_tasks (), чтобы получить список запущенных задач. Но что, если я хочу отфильтровать этот список? Как получить список задач определенного типа (а не конкретного экземпляра), которые я пытался ...
вопрос задан: 27 March 2019 15:52
0
ответов

RuntimeError: Цикл обработки событий закрыт Задача была уничтожена, но она ожидает Discord Python

Привет, я посмотрел на нескольких других форумах и не могу диагностировать мою проблему на основе их кода. Это для несогласного бота, и всякий раз, когда я получаю эту ошибку, он вынуждает код завершиться. Так не бывает каждый ...
вопрос задан: 18 March 2019 23:31
0
ответов

поддерживать соединение aiohttp ClientSession

Я отправляю асинхронные запросы POST на какой-то удаленный URL, на котором развернут код моего приложения. Брандмауэр сервера реализует длительное время ожидания соединения, если нет связи ...
вопрос задан: 22 February 2019 02:46
0
ответов

Правильно используя loop.create_future

Я читал документацию по Python и книгу PyMotW, пытаясь изучить Async / Await, Futures и Tasks. Документация сопрограмм и задач: Обычно нет необходимости создавать объекты Future в ...
вопрос задан: 20 January 2019 02:16
0
ответов

Почему дельта-время цикла python увеличивается, когда соединение веб-сокета активно?

У меня есть приложение Python, которое должно поддерживать соединение с клиентом, но также необходимо запустить цикл. Я делаю это с помощью asyncio и фреймворка под названием quart. Но когда я подключаюсь к приложению, время дельта ...
вопрос задан: 19 January 2019 22:43