run_forever оно без аргументов, а ожидать завершения это run_until_complete

Ему бесконечно надо было

Понял

пусть эта бесконечность там внутри, а тут run_until_complete

мало ли, когда-нибудь захочется, чтобы бесконечность закончилась

run_forever будет снова инициировать функцию, после ее завершения. Верно?

C-c наприме

нет, не будет

Ох, пойду осваивать, зря я ночью прогуливал asyncio. Спасибо!

Штука весьма годная и сейчас нужна почти любому питонщику. так что изучить лишнем не будет

run_forever это мы запустили луп и все

остановится только когда loop.stop() будет вызван

все таски, которые ты накидал в него, отработают один раз и все. И луп просто будет висеть и ждать, пока появится еще какая-нибудь работа

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

Точнее не висеть, а ждать новый loop

при вызове ctypes.CDLL, как посмотреть что возвращается .so'кой?

ждать новый таск

да

Точнее не висеть, а ждать новый loop

loop это общий цикл выполнения где выполняются таски. Обычно он один на thread. поэтому мы пишем get_event_loop() и с ним уже работаем. Но такое не сработает если ты создал новый Thread там придется делать новый через new_event_loop()

Всем привет! Кто с opencv на питон хорошо знает? Как увеличить тайм-аут videocapture()?

loop это общий цикл выполнения где выполняются таски. Обычно он один на thread. поэтому мы пишем get_event_loop() и с ним уже работаем. Но такое не сработает если ты создал новый Thread там придется делать новый через new_event_loop()

new_event_loop() для тогоже объекста loop?

loop.run_until_complete(asyncio.gather(*task_list)) Тут звездочка чтобы он всё принял в args? Разве нельня просто передать кортеж?

loop.run_until_complete(asyncio.gather(*task_list)) Тут звездочка чтобы он всё принял в args? Разве нельня просто передать кортеж?

https://docs.python.org/3/library/asyncio-task.html#asyncio.gather

Понял, тупой вопрос

Если ли вариант запустить всё tasks и продолжить выполнение программы?

да. просто весь код своей программы оберни в функцию async def и запусти в цикле )

class BotEvents: def __init__(self): @self.bot.event async def on_ready(): ... create_tasks() print('A') def create_tasks(): loop = asyncio.get_event_loop() task_list = [counter(server) for server in self.servers.keys()] loop.run_until_complete(asyncio.gather(*task_list)) loop.close()

да. просто весь код своей программы оберни в функцию async def и запусти в цикле )

как то я туплю

Не подскадите??

Я BS4 установил

pip3 install lxml

понял, сейчас попробую. спасибо

def get_text_html(html): return забыл

pip3 install lxml

Спасибо!

Я не забыл я еще дальше пишу! Спасибо еще раз!

loop = asyncio.get_event_loop() task_list = [counter(server) for server in self.servers.keys()] loop.run_forever(asyncio.gather(*task_list)) loop.close()

Traceback (most recent call last): File "/home/poppy/.local/lib/python3.5/site-packages/discord/client.py", line 307, in _run_event yield from getattr(self, event)(*args, **kwargs) File "/media/poppy/Ntfs_128gb/Projects/python3/Social networks/Discord/bots/LiveCounter/botevents.py", line 17, in on_ready await run_counter() File "/media/poppy/Ntfs_128gb/Projects/python3/Social networks/Discord/bots/LiveCounter/botevents.py", line 23, in run_counter loop.run_until_complete(asyncio.gather(*task_list)) File "/usr/lib/python3.5/asyncio/base_events.py", line 454, in run_until_complete self.run_forever() File "/usr/lib/python3.5/asyncio/base_events.py", line 408, in run_forever raise RuntimeError('This event loop is already running') RuntimeError: This event loop is already running

Traceback (most recent call last): File "/home/poppy/.local/lib/python3.5/site-packages/discord/client.py", line 307, in _run_event yield from getattr(self, event)(*args, **kwargs) File "/media/poppy/Ntfs_128gb/Projects/python3/Social networks/Discord/bots/LiveCounter/botevents.py", line 17, in on_ready await run_counter() File "/media/poppy/Ntfs_128gb/Projects/python3/Social networks/Discord/bots/LiveCounter/botevents.py", line 23, in run_counter loop.run_until_complete(asyncio.gather(*task_list)) File "/usr/lib/python3.5/asyncio/base_events.py", line 454, in run_until_complete self.run_forever() File "/usr/lib/python3.5/asyncio/base_events.py", line 408, in run_forever raise RuntimeError('This event loop is already running') RuntimeError: This event loop is already running

loop уже запущен. Тогда нужно в уже запущенный закинуть свои таски. Попробуй loop.gather

Или asyncio.gather(loop=loop) забыл как правильно

task_list = [counter(server) for server in self.guilds.keys()] loop.gather(asyncio.gather(*task_list)) ?

task_list = [counter(server) for server in self.guilds.keys()] asyncio.gather(*task_list, loop=loop))

Можешь в крации роль await?

