def run_forever(self): self._loop.create_task(self.start_server()) self._loop.run_forever()

и это работает

и там в accept_client создаются новые таски и они автоматически стартуют

ахха, не ensure_future, а create_task

вот в него передаешь корутину и она ставится в очередь на выполнение и будет выполняться сразу, как есть работающий луп

хм, а заработало, ща допилю проверю, спасибо))

с create_task

а вот create_task, он получается только одну таску принимает, ему пачку нельзя сразу дать или через цикл просто создать?

а я на любую задачу создаю новый threading.Thread. По сути сотнями. Зря я так делаю да?

а вот те кто пишет на asyncio: как вы мониторите упавшие таски/рестартуете их?

как обычную обработку исключения

как обычную обработку исключения

т.е. внутри корутины?

а почему нет?

О. 3.7 зарелизили

О. 3.7 зарелизили

Вреш?

http://www.opennet.ru/opennews/art.shtml?num=48859

Вреш?

не

Найс

?

с каждой новой версией питона Зарт все глубже осознает устарелость своих взглядов

впрочем, asyncio быстрее все равно вряд ли стал

Теперь ждём ещё 5 лет появления в centos

а почему нет?

потому что если что-то не предусмотрел - всё, привет. и если мы в корутине идем во внешний сервис(а он недоступен, например) и надо реализовать повторные попытки по определенному закону, то как быть? тупо спать в корутине?

потому что если что-то не предусмотрел - всё, привет. и если мы в корутине идем во внешний сервис(а он недоступен, например) и надо реализовать повторные попытки по определенному закону, то как быть? тупо спать в корутине?

почему тупо?

спать - норм, до тех пор, пока спишь асинхронно :)

спать - норм, до тех пор, пока спишь асинхронно :)

добавь сюда таймауты на операции и у тебя наступит счастье

добавь сюда таймауты на операции и у тебя наступит счастье

так обернуть в asyncio.timeout() и все

а что за пакеты?

Яровой

потому что если что-то не предусмотрел - всё, привет. и если мы в корутине идем во внешний сервис(а он недоступен, например) и надо реализовать повторные попытки по определенному закону, то как быть? тупо спать в корутине?

ну для этого существуют брокеры очередей. Это не решается одним лишь языком программирования... Можно в связке с Celery уйти на повтор закинув таск обратно в очередь.

впрочем, asyncio быстрее все равно вряд ли стал

Говорят "Особенно большой прирост производительности отмечается в модуле asyncio."

ну для этого существуют брокеры очередей. Это не решается одним лишь языком программирования... Можно в связке с Celery уйти на повтор закинув таск обратно в очередь.

в нормально написанных асинхронных приложениях брокеры очередей не то чтобы очень нужны

Говорят "Особенно большой прирост производительности отмечается в модуле asyncio."

чо, уже го порвали или нет еще?

Хз :)

в нормально написанных асинхронных приложениях брокеры очередей не то чтобы очень нужны

От задачи зависит. уйти на повтор - явно задача для брокера очереди.

От задачи зависит. уйти на повтор - явно задача для брокера очереди.

с чего вдруг? уйти на повтор - это всего лишь задача реестра тасков. Таска лежит в реестре и имеет статус pending до тех пор, пока не выполнится

всю логику по повторам можно сделать легко таймаутами и слипами

ну для этого существуют брокеры очередей. Это не решается одним лишь языком программирования... Можно в связке с Celery уйти на повтор закинув таск обратно в очередь.

Celery и asyncio???

с чего вдруг? уйти на повтор - это всего лишь задача реестра тасков. Таска лежит в реестре и имеет статус pending до тех пор, пока не выполнится

А если уходить на повтор надо в нескольких миллионов тасках? Не слишком ли дофига приложенька начнет жрать? Не потеряется ли вся очередь если приложенька рухнет?

А если уходить на повтор надо в нескольких миллионов тасках? Не слишком ли дофига приложенька начнет жрать? Не потеряется ли вся очередь если приложенька рухнет?

несколько миллионов тасков - это несколько миллионов файловых дескрипторов на сокете надо обрабатывать в одной приложухе? что, боишься, что epoll порвется?

вообще если у тебя такое происходит с питоноприложением - значит, у тебя кривая архитектура по обработке, но дело не в очереди

да не.... просто в случае с Midleware сервачком, можно будет разгребание очереди наладить на куче машин.

?

Я же говорю, от задачи…

