Привет. Я к вам снова с asyncio.☺️

Привет. Я к вам снова с asyncio.☺️

задавай вопрос асинхронно

Допустим у меня есть функция которая постоянно делает longpoll запрос для получения изменений, и мне надо, получив эти изменения отправить их на обработку, но при этом чтобы запрос продолжался. Как мне из этой функции заставить параллейно отработать функцию обработки изменения?

пытаешься впихать синхронный код в асинхронщину?

Могу ли я вызвать обработку методом asyncio.gather(func())?

пытаешься впихать синхронный код в асинхронщину?

Синхрон имеется, пытаюсь сделать асинхрон

ты там не бота на айограме пишешь случайно?

Допустим у меня есть функция которая постоянно делает longpoll запрос для получения изменений, и мне надо, получив эти изменения отправить их на обработку, но при этом чтобы запрос продолжался. Как мне из этой функции заставить параллейно отработать функцию обработки изменения?

Мы же вчера обсуждали

Могу ли я вызвать обработку методом asyncio.gather(func())?

газер он для получения результатов пачки корутин

Мы же вчера обсуждали

чё у него там?

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

Допустим у меня есть функция которая постоянно делает longpoll запрос для получения изменений, и мне надо, получив эти изменения отправить их на обработку, но при этом чтобы запрос продолжался. Как мне из этой функции заставить параллейно отработать функцию обработки изменения?

https://t.me/ru_python/960324

https://docs.python.org/3/library/concurrent.futures.html#threadpoolexecutor

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

А я вот взялся за асинк. Я не собираюсь глубоко влезать. Мне просто надо иметь постоянно опрашивающую сервер функцию и по мере поступления обрабатывать уведомления.

А я вот взялся за асинк. Я не собираюсь глубоко влезать. Мне просто надо иметь постоянно опрашивающую сервер функцию и по мере поступления обрабатывать уведомления.

Ты вообще в курсе что такое вытесняющая и кооперативная многозадачность?

И в чем разница?

https://docs.python.org/3/library/concurrent.futures.html#threadpoolexecutor

я ему вот это собрался советовать from concurrent.futures.thread import ThreadPoolExecutor _executor = ThreadPoolExecutor(20) async def in_thread(func, *args, **kwargs): loop = asyncio.get_event_loop() return await loop.run_in_executor(_executor, functools.partial(func, *args, **kwargs))

я ему вот это собрался советовать from concurrent.futures.thread import ThreadPoolExecutor _executor = ThreadPoolExecutor(20) async def in_thread(func, *args, **kwargs): loop = asyncio.get_event_loop() return await loop.run_in_executor(_executor, functools.partial(func, *args, **kwargs))

И спрашивается, зачем тут асинк :)))

а он не нужен?

а лол

И в чем разница?

Нет. Возможно есть представление иного их названия

а то я везде эвэйтю in_thread

нходил где-то на SO так было

Даже очередь видимо не нужна, достаточно ему экзекьютора

А я вот взялся за асинк. Я не собираюсь глубоко влезать. Мне просто надо иметь постоянно опрашивающую сервер функцию и по мере поступления обрабатывать уведомления.

Чем тебе ThreadPoolExecutor не подошёл?

Я предполагаю в качестве сервера использовать vps 1cpu 512ram. Треды будут конкурировать, верно понимаю?

Чем тебе ThreadPoolExecutor не подошёл?

уже несколько статей на самом деле про асинк/эвэйт проитал но всё равно в голове не укладывается куда выпадает корутина когда натыкается на await

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

Я предполагаю в качестве сервера использовать vps 1cpu 512ram. Треды будут конкурировать, верно понимаю?

Поэтому блин ограничь их какими-нибудь небольшим числом

но когда оно вообще считается-то?

Я предполагаю в качестве сервера использовать vps 1cpu 512ram. Треды будут конкурировать, верно понимаю?

Что ты подразумеваешь под "конкурировать"?

если поток один

уже несколько статей на самом деле про асинк/эвэйт проитал но всё равно в голове не укладывается куда выпадает корутина когда натыкается на await

При gather переключается на следующую и потом обратно, больше ничего не понял

но когда оно вообще считается-то?

