Вопросы по теме 'python-asyncio'

asyncio - Как можно использовать сопрограммы в обработчиках сигналов?
Я разрабатываю приложение, которое использует asyncio из python3.4 для работы в сети. Когда это приложение корректно завершает работу, узел должен «отключиться» от концентратора. Это отключение является активным процессом, для которого требуется...
9576 просмотров
schedule 26.03.2023

Динамически добавлять в список того, что должен выполнять цикл событий Python asyncio.
У меня есть функция download_all, которая выполняет итерацию по жестко запрограммированному списку страниц, чтобы последовательно загрузить их все. Но если я хочу динамически добавлять в список на основе результатов страницы, как я могу это сделать?...
7253 просмотров

Поддерживает ли asyncio запуск подпроцесса из неосновного потока?
Я разрабатываю приложение, которое в основном состоит из сервисов, представляющих собой потоки с настраиваемыми циклами выполнения. Одна из служб должна порождать подпроцессы, и я действительно не понимаю, действительна она или нет. Официальная...
1245 просмотров
schedule 30.04.2023

Использование Cython с Asyncio (Python 3.4)
Кому-то удалось заставить Cython работать с сопрограммой Asyncio? У меня есть очень тривиальный пример, который хорошо работает в Python и отказывается работать в Cython: это следующий файл, который я компилирую с помощью Cython и выполняю....
1675 просмотров
schedule 25.01.2023

Цикл событий Asyncio для каждого процесса Python (обработка aioprocessing, несколько циклов событий)
У меня два процесса; основной процесс и подпроцесс. Основной процесс запускает цикл событий asyncio и запускает подпроцесс. Я хочу запустить еще один цикл событий asyncio в подпроцессе. Я использую модуль aioprocessing для запуска подпроцесса....
4239 просмотров
schedule 13.01.2022

Создание соединений с помощью python3 asyncio
Я пытаюсь подключиться к нескольким серверам одновременно. В настоящее время я использую loop.create_connection , но он зависает на первом не отвечающем сервере. gsock = loop.create_connection(lambda: opensock(sid), server, port) transport,...
1383 просмотров

PyQt5 и asyncio: выход из никогда не завершается
Я пытаюсь создать новое приложение на основе PyQt5 и asyncio (с python 3.4, с нетерпением жду возможности в конечном итоге перейти на 3.5 с помощью async/await). Моя цель — использовать asyncio, чтобы графический интерфейс оставался отзывчивым, даже...
5460 просмотров
schedule 12.08.2023

Асинхронная задача Python3 была уничтожена, но ожидает выполнения с определенным условием
Вот упрощенный код, который использует сопрограмму python3 и устанавливает обработчик сигналов SIGING и SIGTERM для правильной остановки задания: #!/usr/bin/env python3 # -*- coding: utf-8 -*- import argparse import asyncio import signal import...
13523 просмотров
schedule 31.03.2023

Как измерить производительность асинхронного кода Python?
Я не могу использовать обычные инструменты и методы для измерения производительности сопрограммы, потому что время, которое требуется в await , не следует принимать во внимание (или следует просто учитывать накладные расходы на чтение из ожидаемого,...
4510 просмотров

asyncio queue потребительская сопрограмма
У меня есть подкласс asyncio.Protocol , получающий данные с сервера. Я сохраняю эти данные (каждую строку, потому что это текст) в asyncio.Queue . import asyncio q = asyncio.Queue() class StreamProtocol(asyncio.Protocol): def...
14278 просмотров

Может выполнять только запросы GET в тесте Tornado
Я пытаюсь протестировать обработчик запросов Tornado, использующий asyncio и новый синтаксис async def . Запросы GET работают, но другие запросы не выполняются. import asyncio import tornado.platform.asyncio as tasyncio from tornado import...
1155 просмотров

Связывание запросов aiohttp с их ответами
Очень просто, я просто хотел бы связать ответы от aiohttp асинхронных HTTP-запросов с идентификатором, например с ключом словаря, чтобы я знал, какой ответ соответствует какому запросу. Например, функция ниже вызывает URI с суффиксами значений...
1260 просмотров

Ожидание завершения подзадачи по событию завершения внешней задачи (асинхронная версия add_done_callback)
Допустим, у нас есть некоторая задача (подзадача), которая должна быть завершена после выполнения внешней задачи. У нас нет контроля над внешней задачей: мы не знаем, когда она будет завершена (это может произойти до выполнения подзадачи), мы не...
340 просмотров
schedule 28.11.2022

Индикатор выполнения asyncio aiohttp с tqdm
Я пытаюсь интегрировать tqdm индикатор выполнения для отслеживания запросов POST, сгенерированных aiohttp в Python 3.5. У меня есть индикатор выполнения, но я не могу собирать результаты с помощью as_completed() . Указатели получены с...
9577 просмотров

Выполнение 1 миллиона запросов с помощью aiohttp/asyncio — буквально
Я следовал этому руководству: https://pawelmhm.github.io/asyncio/python/aiohttp/2016/04/22/asyncio-aiohttp.html , и все работает нормально, когда я делаю около 50 000 запросов. Но мне нужно сделать 1 миллион вызовов API, и тогда у меня проблема с...
3454 просмотров

понимание вывода профилировщика Python asyncio
Я пытаюсь понять вывод профилировщика Python при запуске программы на основе Python asyncio: Я вижу, что моя программа тратит примерно 67% времени на попытки получить блокировку потока. Это нормально в программах asyncio? Мое...
1937 просмотров

Python 3.5 async/await с реальным примером кода
Я прочитал тонны статей и туториалов о Python 3.5 async/await. Должен сказать, что я довольно запутался, потому что некоторые используют get_event_loop() и run_until_complete(), некоторые используют sure_future(), некоторые используют asyncio.wait(),...
10263 просмотров

@asyncio.coroutine против асинхронного определения
С библиотекой asyncio , которую я видел, @asyncio.coroutine def function(): ... и async def function(): ... используются взаимозаменяемо. Есть ли какая-то функциональная разница между ними?
15157 просмотров

Общее состояние с веб-сервером aiohttp
Мой веб-сервер aiohttp использует глобальную переменную, которая со временем меняется: from aiohttp import web shared_item = 'bla' async def handle(request): if items['test'] == 'val': shared_item = 'doeda'...
1112 просмотров

Очередь Python asyncio не обновляется
Следующий код создает экземпляр объекта asyncio.Queue и пытается заполнить и использовать эту очередь из двух разных сопрограмм, соответственно arrival() и server() . loop = asyncio.get_event_loop() q = asyncio.Queue() async def arrival(q):...
1036 просмотров
schedule 02.08.2023