Я же говорю, от задачи…

ну, если у тебя корнер кейс - тогда да

а в общем случае celery не нужен для asyncio

более того, если у тебя миллионы тасков - то celery тем более не нужен

там надо уже кролика какого-нибудь брать

и пихать туда stomp-json или даже лучше msgpack напрямую

без оверхеда на каждой таске

Так уже никто не делает

так делают примерно все

а если нагрузка вырастает еще сильнее - меняют кролика на кафку

но это уже не относится к питону

всю логику по повторам можно сделать легко таймаутами и слипами

Но зачем? Альтернатива - это супервизоры. Таска просто рестартует упавших + таймауты на исполнение порожденных тасков

Но зачем? Альтернатива - это супервизоры. Таска просто рестартует упавших + таймауты на исполнение порожденных тасков

так а чем это отличается-то? у тебя роль супервизора играет родительская корутина, которая по таймауту может рестартить, что угодно

не вижу разницы

так а чем это отличается-то? у тебя роль супервизора играет родительская корутина, которая по таймауту может рестартить, что угодно

Я про корутину-супервизор.

Я про корутину-супервизор.

тогда что "но зачем"? :) если ты согласен

впрочем, asyncio быстрее все равно вряд ли стал

А он медленный?

А он медленный?

да

Кто то конвектировал питон файлы в ехе? Чем? Питон 3

без uvloop так вообще

Кто то конвектировал питон файлы в ехе? Чем? Питон 3

pyinstaller

да

Есть бенчи какие?

Ну это ж питон, он в принципе небыстрый

Есть бенчи какие?

https://github.com/python/asyncio/wiki/Benchmarks

pyinstaller

Там нужно библиотеки все используемые и все?

Там нужно библиотеки все используемые и все?

честно сказать, не помню. Вроде да, он просто все пакует вместе с интерпретатором

https://github.com/python/asyncio/wiki/Benchmarks

А новее?

Спасибо

не вижу разницы

Разница где живёт логика рестарта: в супервизоре или самой таске

Разница где живёт логика рестарта: в супервизоре или самой таске

вообще похер, это одна и та же логика

чем меньше лишних слоев и проще код - тем лучше

А новее?

ну погугли сам, я сейчас не могу

ну погугли сам, я сейчас не могу

Понял, спасибо

но будь уверен - у го и даже у ноды он по-прежнему сосет

Понял, спасибо

если найдешь - кинь сюда тоже, пожалуйста

Понял, спасибо

https://github.com/vibora-io/benchmarks

https://github.com/vibora-io/benchmarks

прикольный проектик

откуда взялся?

та в этом месяце чувак начал пилить

вообще похер, это одна и та же логика

нет. тут не надо думать про корректность внутри самой корутины.

выборы, выборы, кандидаты...

нет. тут не надо думать про корректность внутри самой корутины.

у тебя логика все равно будет в той корутине, которая под таймаутом

то есть смешения слоев не будет, как ни крути

https://github.com/vibora-io/benchmarks

Хм, 61к в норм же. Хотя парсинг формы вообще пиздец

Хм, 61к в норм же. Хотя парсинг формы вообще пиздец

это еще и хеллоуворлд. Ты представь, что будет при запросе в базу, например, или при другой логике на питоне

сразу на порядок меньше

там надо уже кролика какого-нибудь брать

А что, celery не может из него таски брать?

А что, celery не может из него таски брать?

может, но celery - это питоновая шняжка, которая будет давать тебе оверхед на каждую таску

это еще и хеллоуворлд. Ты представь, что будет при запросе в базу, например, или при другой логике на питоне

Если бы ещё хоть что-то могло нормально работать с бд для асинка....

у тебя логика все равно будет в той корутине, которая под таймаутом

смотри. когда у тебя логика внутри таска тебе важно не сломать control flow внутри, потому что иначе никаких повторов/рестартов не будет. а все потому что логика задачи решаемой таской смешана с логикой рестарта.

Если бы ещё хоть что-то могло нормально работать с бд для асинка....

tarantool

смотри. когда у тебя логика внутри таска тебе важно не сломать control flow внутри, потому что иначе никаких повторов/рестартов не будет. а все потому что логика задачи решаемой таской смешана с логикой рестарта.

да не будет она смешана же, еще раз

может, но celery - это питоновая шняжка, которая будет давать тебе оверхед на каждую таску

По скорости? Не это уже вопрос, кто обрабатывает таски, а не через что их передавать