ASYNCIO НА ПРАКТИЧЕСКОМ ПРИМЕРЕ

Привет! Показываю на пальцах, в чём крутость асинхронного кода на Python и показываю, как с помощью него эффективно взаимодействовать с БД.
Поддержать:
/ luchanos
/ @luchanos
#ityoutubers #ityoutubersru

[@Ratmirsh]

подписан на тебя где-то год, но когда нахожу такие старые видео у тебя - респект к каналу все больше растет)

[@ChrisNasredin]

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

[@slyjpg]

Огромная благодарность за уроки! 🙏

[@ivan_inanych]

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

[@АлександрАлександров-о8ж]

Полезная тема! Надо глубже.

[@luchanos]

спасибо! сделаем)

[@rtyhujrtyhfjfghjgfj]

Круто! До этого плохо понимал как работает asyncio, но теперь все понятно

[@alex_kird]

Очень сильно понравилось, спасибо

[@letsplaybi]

Спасибо большое! очень доходчиво! а боялась, что не осилю асинхронность)

[@denissavast]

благодарю за отличную работу !

[@luchanos]

спасибо что смотрите!

[@olhap.1414]

дякую! змістовний приклад!

[@dizoner2610]

Парень, спасибо большое ! Очень круто объяснил!

[@HEKPACOFF]

Очень доходчиво! Благодарю за труд!

[@valeriyemelyanov9090]

Спасибо!!! Интересно, полезно, и вроде как вполне "взрослый" подход

[@andrey_1364]

Пересмотрел и спустя полгода понял что к чему)))

[@99phenomenon]

Спасибо за труд! Постепенно вхожу в сферу!)

[@PlanSK]

Спасибо за познавательный материал без воды👍

[@BestCrafting1]

отличный туториал,спасибо автор 👍

[@EvgeniyYatsenko]

отличный материал - спасибо!

[@vanker_189]

Большое спасибо за видеоурок

[@romanbush5164]

Офигеть год прошел)

[@ВасилийЗайцев-н9ю]

Когда нужен был create table, а pyspark умеет только dml , нашел это изделие И получается, отправляю в базу один ddl запрос через асинхронную функцию, предназначенную для параллельной работы тьмы запросов Профит

[@ivangordiychuk5510]

Спасибо! Очень помогло!

[@avazart614]

Лайк! (по рекомендачии от канала джангоскул)

[@anim5812]

Спасибо, было очень познавательно

[@luchanos]

благодарю!

[@никитамарыков-я6ц]

отличное видео. красавец

[@andreykalugin8075]

Отлично! Лайк и подписка!

[@luchanos]

спасибо! постараюсь радовать контентом!

[@romanbush5164]

Круто спасибо

[@luchanos]

И вам)

[@googleadmin4749]

Очень круто, было бы прикольно осознать как запускать в фоне процесс без ожидания

[@luchanos]

процесс как python-процесс? не могли бы вы конкретизировать?

[@antonkryukov7134]

В конце sleep забыл удалить

[@Ybuotue]

Не забыл, а оставил для имитации задержки сети, подключается же к локалхосту.

[@ара_вася]

4:39 наша лупа))

[@luchanos]

Ага и пупа)

[@vyacheslavm7844]

Асинхронка крутая тема👍 ждём новых выпусков про неё)

[@KereellOlorin]

Спешиал сенкс за отсылку к PEP 515 - Underscores in Numeric Literals. Забыл шо так можно.

[@hopelesssuprem1867]

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

[@hopelesssuprem1867]

@Ivan Petrov спасибо за развернутый ответ)

[@orkhangasanov]

А если не использовать асинхронную библиотеку для постгри и пытаться стандартной библиотекой psycopg2 выполнять запросы в функциях-корутинах завернутых в async + await asyncio.sleep(0.1). Не будет также по скорости? Вопрос в целом, почему нельзя использовать синхронную библиотеку для записи БД или чего-то ещё, если мы всё равно можем передать для async def xxx(). awaitable объект.

[@Putu_pererenan]

Встанет колом

[@gryu7214]

Спасибо! Понятно

[@supreltd]

Кайфанул! Спустя 1,5 года разработки не расторопных сервисов, наконец то добрался до асинхрона. Спасибо!

[@PavelMostovoy]

Можно и блокирующий код запускать, для этого используется конструкция loop.run_in_executor(). Но вот написать не блокирующий код не используя await asyncio.sleep() и уже готовые библиотеки которые это поддерживают, это уже интересно.

[@Spk111]

Да топчик

[@luchanos]

спасибо!

[@Nick_Libman]

Хорошее видео) Есть только один вопрос - можно ли в chunk передать сразу все 10000 запросов? Как проверить это ограничение и что вообще будет?

[@СергейВеличко-п6б]

странно получается) до 10 инсерта как-то в разнобой ID и cnt, потом нормально create table test (id serial not null, val text) QUERY = """INSERT INTO test (val) VALUES ($1)""" await db_pool.fetch(QUERY, 'test insert ' + str(cnt)) ID. VAL 1 test insert 2 2 test insert 4 3 test insert 1 4 test insert 7 5 test insert 3 6 test insert 6 7 test insert 8 8 test insert 5 9 test insert 9 10 test insert 10

