apschedule и asyncio
Всем доброго времени суток! Помогите, пожалуйста с асинхронными циклами. Как сделать так, чтобы не было ошибки "RuntimeError: Event loop is closed" ? import asyncio from…
Всем доброго времени суток! Помогите, пожалуйста с асинхронными циклами. Как сделать так, чтобы не было ошибки "RuntimeError: Event loop is closed" ? import asyncio from…
Кратко суть проблемы: Написал telegram бота (пишу далеко не первый раз) и появилась очень странная проблема: через некоторое продолжительное время (2-5 часов) (я так понимаю при н…
Если кратко, то у меня такая проблема: Пользователь А вводит сложный запрос, начинается обработка, через 5 секунд Пользователь Б вводит другой запрос. Бот заканчивает обработку дл…
Пишу бот в который рассылает даты, есть основной файл мейн он работает нормально И есть файл crona.py, он запускается каждый день по времени (использую pythonanywere) Код отрабаты…
Делаю музыкального бота на Python с помощью discord.py. Сам бот уже формирует какую-никакую очередь, проигрывает музыку. Однако столкнулся с такой проблемой: async def playSong(ct…
В моём дискорд-боте необходимо вызвать асинхронную функцию из синхронной, т.к. функция play voice_client'а принимает только синхронный коллбек. Т.к. сама библиотека Discord.py аси…
Тестирую асинхронный ping. По умолчанию host3 отбрасываю в исключения, а host6 недоступный. По логике при проверке недоступного host3 во время ожидания должны сразу переключиться …
Данный кусок кода успешно выполняется, НО в самом дискорде пишет сообщение о том что Приложение не отвечает. В самой консоли ошибок не сообщается. По разному искал решение так и н…
Необходимо считывать через WebSocket поступающие на клиент сообщения, для этого у меня есть функция подключения к серверу, которая через async for читает содержимое канала с сообщ…
Подскажите пожалуйста в чём проблема следующего кода: import asyncio import asyncpg class DataBase: def __init__(self, pool): self.pool = pool async def fetchone(self, query, *arg…
К примеру, есть функция, которая прослушивает вебсокет binance и обрабатывает ивент, который содержит данные о свечах async def kline_listener(bsm: BinanceSocketManager, client: A…
пишу бота для телеграмм с использованием pyrogram. Нужно сделать рассылку по чатам по айди, что я и сделал: async def start_mailing(): while True: if check_time(settings['timer'])…
мне нужно как то ускорить парсинг до 3 сек. возможно ли это? там 3000 объявлений по 1000 по 3 категориям import aiohttp import json import time import asyncio headers = { "Us…
У меня есть телеграмм бот, мне нужно чтобы о каждые 2 минуты проверял базу данных В этой базе хранится список заявок бронирования, у каждой заявки есть время на которое пользовате…
Пишу программу на Python с графическим интерфейсом. Которая передает камеру компьютера на другой ПК (Camera Streaming). Не знаю проблема ли в этом или нет, но мне кажется что я не…
В общем задача создать бота, который выполняет определённые действия, если пользователь не ответит ему за определённый промежуток времени. async def timer(chat_id, state: FSMConte…
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 …
В python есть 3 способа выполнять код одновременно: многопроцессорность многопоточность асинхронность Если с многопроцессорностью всё понятно - она позволяет реально распараллелит…
Проблема с асинхронным получением данных от сервера. Если синхронно через функцию обращаться к серверу, то программа замирает, пока не придет какой-то ответ. При оборачивании функ…
Есть такой код: import asyncio from concurrent.futures import ProcessPoolExecutor async def test1(text: str): for _ in range(2): await asyncio.sleep(1) print(text.upper()) async d…
В общем пишу телеграм бота и использую там библиотеку requests, оказалось что она не работает в асинхроне и ищу аналог. Посоветуйте, пожалуйста, библиотеку для получения кода стра…
Пишу бота на aiogram, использую Python. Вот код: import requests from bs4 import BeautifulSoup import asyncio import logging from aiogram import Bot, Dispatcher, executor, types i…
У меня есть телеграмм бот, написанный на aiogram взаимодействующий с БД - aiomysql. И функция, которая принимает нажатие кнопки, имеет подпоток, в котором for loop обходит массив,…
Вот мой код: import asyncio import logging from abc import ABC, abstractmethod from collections.abc import Awaitable, Callable from typing import Any, AsyncIterator from queue imp…
У меня есть телеграмм бот, написанный на aiogram. Сам бот запускается в отдельном процессе: def start_bot(): executor.start_polling(dp, skip_updates=True) if __name__ == '__main__…
from bs4 import BeautifulSoup import asyncio import aiohttp async def gather_data(): asyncio.set_event_loop_policy(asyncio.WindowsProactorEventLoopPolicy()) headers = {"Accep…
Возникла проблема с асинхронностью кода на python. У нас есть бот, написанный на библиотеке aiogram. В нем необходимо создать процесс, в котором будет бесконечно выполнятся функци…
Я создаю большое количество сессий aiohttp.ClientSession и отправляю запросы через http-proxy. Пример кода прикладываю Все работает корректно, до того момента , как я пытаюсь одно…
Предположим, у меня есть следующий код: from my_module import MyTask import asyncio async def main(): async def controll(fsuspend): await asyncio.sleep(2) resume = await fsuspend(…
Есть 2 программы, первая построена на блокирующих функциях опроса различных устройств через последовательные порты, общается с базой данных и иногда шлет информацию на сервер. Так…