До запуска есть функция получения инфы, если я ставлю await servers_info() То есть ошибка лишь про RuntimeError: This event loop is already running И всё равно запускаются counter Если я убираю await, то сыпятся /media/poppy/Ntfs_128gb/Projects/python3/Social networks/Discord/bots/LiveCounter/botevents.py:16: RuntimeWarning: coroutine 'BotEvents.__init__.<locals>.servers_info' was never awaited servers_info() Ignoring exception in on_ready Traceback (most recent call last): File "/home/poppy/.local/lib/python3.5/site-packages/discord/client.py", line 307, in _run_event yield from getattr(self, event)(*args, **kwargs) File "/media/poppy/Ntfs_128gb/Projects/python3/Social networks/Discord/bots/LiveCounter/botevents.py", line 20, in on_ready loop.run_until_complete(asyncio.gather(*task_list)) File "/usr/lib/python3.5/asyncio/base_events.py", line 454, in run_until_complete self.run_forever() File "/usr/lib/python3.5/asyncio/base_events.py", line 408, in run_forever raise RuntimeError('This event loop is already running') RuntimeError: This event loop is already running Traceback (most recent call last): File "main.py", line 25, in <module> DiscordBot() File "main.py", line 21, in __init__ self.bot.run(const.BOT_TOKEN) File "/home/poppy/.local/lib/python3.5/site-packages/discord/client.py", line 519, in run self.loop.run_until_complete(self.start(*args, **kwargs)) File "/usr/lib/python3.5/asyncio/base_events.py", line 464, in run_until_complete raise RuntimeError('Event loop stopped before Future completed.') RuntimeError: Event loop stopped before Future completed. И программа закрывается

если уже запущен, то run_until_complete не требуется, надо wait

ну или наоборот, если ты сначала что-то запускал асинковое, то надо было это делать в run_until_complete, чтобы луп был снова остановленным

await servers_info() task_list = [counter(server) for server in self.guilds.keys()] asyncio.gather(*task_list) Получилось вот таким вариантом, тоесть await переключается после servers_info на сопрограмму с функцией counter, так?

Всем привет! Кто знает как в telnetlib обработаь правильно не верный логин/пароль? tn = telnetlib.Telnet(T_HOST,23,5) tn.read_until("Username: ", 5) tn.write(T_USER + "\n") if T_PASSWORD: tn.read_until("Password: ", 5) tn.write(T_PASSWORD + "\n") #tn.write('show switch') data = '' tn.read_until('#') tn.write('show fdb port 1\n') while data.find('#') == -1: data = tn.read_very_eager() print data sleep(1)

если он по какойто причине не верный, где это ловить

Пацаны, питон или Пайтон?

В этом случае запускается функция за первым аргументом(Скажем с сервером 1) и всё, но если я нажму CTRL+C, то запустится функция уже с сервером 2

await servers_info() task_list = [counter(server) for server in self.guilds.keys()] asyncio.gather(*task_list) Получилось вот таким вариантом, тоесть await переключается после servers_info на сопрограмму с функцией counter, так?

Пацаны, питон или Пайтон?

пайсон (с межзубное)

не понял кто на ком стоял, но на всякий случай скажу, что наверняка можно )

Ну есть сервер который на asyncio работает, я хочу к нему добавить тгбота что бы они работали вместе

птон

Житон

петухон

https://forvo.com/word/python/#en

Пистон

ERROR: S client not available

Присоединяюсь

Пихтон

путхон

Путён

await servers_info() task_list = [counter(server) for server in self.guilds.keys()] asyncio.gather(*task_list) Получилось вот таким вариантом, тоесть await переключается после servers_info на сопрограмму с функцией counter, так?

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

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

await это ведь типа активации yield from

await это ведь типа активации yield from

yield это возврат итератора. a await это ожидание ответа от сопрограммы. немного другое. а уж асинхронные генераторы это вообще отдельная тема

yield это возврат итератора. a await это ожидание ответа от сопрограммы. немного другое. а уж асинхронные генераторы это вообще отдельная тема

yield это же как class только подметод аргумента

А насчет этого?

В этом случае запускается функция за первым аргументом(Скажем с сервером 1) и всё, но если я нажму CTRL+C, то запустится функция уже с сервером 2

await servers_info() task_list = [counter(server) for server in self.guilds.keys()] asyncio.gather(*task_list) Получилось вот таким вариантом, тоесть await переключается после servers_info на сопрограмму с функцией counter, так?

К тому что они запускаются по очереди, но так как внутри While True: то работает один из них

https://www.opennet.ru/opennews/art.shtml?num=49256

Что такого? Ничего криминального

Что такого? Ничего криминального

Обсуждение поднял Сальвадор Санфилиппо (Salvatore Sanfilippo), создатель СУБД Redis, который не считает, что переименование оправдано, но вынужден реагировать из-за давления со стороны политактивистов, призывающих не использовать Redis из-за применения дискриминационной терминалогии.

yield это возврат итератора. a await это ожидание ответа от сопрограммы. немного другое. а уж асинхронные генераторы это вообще отдельная тема

тогда почему 2 асинк функции могут работать одновременно, если обе ожидают ответа?

ПОЛИТАКТИВИСТОВ

Обсуждение поднял Сальвадор Санфилиппо (Salvatore Sanfilippo), создатель СУБД Redis, который не считает, что переименование оправдано, но вынужден реагировать из-за давления со стороны политактивистов, призывающих не использовать Redis из-за применения дискриминационной терминалогии.

Ну это уже тупо

Покуда такие термины как slave считаются чем-то особенным, они будут оставаться особенными

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

Обсуждение поднял Сальвадор Санфилиппо (Salvatore Sanfilippo), создатель СУБД Redis, который не считает, что переименование оправдано, но вынужден реагировать из-за давления со стороны политактивистов, призывающих не использовать Redis из-за применения дискриминационной терминалогии.

Весь мир долбанулся

ПОЛИТАКТИВИСТОВ

вот тоже интересно, они тут причем вообще.

вот тоже интересно, они тут причем вообще.

Деньги зарабатывают

тогда почему 2 асинк функции могут работать одновременно, если обе ожидают ответа?

Они не могут

тогда почему 2 асинк функции могут работать одновременно, если обе ожидают ответа?

чтобы так было ты должен их собрать через специальную функцию типа gather или wait иначе ты можешь и await от них вместе. await приостанавливает текущий поток выполнения.