Описание тега python-trio

Описание тега Вопросы с тегом
Trio - это пакет Python для асинхронного параллелизма и ввода-вывода, который одержим удобством использования и правильностью.
1 ответ

Трио: чтение нескольких задач с одного и того же диска

У меня есть файловый дескриптор, и я хотел бы прочитать его с несколькими задачами. Каждый запрос read() на fd будет возвращать полный, независимый пакет данных (при условии, что данные доступны). Моя наивная реализация заключалась в том, чтобы кажд…
18 сен '18 в 12:27
1 ответ

Как очистить соединения после KeyboardInterrupt в python-trio

Мой класс, когда он подключен к серверу, должен немедленно отправить строку входа в систему, а после окончания сеанса он должен отправить строку выхода и очистить сокеты. Ниже мой код. import trio class test: _buffer = 8192 _max_retry = 4 def __init…
14 фев '18 в 23:56
3 ответа

Объединение семафора и ограничения времени в python-trio с запросом http запроса

Я пытаюсь использовать Python в асинхронном режиме, чтобы ускорить свои запросы к серверу. Сервер имеет низкое время отклика (часто несколько секунд, но иногда быстрее секунды), но работает хорошо параллельно. У меня нет доступа к этому серверу и я …
09 июл '18 в 17:06
2 ответа

Захватить возвращаемое значение из объектов питомника

При использовании трио и nursery объекты, как вы захватываете любое значение, которое было возвращено из метода? Возьмите этот пример с сайта трио: async def append_fruits(): fruits = [] fruits.append("Apple") fruits.append("Orange") return fruits a…
28 июл '18 в 02:09
1 ответ

Будущее / Обещание, как материал для Трио в Python?

Скажи у меня класс Messenger который отвечает за отправку и получение сообщений. Теперь у меня есть служба, которая отправляет запросы и ожидает ответов через нее, сопоставляя каждую пару с полем id в сообщении. В asyncio я бы сделал: class Service:…
12 мар '18 в 07:20
5 ответов

Порождение процессов и связь между процессами в приложении Python на основе трио

Для стажировки в FluidImage библиотеки Python мы исследуем, может ли быть хорошей идеей написать параллельное приложение HPC с моделью клиент / сервер с использованием трио библиотеки. Для асинхронного программирования и ввода / вывода трио действит…
04 июл '18 в 10:11
1 ответ

В трио, как я могу иметь фоновую задачу, которая живет столько же, сколько мой объект?

Я пишу класс, который будет порождать задачи при его жизни. Так как я использую Trio, я не могу создавать задачи без детской. Моей первой мыслью было иметь self._nursery в моем классе, в котором я могу создавать задачи. Но кажется, что дочерние объе…
16 янв '18 в 13:52
2 ответа

Как я могу читать по одной строке из трио ReceiveStream?

Асинсио имеет StreamReader.readline(), позволяя что-то вроде: while True: line = await reader.readline() ... (Я не вижу async for доступно в Asyncio, но это будет очевидная эволюция) Как мне получить эквивалент с трио? Я не вижу никакой поддержки вы…
01 дек '18 в 23:29
2 ответа

Способ асинхронного трио, чтобы решить пример Геттингера

Раймонд Хеттингер выступил с докладом о параллелизме в python, где один из примеров выглядел так: import urllib.request sites = [ 'https://www.yahoo.com/', 'http://www.cnn.com', 'http://www.python.org', 'http://www.jython.org', 'http://www.pypy.org…
10 апр '18 в 16:02
1 ответ

TRIO Lib очередь получить и поставить

Здравствуйте, я пытаюсь использовать трио с двумя асинхронными функциями и сообщение между ними. но это не запускает потребителя, и я действительно не понимаю, почему. Производитель хорошо отправляет в "очередь" и не отправляет ничего, как только он…
03 авг '18 в 21:09
5 ответов

Как собрать результаты задачи в Трио?

Я написал скрипт, который использует детскую и модуль asks для циклического прохождения и вызова API на основе переменных цикла. Я получаю ответы, но не знаю, как вернуть данные, как вы бы с asyncio. У меня также есть вопрос об ограничении API до 5 …
05 окт '18 в 18:25
1 ответ

Сочетание py.test и trio/curio

Я хотел бы объединить pytest и trio (или curio, если так проще), то есть написать свои тесты в качестве функций сопрограммы. Этого относительно легко достичь, объявив пользовательский бегун в conftest.py: @pytest.mark.tryfirst def pytest_pyfunc_call…
18 янв '18 в 20:42
1 ответ

python-trio: AttributeError: sendall

Я просто пытаюсь запустить echo-client-low-level.py от python-trio документы: # echo-client-low-level.py import sys import trio # arbitrary, but: # - must be in between 1024 and 65535 # - can't be in use by some other program on your computer # - mu…
14 фев '18 в 00:11
2 ответа

Python: способы синхронизации задач трио и обычных потоков

Я нахожусь в ситуации, когда мне нужно синхронизировать задачи Trio с потоками Python. На данный момент я использую threading.Lock объекты, которые задачи Трио должны приобрести с trio.run_sync_in_worker_thread(lock.acquire), Я думаю, что это также …
23 сен '18 в 18:09
1 ответ

Время выполнения трио без операций ввода-вывода

Я делаю примеры, чтобы понять, как работает Python асинхронно. Я прочитал документацию по Trio и подумал, что только одна задача может быть выполнена в цикле каждый раз и в каждом checkpoint scheduler решить, какая задача будет выполнена. Я сделал п…
15 авг '18 в 09:05
1 ответ

Трио питомник, который не отменяет все задачи, если один не удается

Я хотел бы реализовать сервер с трио. Индивидуальные клиентские связи обрабатываются задачами, порожденными детской. Тем не менее, в документах трио говорится, что "если какая-либо задача внутри питомника заканчивается с необработанным исключением, …
20 янв '18 в 10:18
1 ответ

В чем основная разница между асинчо и трио?

Сегодня я нашел библиотеку с именем trio, которая говорит, что сама по себе является асинхронным API для людей. Эти слова немного похожи на requests". Как requests действительно хорошая библиотека, мне интересно, каковы преимущества trio, Там не так…
26 мар '18 в 02:07
2 ответа

Сочетание трио и колбы

Я пытаюсь создать HTTP API, который может создавать и уничтожать параллельные задачи, которые открывают TCP-соединения с удаленными серверами, передающими потоковые данные ~15 секунд. Я должен выяснить, как обрабатывать данные позже. Сейчас я просто…
08 мар '19 в 18:26
1 ответ

Как сжать код, который выбирает, сколько параллельных задач выполняется на основе ввода?

У меня есть проект Scrapper, который работает с асинхронными запросами, просит библиотеки и трио. Я хотел бы выбрать, сколько параллельных задач выполняется на основе ввода, но мой код длинный и примитивный. Я использую объект трио для порождения и …
12 апр '19 в 16:55
1 ответ

Любой совет, как настроить параметры для загрузки URL-адресов быстрее с меньшим количеством ошибок? (трио + спрашивает)

Я пишу простую программу, которая загружает список URL-адресов. подготовить список URL !curl -LO https://github.com/mozilla/cipherscan/raw/master/top1m/top-1m.csv !head -5 top-1m.csv 1,google.com 2,facebook.com 3,youtube.com 4,yahoo.com 5,baidu.com …
28 апр '19 в 08:40