python-asyncio
Как я могу создать оболочку, которая делает задачи сельдерея похожими на asyncio.Task? Или есть лучший способ интегрировать сельдерей с asyncio? @asksol, создатель сельдерея, сказал это:: Довольно часто сельдерей используется в качестве распределенного слоя поверх асинхронных фреймворков ввода-вывода (ве...
API часто имеют ограничения скорости, которые пользователи должны соблюдать. В качестве примера возьмем 50 запросов в секунду. Последовательные запросы занимают 0,5-1 секунду и поэтому слишком медленны, чтобы приблизиться к этому пределу. Параллельные запросы с aiohttp, однако, превышают ограничение скорости....
Я немного затрудняюсь решить, как выйти из этой сопрограммы, если оператор except поймает. Обычно я просто использую: def f(x): try: foo_var = next(a_volitile_generator(x)) except Exception: print('it broked') return yield foo_var Однако! Я собираюсь породить газиллион ...
Я работаю над проектом с Raspberry Pi 3 для некоторого экологического контроля с рядом простых повторяющихся событий в непрерывном цикле. RP3 слишком квалифицирован для этой работы, но это позволяет мне сосредоточиться на других вещах. Характеристики приложения: Приложение должно собирать сенсорные данные...
Я новичок в Python и мало что знаю об asyncio. Я хочу запустить этот скрипт, и если программное обеспечение OBS, к которому он пытается подключиться на 10.11.0.124, не работает, чтобы выйти из кода. Код делает это, но это займет 2 минуты, прежде чем он выйдет. Я не могу понять, почему он не выходит немедле...
В настоящее время я делаю свои первые шаги с asyncio в Python 3.5, и есть одна проблема, которая меня беспокоит. Очевидно, я не до конца понял соратников... Вот упрощенная версия того, что я делаю. В моем классе есть метод open (), который создает новый поток. В этом потоке я создаю новый цикл событий и сое...
Допустим у нас есть функция манекена: async def foo(arg): result = await some_remote_call(arg) return result.upper() в чем разница между: coros = [] for i in range(5): coros.append(foo(i)) loop = get_event_loop() loop.run_until_complete(wait(coros)) и: from asyncio import ensure_future fu...
Я видел несколько основных руководств Python 3.5 по asyncio, выполняющих одну и ту же операцию в разных вкусах. В этом коде: import asyncio async def doit(i): print("Start %d" % i) await asyncio.sleep(3) print("End %d" % i) return i if __name__ == '__main__': loop = asyncio.get_event_...
я пытаюсь правильно понять и реализовать два одновременно работающих Task объекты с использованием Python 3 относительно новые asyncio модуль. в двух словах, asyncio, кажется, предназначен для обработки асинхронных процессов и параллельных Task исполнение в течение цикла обработки событий. Это способствует и...
asyncio.gather и asyncio.wait похоже, что у меня есть аналогичное использование: у меня есть куча асинхронных вещей, которые я хочу выполнить/подождать (не обязательно ждать, пока один из них закончится до начала следующего). Они используют различный синтаксис, и отличаются в некоторых деталях, но, похоже, оч...