У тебя есть список текущих корутин. Между ними происходит переключение во время эвейта

Есть ноутбук. Хочу сделать на нем хостинг свого сайта. Какую ОС ставить на него? Я думал что то типа Ubuntu server

Есть ноутбук. Хочу сделать на нем хостинг свого сайта. Какую ОС ставить на него? Я думал что то типа Ubuntu server

центось

Любую

хоть шиндовс сервер если секса очень охота

Поэтому блин ограничь их какими-нибудь небольшим числом

Чат-бот...ну ограничу я их и что? Бот будет ждать ждать...потом пришлет обработку. Верное? Если ему будут писать 3-5 человек- не страшно, а когда 40-50...

У тебя есть список текущих корутин. Между ними происходит переключение во время эвейта

я понимаю что оно переключается

а выполнение-то того что эвэйтится когда происходит?

У тебя есть список текущих корутин. Между ними происходит переключение во время эвейта

Вот , а мне надо сделать чтобы опрос сервера не еереключался а продолжал опрашивать

Чат-бот...ну ограничу я их и что? Бот будет ждать ждать...потом пришлет обработку. Верное? Если ему будут писать 3-5 человек- не страшно, а когда 40-50...

Ну а что, у тебя ресурсы из магии асинкио появятся?

Вот , а мне надо сделать чтобы опрос сервера не еереключался а продолжал опрашивать

Да блин запускай обработчики в экзекьюторе

Чат-бот...ну ограничу я их и что? Бот будет ждать ждать...потом пришлет обработку. Верное? Если ему будут писать 3-5 человек- не страшно, а когда 40-50...

Что у тебя происходит вообще в обработчике, что людям приходится ждать?

а выполнение-то того что эвэйтится когда происходит?

Ну вот выполняется одна в один момент времени. Остальные стоят, ждут

А то, что касается чтения из сети - ну так там ничего не делается, просто ожидание буфера

Вот набросал что то похожее

async def main()

async def main()

Да да да...забыл)

Вот набросал что то похожее

Да что у тебя там в обработчике происходит?

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

Если ты например полчаса там считаешь матрицы на питоне, хрен тебе а не параллельная обработка - тред заблокируется на одной корутине

И все будут ждать её завершения

получается хуйню я понаписал

Да что у тебя там в обработчике происходит?

Проверяет что прислали, сверяет команда ли это или просто текст. Это чпт бот. Проверяет сидит ли этот чел в чате, если нет, то шлёт справку как зайти, если да, то шлёт сообщение остальным. Или если это команда из списка команд, то обрабатывает её и высылает ему ответ. Там конструкция if elseif else как волос на обезьяне?

Тишка

ты меня запутал

Проверяет что прислали, сверяет команда ли это или просто текст. Это чпт бот. Проверяет сидит ли этот чел в чате, если нет, то шлёт справку как зайти, если да, то шлёт сообщение остальным. Или если это команда из списка команд, то обрабатывает её и высылает ему ответ. Там конструкция if elseif else как волос на обезьяне?

Ну и чём тебе ThreadPoolExecutor не подошёл?

А асинк хочу сразу воткнуть чтоб в будущем модифицировать скрипт и больше функционала впихнуть

А асинк хочу сразу воткнуть чтоб в будущем модифицировать скрипт и больше функционала впихнуть

Это никак не связанные вещи

Грубо - пока у тебя не будет 10000 одновременных юзеров, об асинке можешь не думать

Ну и чём тебе ThreadPoolExecutor не подошёл?

Как он себя поведет, если надо будет в чате от человек 100 принять сообщение и отправить всем исключая адресата. А количество человек я не знаю сколько будет, может сто, больше меньше.

Грубо - пока у тебя не будет 10000 одновременных юзеров, об асинке можешь не думать

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

Ну и чём тебе ThreadPoolExecutor не подошёл?

Как он себя ведёт? Очередь пулов?

Я не знаю как себя поведет ВК когда ты попытаешьмч послать одновременно 100*100 сообщений. Мне кажется, тебя просто срежут по лимитам частоты обращений

