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

Как передать поток stdout/stderr из дочернего процесса с помощью asyncio и получить его код выхода после?
В Python 3.4 в Windows мне нужно передавать данные, записанные в stdout/stderr дочерним процессом, т. е. получать его вывод по мере его возникновения, используя asyncio , представленный в Python 3.4. Я также должен определить код выхода программы...
3080 просмотров

Как гарантировать передачу данных tcp с использованием python asyncio?
У меня есть клиент, который подключается к серверу и отправляет все сообщения из списка, и каждое отправленное сообщение удаляется из списка. Но когда я заставляю сервер закрыться, клиент продолжает отправлять и удалять сообщения из списка. Я бы...
1621 просмотров

Когда задача asyncio сохраняется после создания, исключения из задачи отключаются.
Я использовал asyncio для проекта и столкнулся с этим странным поведением. import asyncio def schedule_something(): global f tsk = asyncio.async(do_something()) f = tsk #If this line is commented out, exceptions can be heard....
1754 просмотров
schedule 03.02.2024

py.test миксеры и сопрограммы asyncio
Я создаю несколько тестов для кода python3, используя py.test. Код обращается к базе данных Postgresql с помощью aiopg (интерфейс на основе Asyncio для postgres). Мои основные ожидания: Каждый тестовый пример должен иметь доступ к новому...
2596 просмотров

Можно ли рассматривать Python asyncio.coroutine как генератор?
Я погуглил python coroutine и увидел только генераторы (Почти почти во всех примерах используется yield без asyncio .) Они действительно такие же? В чем разница между asyncio.coroutine и генератором?
968 просмотров

Добавление задач в python asyncio
Я пытаюсь написать простой веб-сканер, чтобы проверить, как работает новый модуль asyncio, но что-то я делаю не так. Я пытаюсь запустить сканер с одним URL-адресом. Сценарий должен загрузить эту страницу, найти любые теги <a> на странице и...
226 просмотров
schedule 20.11.2023

отправить данные в виде файла с aiohttp
У меня есть такая конечная точка, которая возвращает файл с csv: # POST /export/ @asyncio.coroutine def export(request): post = yield from request.post() if not post.get('passwd', None) == 'topsecret': return...
3698 просмотров
schedule 08.06.2024

Обратные вызовы от автобана WebSocketClientProtocol к другому объекту
Во-первых, есть класс IO , которому на __init__ передается объект асинхронного цикла ( io = IO(loop) ), созданный ранее в основном классе. IO затем в какой-то момент инициализирует класс Socket , выполнив self.socket = Socket(self) , чтобы...
1386 просмотров

Запустить функцию async без импорта пакета asyncio
Можно ли запустить такую ​​функцию async def foo(): while True: print("Hello!") без импорта пакета asyncio (и получения цикла событий)? Я ищу принцип, похожий на горутины Go, где можно запустить сопрограмму с помощью только...
4756 просмотров
schedule 16.11.2022

Реализация асинхронного итератора
Согласно PEP-492 я я пытаюсь реализовать асинхронный итератор, чтобы я мог сделать, например. async for foo in bar: ... Вот тривиальный пример, похожий на тот, что в документации, с очень простым тестом создания экземпляра и...
17560 просмотров

Можно ли запустить экземпляр asyncio.Server, когда цикл событий уже запущен
Я пытаюсь понять, можно ли запустить экземпляр asyncio.Server , когда цикл событий уже выполняется методом run_forever (из отдельного потока, конечно). Как я понимаю, сервер можно запустить либо по...
702 просмотров
schedule 13.06.2024

Поток Python никогда не запускается, если run() содержит yield from
Python 3.4, я пытаюсь создать сервер с помощью модуля веб-сокетов (ранее я использовал обычные сокеты, но хотел создать клиент javascript), когда столкнулся с проблемой (потому что он ожидает асинхронность, по крайней мере, если примеры должны быть...
452 просмотров

Невозможно создать новый цикл событий после вызова loop.close asyncio.get_event_loop в Python3.6.1
В Python3.6.1 после вызова loop.close() в цикле, полученном из asyncio.get_event_loop(), можно ли создать новый цикл? Я просмотрел другие сообщения с ответами на правильное закрытие цикла, а также на то, как использовать task.cancel(), но не смог...
1596 просмотров
schedule 20.10.2022

Как нужно обрабатывать CancelledError на типичных веб-серверах aiohttp?
У меня есть приложение веб-сервера aiohttp с такими обработчиками, как: async def handler(request): async with request.app["db"].acquire() as db: row = await query(db) return aiohttp.web.json_response(row) Где app["db"] -...
1185 просмотров

Программа, использующая AsyncIO и aiohttp для сканирования сайта и сбора всех URL-адресов.
С помощью этого асинхронного (более быстрого) решения вы можете собирать все URL-адреса с сайта и записывать их в текстовые файлы в том же каталоге, где находится программа. Эти текстовые файлы затем можно использовать для дальнейшего сканирования или...
737 просмотров
schedule 22.02.2024

Чем чтение сокетов отличается от чтения файлов?
Я просто планировал переписать некоторый код Python, в котором я опрашивал файл на наличие изменений. Я хотел переписать его как упражнение для asyncio , и концептуальная идея заключалась в том, чтобы сделать неблокирующее чтение файла, которое даст...
56 просмотров

python: как сделать периодический неблокирующий поиск
Не могли бы вы посоветовать, как периодически выполнять задачу, выполнение которой занимает больше времени, чем периодический интервал? Например: def lookup(): # do some lookups, retrieve info, let's assume it takes 60sec to complete...
682 просмотров

Тестирование клиента aiohttp с помощью unittest.mock.patch
Я написал простой HTTP-клиент, используя aiohttp, и пытаюсь протестировать его, исправляя aiohttp.ClientSession и aiohttp.ClientResponse . Однако похоже, что декоратор unittest.mock.patch не учитывает мой асинхронный код. На первый взгляд, я бы...
3414 просмотров
schedule 07.12.2023

Аргументы клиента асинхронного автобана
Отказ от ответственности: я впервые работаю с WS и MQTT, поэтому структура может быть неправильной. Пожалуйста, укажите это. Я использую автобан с asyncio для получения и отправки сообщений в экземпляр HA (HomeAssistant) через веб-сокеты. Как...
97 просмотров
schedule 07.03.2024

asyncio с несколькими методами в микропитоне
Когда я запускаю следующий код, он запускается и печатает («Прослушивание, подключите ваше приложение к http://192.168.4.1:8080/ ") и ожидает запроса в качестве веб-сервера. В режиме веб-сервера я хочу, чтобы светодиод мигал, поэтому я применил...
1404 просмотров
schedule 21.09.2022