[@luchanos]

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

[@alexsur7315]

Интересно а если неизвестно заранее количество запросов? Получается если поставить длину 1, то он будет ждать пока не наберётся 200 и пользователю ничего не вернётся?

[@luchanos]

абсолютно верно!) тут надо понимать какие риски мы несём и как с этим бороться. в ремейке этого ролика я покажу расширенный вариант)

[@alexsur7315]

@@luchanos спасибо. А когда ролик на этот счёт будет выпущен?

[@luchanos]

@@alexsur7315 я думаю что это всё будет в рамках проекта, по срокам точно не скажу сейчас. идея в том, что тот материал, который я тут осветил прикрутить на что-то "боевое". я уже купил домен и там есть сервер на котором будет web-app, которое мы будем покрывать всеми такими вот прелестями)

[@PizdaRusni2023]

tasks в середину цикла. Почему не показать пример с батч генератором.

[@luchanos]

хороший кейс, спасибо! покажу в переработанном материале)

[@RrRr-vf3gt]

Здравствуйте. ищу решение. У меня такая проблема. Основной код асинхронный, и при определённом выполнении условия должен создаваться новый тред/поток, который должен жить уже дальше своей жизнью. Но к сожалению выходит так, что создаётся новый потом внутри асинхронке и он стопорит всё, пока не закончит свою работу. Уже месяца 2 ищу как мне создать новый поток, который бы зарождался в асинхронке и жил своей жизнью. Может у кого есть идеи? ПС. Пожалуйста не пишите, мол зачем тебе, сделай асинхронно вообще всё. Это не решение моей задачи. Мне нужный асинхронный парсинг в процессе работы которого, выполняется условие и стартует грубо говоря отдельная программа. И мне нужно, что бы это был именно новый поток. Ни и что бы совсем усложнить задачу, количество будущих потоков неизвестно (динамическое). Кто знает решение такой задачи. Отзовитесь ))

[@maxvakker7719]

Уже неактуально (

[@cs_dequeue]

Супер видео! Спасибо! Кстати, можно убрать искусственно тормозящий asyncio.sleep в конце и будет еще быстрее)

[@luchanos]

да! но это спецом было сделано)

[@radikmasagutov9716]

Интересно. Спасибо. НО БОЛЬШАЯ ПРОСЬБА не бить так сильно по клавишам!!! В наушниках очень не приятно слушать.

[@luchanos]

спасибо! я уже купил оборудование - будет ремастер старых роликов)

[@donfedor007]

Я экспериментировал с asyncio и библиотекой Jira. Не хотят они дружить(( У Вас нет не чего в этой теме?

[@luchanos]

Никогда не слышал про библиотеку Jira, надо будет поугглить

[@johnylemon473]

спасиюо за видео. сделай пожалуйста большой ,углубленный туториал реальным проектом по этой теме.

[@luchanos]

уже в разработке!) ждите анонс!)

[@dmytroznak8843]

👍🏻

[@VakaramGolang]

ахиреть как быстро стало работать. столкнулся с проблемой асинхронности с ТГ ботом на aiogram не хочет работать просто так с sqlite а мне она идеально подходит +-. Ну и шаг назад два вперёд , сейчас буду повторять код.

[@ivanowdenis]

Классное видео, только "or pended == 10_000" никогда не исполнится(т.к. 9_999 будет последним в range )

[@luchanos]

хаха)) действительно)) спасибо!)

[@avazart614]

@@luchanos А сколько по умолчанию в пуле воркеров ? Можно его менять ... стоило упомянуть

[@olzh6285]

pended и не нужен, у него цикл х из 10_000, мог бы использовать х, что бы не добавлять лишние действия. Но это не важно, главное знания про асинхронность он донес

[@vilesovds]

Интересно, а зачем create_pool асинхронный?

[@luchanos]

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

[@PavelNebo]

забыл убрать await sleep(.1)

[@Putu_pererenan]

Он же сказал, что спецом не будет убирать

[@ЗахаровЕгений]

Еще бы как-нибудь создать код анализирующий нагрузку на БД и автоматом меняющий чанки на оптимальное значение. По теме - палец вверх

[@luchanos]

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

[@МахамбетМамыров]

+++

[@klayd4009]

Бесполезное видео. Вы не даете конкретики во времени выполнения. Много всяких излишеств. Раз уж вы показываете gather, то следовало бы использовать comprehension, заполняемый корутинами.

[@luchanos]

Сделайте видео лучше, я приду и оценю с удовольствием))

[@Anonymous00754]

круто нихера не понял где можно нормльно разобрать асинх у меня надо гет пост в панду сложить прилетит джсон после псот проверил методом раскидать по ядрам ну бустрее но ядра занимать не хочется # df['jsonreport'] = df.newbody.parallel_apply(self.apply_func) типо того на 4 быстрее чем просто апплай да ) но вот про асинхр пытаюсь понять как действовать ничига не понимаю(