Вопросы с меткой [asyncio]

Модуль для разработки асинхронного кода в Python

Фильтрация
Сортировка
Метки
0 голосов
2 ответа
54 показа

В asyncio не все coros выполняются до конца

Начал разбираться в asyncio. Делаю тестовую программу в которой асинхронно запускаются несколько функций и которые засыпают на определенное время. Для проверки хода выполнения кода в каждой функции ...
Вася Пупкин's user avatar
0 голосов
0 ответов
33 показа

Чем заменить Executor при переходе на aiogram 3?

Есть бот, написанный с использованием Executor aiogram 2.25. Совместно крутится поллинг и таск для работы с БД. При выходе по Ctrl/C поллинг и таск штатно закрываются. Структурно код такой: from ...
remendado's user avatar
0 голосов
1 ответ
20 показов

Асинхронная фильтрация списка строк

filtered_strings = [string for string in need_strings if string not in all_strings] Есть такая строка. Она находится внутри асинхронного метода и при выполнении останавливает все остальные ...
Myrsus Gap's user avatar
0 голосов
0 ответов
23 показа

Асинхронная загрузка файлов с dropmefiles

async def get_file_from_dmf(url: str,path): async with aiohttp.ClientSession() as session: async with session.get( 'https://drop1.dropmefile.com/dl' + urlparse(url).path, ...
Myrsus Gap's user avatar
0 голосов
0 ответов
33 показа

Переход на предыдущий шаг с помощью асинхронных функций

Мне нужно в телеграмм боте на aiogram 3 ввести данные паспорта (допустим, это будет 8 цифр) и проверить, есть ли в базе данных бота эти цифры (хранится в виде списка). Если есть, то поприветствовать и ...
Сергей Иванов's user avatar
0 голосов
0 ответов
18 показов

AttributeError: 'coroutine' object has no attribute 'chats'. Парсер для телеграмма на python (Telethon)

Код работал пока я не начал пытаться добавить всякие фичи. В интернет-руководстве код идентичен и работает. У меня уже руки опускаются. Проблема связанна с этим отрывком кода: chats = [] ...
keqy's user avatar
  • 1
0 голосов
0 ответов
38 показов

Ребята, кто сталкивался с созданием клиента pyrogram и авторизацией в телеграмме, хелпаните пожалуйста!

Возникла проблема с использованием кода из смс при авторизации clieta telegramm, а именно я не могу понять почему у меня не вызывается функция с этим кодом из моего модуля, ниже предоставляю код: Код ...
Sonder's user avatar
  • 1
0 голосов
0 ответов
30 показов

aiocron.crontab() срабатывает 2 раза (Python aiocron)

@aiocron.crontab("25 15 * * *") async def notifications(): with connection.cursor() as cursor: cursor.execute("""SELECT user_id FROM users WHERE notifications = 1&...
Viktorio135's user avatar
0 голосов
0 ответов
21 показ

Не приходит ответ от asyncio.queues.Queue.get

вот кусочек кода from asyncio.queues import Queue async def func(self, timeout): # self.q = Queue присваивается выше return await asyncio.wait_for(self.q.get(), timeout) Здесь не ...
Daniil's user avatar
  • 13
0 голосов
0 ответов
24 показа

Правильно ли делаю параллельные задачи?

У меня есть таблица в базе данных, которая содержит запросы, которые будут отправлены в будущем. И мне нужно, чтобы все задачи (отправка, уменьшение времени, проверка пользователей, проверка премиум) ...
vefixx's user avatar
  • 1
0 голосов
0 ответов
35 показов

Съедается начало ответа от api GPT при асинхронном запросе

Всем привет! Пишу бота через aiogram и прикрутил к нему gpt, но при асинхронных запросах начало съедать начало текста. Такая штука только при асинхронном запросе, через модуль Openai. Пробовал и через ...
Denis Denmer's user avatar
0 голосов
1 ответ
36 показов

После рассылки происходит ошибка "Unclosed client session"

Пишу бот в который рассылает даты, есть основной файл мейн он работает нормально И есть файл crona.py, он запускается каждый день по времени (использую pythonanywere) Код отрабатывает хорошо, только ...
ironman47's user avatar
1 голос
0 ответов
32 показа

Как остановить проигрывание музыки в музыкальном боте discord.py, если используется аргумент after?

Делаю музыкального бота на Python с помощью discord.py. Сам бот уже формирует какую-никакую очередь, проигрывает музыку. Однако столкнулся с такой проблемой: async def playSong(ctx, voice, path): ...
Termos189's user avatar
0 голосов
1 ответ
27 показов

Асинхронная функция из синхронной в Python и discord.py

В моём дискорд-боте необходимо вызвать асинхронную функцию из синхронной, т.к. функция play voice_client'а принимает только синхронный коллбек. Т.к. сама библиотека Discord.py асинхронная, в ней уже ...
kaban339's user avatar
0 голосов
1 ответ
36 показов

Почему в асинхронной функции при задержке не переключается на другую работу?

Тестирую асинхронный ping. По умолчанию host3 отбрасываю в исключения, а host6 недоступный. По логике при проверке недоступного host3 во время ожидания должны сразу переключиться на проверку других ...
legion088's user avatar
0 голосов
2 ответа
27 показов

Приложение не отвечает

Данный кусок кода успешно выполняется, НО в самом дискорде пишет сообщение о том что Приложение не отвечает. В самой консоли ошибок не сообщается. По разному искал решение так и не смог добиться ...
ProGaMEr110 521's user avatar
2 голоса
1 ответ
36 показов

Создание неблокирующего асинхронного цикла в Python

Необходимо считывать через WebSocket поступающие на клиент сообщения, для этого у меня есть функция подключения к серверу, которая через async for читает содержимое канала с сообщениями. В моем случае ...
Yksys126's user avatar
0 голосов
0 ответов
17 показов

Ускорение парсера animebuff

Я сейчас работаю над асинхронным парсером для animebuff, но столкнулся с проблемой скорости сбора данных парсера(это может затянуться до нескольких минут от 15 до 20 вроде, а может и больше). Хотел ...
The Fallen Angel's user avatar
1 голос
0 ответов
37 показов

Проблема с asyncio и asyncpg

Подскажите пожалуйста в чём проблема следующего кода: import asyncio import asyncpg class DataBase: def __init__(self, pool): self.pool = pool async def fetchone(self, query, *args):...
Filips's user avatar
  • 87
0 голосов
0 ответов
35 показов

Как реализовать расчет определенных индикаторов торговли в реальном времени?

К примеру, есть функция, которая прослушивает вебсокет binance и обрабатывает ивент, который содержит данные о свечах async def kline_listener(bsm: BinanceSocketManager, client: AsyncClient, symbol: ...
milt's user avatar
  • 1
0 голосов
0 ответов
24 показа

как отправлять сообщение дискорд бота из другого питон файла?

Есть дискорд бот на discord.py, но bot.run(token) указывается в конце, и я не могу просто импортировать bot из другого файла как в тг. В общем, есть бот который вызывает функцию add_queue из другого ...
Artik gnom's user avatar
0 голосов
0 ответов
12 показов

Не получается обрабатывать два события в pyrogram

пишу бота для телеграмм с использованием pyrogram. Нужно сделать рассылку по чатам по айди, что я и сделал: async def start_mailing(): while True: if check_time(settings['timer']): # Нужно ...
Kewsen's user avatar
  • 49
0 голосов
0 ответов
51 показ

Ускорение парсинга с помощью asyncio

мне нужно как то ускорить парсинг до 3 сек. возможно ли это? там 3000 объявлений по 1000 по 3 категориям import aiohttp import json import time import asyncio headers = { "User-Agent": &...
Улукман's user avatar
1 голос
2 ответа
68 показов

Как выполнять асинхронные функции циклично каждые 30 минут, час?

У меня есть телеграмм бот, мне нужно чтобы о каждые 2 минуты проверял базу данных В этой базе хранится список заявок бронирования, у каждой заявки есть время на которое пользователь забронировал что-...
Serosha's user avatar
  • 13
0 голосов
0 ответов
86 показов

В чем причина ошибки: AttributeError: 'NoneType' object has no attribute 'execute'

создаю бд для тг-бот с помощью asyncpg. Ниже представлен мой код Это код из модуля, где я создаю соединение: import asyncpg from asyncpg.pool import Pool from typing import Union from config_data....
Никита's user avatar
0 голосов
0 ответов
522 показа

ConnectionRefusedError: [WinError 10061] Подключение не установлено, т.к. конечный компьютер отверг запрос на подключение | PyQt и Socket

Пишу программу на Python с графическим интерфейсом. Которая передает камеру компьютера на другой ПК (Camera Streaming). Не знаю проблема ли в этом или нет, но мне кажется что я не правильно сделал ...
Vagif's user avatar
  • 35
1 голос
0 ответов
42 показа

Асинхронный таймер на тг боте Aiogram python

В общем задача создать бота, который выполняет определённые действия, если пользователь не ответит ему за определённый промежуток времени. async def timer(chat_id, state: FSMContext): await ...
bomjara62's user avatar
0 голосов
0 ответов
32 показа

TelegramBadRequest aiogram lib при попытке отправить фото в телеграм бота

В общем, нашел недавно api для rule34. Хочу сделать интеграцию фот в бота от туда. Начинает искать фото, и иногда вылезает ошибка aiogram.exceptions.TelegramBadRequest: aiogram.exceptions....
BadRabbit's user avatar
0 голосов
0 ответов
37 показов

Async websocket Python

Пишу асинхронный модуль отправки сообщений по WS. Сообщения для отправки должны формироваться отдельно от самого Вебсокета. Ничего другого, кроме как Asyncio.Queue() не придумал (может подскажите ...
Firefly74's user avatar
0 голосов
0 ответов
26 показов

Варнинг телеграм бота/парсера о незакрытой сессии

Как избавиться от данного варнинга? Варнинг: Unclosed client session client_session: <aiohttp.client.ClientSession object at 0x0000023A0B07EA90> Unclosed connector connections: ['[(<aiohttp....
Almas Kassymkhan's user avatar
0 голосов
0 ответов
31 показ

Получение данных с websocket

Здраствуйте, помогите пожалуйста с решением. Я попытаюсь обьяснить максимально просто задачу и кину код, буду очень благодарен за любую помощь. Задача следующая: получать данные из вебсокета в ...
Alex's user avatar
  • 11
0 голосов
0 ответов
35 показов

При запуске ТГ бота магазина, вылетает ошибка

import asyncio from aiogram import executor from config import admin_id from database import create_db from load_all import bot async def on_shutdown(dp): await bot.close() async def on_startup(dp)...
Viktor ZLOY's user avatar
1 голос
1 ответ
107 показов

Есть ли области где многопоточность лучше, чем асинхронность в python?

В python есть 3 способа выполнять код одновременно: многопроцессорность многопоточность асинхронность Если с многопроцессорностью всё понятно - она позволяет реально распараллелить задачу, то насчет ...
Кирилл Сыроежкин's user avatar
0 голосов
2 ответа
32 показа

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

Проблема с асинхронным получением данных от сервера. Если синхронно через функцию обращаться к серверу, то программа замирает, пока не придет какой-то ответ. При оборачивании функции в Task работает ...
Сергей Князев's user avatar
1 голос
1 ответ
49 показов

Не могу запустить процессы concurrent.futures с асинхронной функции

Есть такой код: import asyncio from concurrent.futures import ProcessPoolExecutor async def test1(text: str): for _ in range(2): await asyncio.sleep(1) print(text.upper()) async ...
Printon's user avatar
  • 95
0 голосов
1 ответ
103 показа

Посоветуйте библиотеку для асинхронных запросов, аналог requests

В общем пишу телеграм бота и использую там библиотеку requests, оказалось что она не работает в асинхроне и ищу аналог. Посоветуйте, пожалуйста, библиотеку для получения кода страницы, которая будет ...
R4mBLe_'s user avatar
  • 49
1 голос
1 ответ
76 показов

Крашится Телеграм бот когда его используют два человека одновременно

Пишу бота на aiogram, использую Python. Вот код: import requests from bs4 import BeautifulSoup import asyncio import logging from aiogram import Bot, Dispatcher, executor, types import config ...
R4mBLe_'s user avatar
  • 49
2 голоса
1 ответ
94 показа

Как дождаться завершения потока в асинхронном коде

У меня есть телеграмм бот, написанный на aiogram взаимодействующий с БД - aiomysql. И функция, которая принимает нажатие кнопки, имеет подпоток, в котором for loop обходит массив, создает конечное ...
xesilver's user avatar
-2 голоса
1 ответ
242 показа

Почему поток выполнения прерывается на await?

Вот мой код: import asyncio import logging from abc import ABC, abstractmethod from collections.abc import Awaitable, Callable from typing import Any, AsyncIterator from queue import Queue, Empty from ...
Aycon's user avatar
  • 390
0 голосов
1 ответ
72 показа

Новый поток блокирует выполнение основного процесса

У меня есть телеграмм бот, написанный на aiogram. Сам бот запускается в отдельном процессе: def start_bot(): executor.start_polling(dp, skip_updates=True) if __name__ == '__main__': Process(...
vortexsf24's user avatar
1 голос
0 ответов
33 показа

raise TooManyRedirects( aiohttp.client_exceptions.TooManyRedirects: 0, message='', url=URL

from bs4 import BeautifulSoup import asyncio import aiohttp async def gather_data(): asyncio.set_event_loop_policy(asyncio.WindowsProactorEventLoopPolicy()) headers = {"Accept": &...
Максим's user avatar
0 голосов
1 ответ
63 показа

Как запустить функцию другого модуля в новом процессе

Возникла проблема с асинхронностью кода на python. У нас есть бот, написанный на библиотеке aiogram. В нем необходимо создать процесс, в котором будет бесконечно выполнятся функция из другого модуля. ...
vortexsf24's user avatar
0 голосов
0 ответов
63 показа

Aiohttp.ClientSession проблема при работе с большим количеством запросов через proxy

Я создаю большое количество сессий aiohttp.ClientSession и отправляю запросы через http-proxy. Пример кода прикладываю Все работает корректно, до того момента , как я пытаюсь одновременно отправить ...
leshalesha_'s user avatar
0 голосов
1 ответ
59 показов

Может ли в python поток выполнения выполнить команду после `await` до завершения ожидания?

Предположим, у меня есть следующий код: from my_module import MyTask import asyncio async def main(): async def controll(fsuspend): await asyncio.sleep(2) resume = await fsuspend()...
Aycon's user avatar
  • 390
0 голосов
0 ответов
36 показов

Как запустить асинхронную программу и программу на PyQt5 кореектно?

Есть 2 программы, первая построена на блокирующих функциях опроса различных устройств через последовательные порты, общается с базой данных и иногда шлет информацию на сервер. Так как много ...
Michael's user avatar
  • 35
0 голосов
1 ответ
68 показов

Помогите соединить две функции в одном файле Python. Юзербот на pyrogram

Помогите исправить код, чтобы в одном файле можно было запустить одновременно две функции, где async def auto_answer - отвечает за автоответ на сообщения, а async def main - за рассылку. У меня ...
Asya's user avatar
  • 23
0 голосов
0 ответов
30 показов

Множество пулов asyncpg

Хочу сделать единый класс для взаимодействия с базой данных, но чтобы использовался один пул (реализовал через паттерн синглтон), но при этом, чтобы я мог переключаться между базами данных не ...
DIMFLIX OFFICIAL's user avatar
0 голосов
0 ответов
28 показов

RuntimeError: Event loop is closed. Asyncio

import asyncio import aiohttp from time import time import aiofiles async def fetch_content(url, session): async with session.get(url, allow_redirects=True) as response: data = await ...
Fleny's user avatar
  • 1
0 голосов
1 ответ
40 показов

Асинхронный роут выполняется не совсем асинхронно

Цель: Запустить функцию bm() асинхронно для с помощью TaskFactory. Ну и после запуска вычитывать прогресс выполнения. Проблема: Код полностью работает. Проблема в асинхронности. Ставлю точку на return ...
Vitaliy Stop_RU_war_in_UA's user avatar
0 голосов
0 ответов
39 показов

Бот отвечает на собственные сообщения

Пишу бота для техподдержки.Когда я отправляю вопрос, бот пересылает его на канал и начинает пересылать его тоже. И так продолжается бесконечно. Пример(User- пользователь, который отправил боту вопрос, ...
agfn's user avatar
  • 15

1
2 3 4 5
9