Вопросы с меткой [asyncio]
Модуль для разработки асинхронного кода в Python
277
вопросов
0
голосов
1
ответ
30
показов
Python. Asyncio - порядок завершения работы корутин
Такой код
import asyncio
import time
async def nested():
print(f' start nested {int(time.time()-t0)}')
await asyncio.sleep(2)
print(f' finsih nested {int(time.time()-t0)}')
async def ...
0
голосов
0
ответов
10
показов
Как реализовать вызов асинхронных функций по расписанию в python?
Ниже приведен рабочий код на python для вызова синхронных функций по расписанию, но требуется вызывать их ассинхронный аналог. Как правильно реализовать вызов асинхронных функций по расписанию ? Какая ...
0
голосов
2
ответа
34
показа
Одинаковые результаты Asyncio и Синхронного кода
написал код, запустил, результаты примерно одинаковы:
4.6002631187438965 ----- 7.045402765274048.
Почему так, ведь, я думаю asyncio запускает всё вместе? А синхронный код в данном случае просто ...
2
голоса
2
ответа
82
показа
python как получить возвращаемое значение асинхронной функции
Как можно получить возвращаемое значение асинхронной фукнции
import asyncio
async def test(asd: bool):
if asd is True:
print("true")
return True
else:
print(&...
1
голос
0
ответов
25
показов
Почему await не работает в ThreadPoolExecutor?
async def check():
with ThreadPoolExecutor(max_workers=1) as executor:
executor.submit(run_payment_in_thread, session_str, api_id, api_hash, sess_name, bot_url, check, msg,
...
1
голос
1
ответ
41
показ
Как запустить asyncio код отдельно от общего event loop'a?
Есть бот в телеграмме, который парсит сайт, на каждого пользователя создается по 40-60 тасков (для каждого элемента который надо обработать),с большим количеством пользователей бот начинает тормозить, ...
1
голос
0
ответов
31
показ
Почему на Windows выдается ошибка "RuntimeError: Event loop is closed"?
Выдается ошибка указанная в заголовке при использовании Python 3.10 на Windows. По умолчанию, начиная с версии 3.8 используется ProactorEventLoop. Мне не совсем понятно, а почему, если оставить по-...
0
голосов
1
ответ
60
показов
Проблема с asyncio в телеграм боте на aiogram (python)
Пишу телеграм бота на библиотеке aiogram, и мои команды запускают долгие парсеры сайтов. Проблема в том, что когда один человек запустил такой парсер, у всех остальных перестает работать бот. Решил ...
0
голосов
1
ответ
68
показов
Python. Выполнение задач в определенное время, asyncio, aicron, aioschedule
Стоит теоретическая цель, отсылать пользователю в телеграм сообщение в определенное (личное для каждого пользователя) время. Но я тут чтобы не захламлять, не буду подключать aiogram и т.д.
import ...
0
голосов
0
ответов
38
показов
В Python не срабатывают два for подряд
пишу авто-проверку контента на страницах сайта, хочу чтобы поочередно выводился текст где выводится указание в каком блоке ошибка и url страницы, если запускать всё сплошняком, работает, но не ...
0
голосов
1
ответ
58
показов
как менять прокси на каждом запросе используя aiohttp
когда мне нужно асинхронно отправить несколько get запросов я делаю так:
async def fetch(session, url):
headers={
'user-agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537....
0
голосов
2
ответа
36
показов
Ошибка: client_session: <aiohttp.client.ClientSession object at 0x0000000004CC4A60> Unclosed connector connections:
Ошибка: client_session: <aiohttp.client.ClientSession object at 0x0000000004CC4A60>
Unclosed connector
connections: ['[(<aiohttp.client_proto.ResponseHandler object at 0x0000000004C9BCA0>, ...
0
голосов
0
ответов
49
показов
asyncio httpx Python/Django
Всем привет!
Есть функция, которая запускает с шаблона async функцию
def mon(request):
asyncio.set_event_loop_policy(asyncio.WindowsSelectorEventLoopPolicy())
asyncio.run(deffl())
...
...
0
голосов
0
ответов
39
показов
Асинхронный запуск функции
У меня есть функция update_db, которая обновляет базу данных. Функция get_product работает секунд 10. Если у меня будет 100 товаров, то функция update_db будет выполняться очень долго. Как можно ...
0
голосов
0
ответов
31
показ
выдаёт такую ошибку после конекта
Код:
import asyncio
import datetime
from telethon import TelegramClient
from telethon import errors
from telethon import functions, types
api_id = int(input("Api id: "))
api_hash = input('...
0
голосов
1
ответ
55
показов
Python asyncio помогите с асинхронностью
Программа проверяет на доступность различные url'ы.
Через цикл это очень медленно из-за того, что сервера отвечают не сразу и все последовательно. Была мысль завернуть их все в потоки, но кажется это ...
0
голосов
1
ответ
54
показа
Всё равно ждёт. Асинхронный Python
Разбираюсь с аsync в Python.
Вроде понимаю особенность работы асинхронности,но в есть программа, где имеется долгое ожидание, и почему то диспетчер ожидает, вместо того, чтобы проверить другой объект.
...
1
голос
1
ответ
142
показа
Выдает ошибку "AttributeError: 'NoneType' object has no attribute 'acquire'" при попытке создать список из базы данных
Здравствуйте столкнулся с проблемой. Есть асинхронная функция в классе Базы данных get_url_price при вызове выдает следующую ошибку.
base_events.py:1729 #ERROR [2022-02-15 23:06:03,774] - ...
0
голосов
1
ответ
36
показов
Функция с queue(python) не выполняеться While True
Функция с queue(python) не выполняеться While True. Я имею ввиду я не могу за 1 секунду записать 5 сообщений в queue для проверки добавления в ту же queue
from asyncio import Queue
import asyncio
q = ...
0
голосов
0
ответов
84
показа
бот на aiogram и api google sheets
Мне нужно, чтобы бот через какие-то промежутки времени добавлял к гугл таблице строку, но когда пытаюсь через asyncio.to_thread или threading вывести таймер в поток, выдается ошибка.
Запуск бота:
from ...
0
голосов
1
ответ
36
показов
Ожидание выполнения асинхронной функции внутри асинхронной функции
Через библиотеку telethon программа реагирует на новые сообщения в канале. Действия после получения нового сообщения требуют некоторого времени. Если в этот промежуток в канале выйдет новое сообщение, ...
0
голосов
0
ответов
23
показа
Хочу запустить бота discord.py в корутинах, но вылетает ошибка asyncio
У меня есть код в корутинах
async def messagespammer_function(token, serverid, msg, chan, proxie, exittasks, loop):
if(proxie=="True"):
proxy_list = open("proxies.txt").read()....
0
голосов
0
ответов
39
показов
Замер скорости запросов в aiohttp
У меня есть 1000 запросов которые я выполняю "параллельно" через aiohttp.Как мне замерить скорость ответа на каждый запрос? Или может есть какой другой способ отправки большого кол-ва ...
0
голосов
1
ответ
53
показа
Как в помощью Asyncio создать функцию постоянно выполняющуюся на фоне
Необходимо сделать цикл (как вариант библиотека Asyncio) который будет работать в фоне параллельно с работой основного кода. Этакая многопоточность.
Пример:
пользователь вводит цифры в программу, а ...
0
голосов
1
ответ
119
показов
Не могу победить ошибку RuntimeWarning: coroutine 'save_res' was never awaited
Имеется неторая струкутура файлов:
some_project
│
├───some_files
│ ├───save_res.py
│ ├───some_class_1.py
│ └───some_class_.py
└───
some_class_1.py
import asyncio
import aiohttp
class ...
0
голосов
2
ответа
55
показов
Python выполнение кода, но с возможностью ввода команды
def test():
for i in range(100):
print(i)
time.sleep(5)
def main():
while True:
response = input(">>> ")
if response == 'quit':
...
-1
голос
1
ответ
184
показа
Как отправить 500 запросов на сайт в секунду python
У меня есть сайт с которого я бы хотел получить ошибку 404 если страница не существует и код ответа 200, если страница на сайте существует, я использовал асинхронный код для отправки get запросов на ...
0
голосов
1
ответ
31
показ
Ожидание выполнения задачи и блокировка формы PyQt5
Как вызвать диалог, который заблокирует основную форму, но при этом чтобы код из основной формы продолжил выполняться?
Я использую PyQt5 и qasync, при нажатии на кнопку у меня выполнятся асинхронный ...
0
голосов
0
ответов
19
показов
Ошибка : RuntimeWarning. Не выполняется асинхронная функция | Python | asyncio | pywebio
Не выполняется асинхронная функция. Выбивает ошибку:
RuntimeWarning: coroutine 'run_login' was never awaited onclick[btn_idx]()
RuntimeWarning: Enable tracemalloc to get the object allocation ...
0
голосов
0
ответов
59
показов
Как использовать asyncio внутри потока в приложении на pyqt5?
У меня есть приложение на pyqt5, внутри функции которого я создаю потоки через измененный класс, с целью остановки потока по желанию пользователя. После чего внутри потока используется asyncio, что ...
0
голосов
0
ответов
48
показов
Asyncio в потоке в приложение Pyqt5
У меня есть приложение на pyqt5, внутри функции которого я создаю потоки через измененный класс, с целью остановки потока по желанию пользователя. После чего внутри потока используется asyncio, что ...
0
голосов
0
ответов
34
показа
Асинхронность в базах данных с python
На оракле есть несколько баз данных с одинаковыми структурами, но разными данными с достаточно большим объемом информации. сейчас есть необходимость создать программу которая будет запрашивать данные ...
0
голосов
1
ответ
275
показов
Как пропустить Please enter your phone (or bot token): в Telethon
У меня есть определенный набор Telegram аккаунтов в виде Telethon сессий, и какие-то из них рабочие, а какие-то нет. Если рабочие, то функция выполняет определенный скрипт и все ок, а если же он ...
-1
голос
2
ответа
119
показов
telethon, async
from telethon import TelegramClient
import time
api_id = 123123
api_hash = '123123123'
client = TelegramClient('session_name', api_id, api_hash)
@client.on(events.NewMessage(chats=('https://t.me/chat')...
1
голос
1
ответ
39
показов
Запуск нескольких задач одновременно в PyQt5
Я разрабатываю приложение на PyQt5 с использованием qasync. Допустим на форме есть некие настройки, поле для вывода лога и кнопки запустить/остановить. При выполнении одной задачи проблем не возникает:...
0
голосов
0
ответов
31
показ
Помогите понять, почему ассинхронный парсер работает синхронно
Пытаюсь разобраться с асинхронной работой... Для сравнения написал синхронный и асинхроный код для загрузки с "jsonplaceholder" и сохранения в PostgreSQL. Вот только мой синхронный код ...
0
голосов
0
ответов
39
показов
Event loop is closed. Вызывается после закрытия дискорд бота
Всем привет. Есть довольно необычная проблема. Я написал дискорд бота. Он спокойно функционирует и работает запросы обрабатывает. Но есть одно но. После завершения (выключения) бот выдает ошибку.
...
0
голосов
1
ответ
39
показов
Как переключиться на другую вкладку в arsenic?
Как переключиться на другую вкладку в arsenic (асинхронный аналог selenium)? Если в selenium driver.switch_to.window(driver.window_handles[1]) работает отлично, то как такое же решение реализовать в ...
0
голосов
0
ответов
90
показов
ValueError: The future belongs to a different loop than the one specified as the loop argument
Происходит гонка двух или более потоков. Ошибка:
raise ValueError('The future belongs to a different loop than '
ValueError: The future belongs to a different loop than the one specified as the loop ...
0
голосов
1
ответ
63
показа
Asyncio и aiohttp отправка запросов
Я не совсем понимаю, как работает aiohttp вместе с create_task с asyncio, порой всё работает так как нужно, а порой наоборот.
Я написал небольшой код, который казалось бы, что должен вывести ...
0
голосов
0
ответов
27
показов
Исправление асинхронного кода
Я знаю что selenium не поддерживает асинхронность и перехожу в arsenic (асинхронный аналог selenium). И если в selenium код работает отлично, то в arsenic код как и полагается кликает на accept, но ...
0
голосов
0
ответов
31
показ
Как код сделать асинхронным?
Как этот код можно выполнить асинхронно, он работает, но синхронно. Ведь я сравнивал по времени выполнения и разницы никакой нет
import asyncio
from selenium import webdriver
import time
def ...
0
голосов
0
ответов
16
показов
Как исправить ошибку в асинхронности имитирования процесса?
Здраствуйте, пытаюсь реализовать имитацию процесса из этой темы - Тык
Вышел, вот такой код, в котором асинхронность слегка не асинхронна, ибо мне нужно, чтобы процессы внутри main выполнялись ...
0
голосов
1
ответ
28
показов
Как реализовать имитацию процесса асинхронно?
Здраствуйте, есть такая схема
Где первый элемент это очередь вместимостью 6 элементов, а дальше 2 обработчика, суть в том, что с какой-то рандомной задержкой (1-2 секунды) мы запускаем в очередь ...
0
голосов
0
ответов
62
показа
Почему результат запроса через Aiohttp неверный, а через request все получается?
import requests
burp0_url = "https://m.avito.ru/api/11/items?key=1&priceMin=1&priceMax=9999999&owner[]=private&sort=date&query=iphone&page=1&display=list&limit=30&...
0
голосов
0
ответов
24
показа
использование памяти ProcessPoolExecutor в Python
я использую ProcessPoolExecutor вместе с loop.run_in_executor() из asyncio. память после выполнения корутины не очищается, процесс все также держит ее в себе. прочитав https://bugs.python.org/...
0
голосов
1
ответ
55
показов
как реализовать click в библиотеке arsenic
Перехожу с selenium в arsenic и возникла ошибка с кликом, если в selenium это работало, то в arsenic, как я понял, клик работает по-другому, и, соответственно, ошибка:
AttributeError: 'coroutine' ...
0
голосов
0
ответов
84
показа
Python Websocket как развернуть/deploy на удаленном vps*server (Windows 2012)
# Web socket Server
# просто получает сообщение от клиента
import asyncio
import websockets
async def response(websocket, path):
message = await websocket.recv()
print(f"We got a ...
0
голосов
0
ответов
44
показа
Не работает очередь вопроизведения музыки у дискорд бота, что делать?
Я попробовал разобраться как реализовать очередь воспроизведения, но зашёл в тупик, и как понимаю написал глупость. Буду рад любой помощи:>
Если это максимально глупая ошибка, то прошу без хейта, я ...
0
голосов
1
ответ
127
показов
Объединение 2х бесконечных циклов в python telethon
У меня есть 2 скрипта по автоматической отправке сообщений от моего имени в канал. Запускаю при помощи параллельного выполнения скриптов. Не очень удобно запускать по 2 сессии. Пытался использовать ...