блин, не могу понять, как работать с модулем threading. сделал функцию, которая принимает один аргумент, есть лист со значениями, которые надо передать этой функции, хочу создавать по треду на каждый аргумент и получается какая-то фигня. for x in all_ips: print(x) my_thread = threading.Thread(target=func, args=(x, )) my_thread.start() и он мне сначала выводит несколько значений, а потом пишет func() takes 1 positional argument but 12 were given

Как он себя ведёт? Очередь пулов?

Пул потоков и очередь задач

и так несколько раз с разными значениями числа аргументов

блин, не могу понять, как работать с модулем threading. сделал функцию, которая принимает один аргумент, есть лист со значениями, которые надо передать этой функции, хочу создавать по треду на каждый аргумент и получается какая-то фигня. for x in all_ips: print(x) my_thread = threading.Thread(target=func, args=(x, )) my_thread.start() и он мне сначала выводит несколько значений, а потом пишет func() takes 1 positional argument but 12 were given

Чо

Пул потоков и очередь задач

Не блокирующие или тут тоже GIL играет в свою игру?

Чо

ну самый простой пример, надо обработать кучу аргументов функции, всё как в примерах пишут

Не блокирующие или тут тоже GIL играет в свою игру?

Да забудь ты про GIL. У тебя одно ядро и много сетевых обращений

ну самый простой пример, надо обработать кучу аргументов функции, всё как в примерах пишут

Нет, покажи реальный код на котором конкретная ошибка

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

Я не знаю как себя поведет ВК когда ты попытаешьмч послать одновременно 100*100 сообщений. Мне кажется, тебя просто срежут по лимитам частоты обращений

Нет, там можно до 20 запросов в секунду делать. А в один запрос можно впихнуть всех адресатов, это будет один запрос.

Нет, там можно до 20 запросов в секунду делать. А в один запрос можно впихнуть всех адресатов, это будет один запрос.

Тогда вообще не вижу проблем. Делаешь пул на 20 потоков и вперёд

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

а, всё, спасибо, запятую потерял в args. Когда писал сюда, то написал как в примере написано и вдруг дошло, что не всё верно. Спасибо за помощь!

Тогда вообще не вижу проблем. Делаешь пул на 20 потоков и вперёд

Хотелось бы все таки с асинком разобраться.?

Хотелось бы все таки с асинком разобраться.?

С тредами разберись :)

Так я никогда ничего не выучу, там кусок там...

Когда поймёшь, бери асинк

А если сразу?? Вроде почти почти....

Сначалв пойми как у тебя там все переключается

Добро пожаловать, @kayakaze! Не забудь ознакомиться с правилами чата. https://t.me/ru_python/802295

Переключаться при помощи await, но это только в верхней функции...

братишки а кто использует vs code для разработки? не могу понять, как заставить его выкидывать автодополнение для переменной log: import logging logging.basicConfig(filename="sample.log", level=logging.INFO) log = logging.getLogger("ex") log. очень много кейcов когда автодополнение просто не показывает методы класса, мб есть какой-то плагин который решит эту проблему?

Лучше скажи, верно ли я обработку запускаю параллейно основному запросу?

братишки а кто использует vs code для разработки? не могу понять, как заставить его выкидывать автодополнение для переменной log: import logging logging.basicConfig(filename="sample.log", level=logging.INFO) log = logging.getLogger("ex") log. очень много кейcов когда автодополнение просто не показывает методы класса, мб есть какой-то плагин который решит эту проблему?

kite

kite

спасиб

Привет, вопрос по pandas - можно как-то в dataframe, полученном с read_excel, задать значение ячеек в зависимости от цвета? К примеру, если ячейка в excel зеленая, то значение у ячейки должно быть "эта ячейка зеленая ололол". В нете куча примеров как сделать обратную штуку, задать цвет, основанный на значении ячейки, через df.style.applymap, а вот обратно чет не получается найти ?

А asyncio.wait случайно не блокируется до завершения корутины, которую ему передал?

Лучше скажи, верно ли я обработку запускаю параллейно основному запросу?

Тв запускаешь не параллельно, асинхронность это не параллельность, смотри в сторону процессов

Wait это же корутина

А вообще вам нужно или просто создавать задачу и бросать ее в пул или взять aiojobs