Всем привет! Помогите разобраться с отправкой сообщений через Aioschedule. Как не менял код, не могу добиться отправки сообщений в определенное время. Функцию job я сделал как затычку. Позже я сделаю инлайн клавиатуру, которая будет предлагать пользователю выбрать удобное время для отправки прогноза погоды и в выбранное время присылать сам прогноз.
Сам бот работает, но когда наступает заданное время, выдается данная ошибка:
Код ошибки
ask exception was never retrieved
future: <Task finished name='Task-4' coro=<scheduler() done, defined at c:\Users\zaggg\Desktop\WeatherBot\main.py:67> exception=TypeError('Passing coroutines is forbidden, use tasks explicitly.')>
Traceback (most recent call last):
File "c:\Users\zaggg\Desktop\WeatherBot\main.py", line 70, in scheduler
await schedule.run_pending()
File "C:\Users\zaggg\AppData\Local\Programs\Python\Python311\Lib\site-packages\aioschedule\__init__.py", line 544, in run_pending
await default_scheduler.run_pending()
File "C:\Users\zaggg\AppData\Local\Programs\Python\Python311\Lib\site-packages\aioschedule\__init__.py", line 111, in run_pending
return await asyncio.wait(jobs, *args, **kwargs)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\zaggg\AppData\Local\Programs\Python\Python311\Lib\asyncio\tasks.py", line 415, in wait
raise TypeError("Passing coroutines is forbidden, use tasks explicitly.")
TypeError: Passing coroutines is forbidden, use tasks explicitly.
C:\Users\zaggg\AppData\Local\Programs\Python\Python311\Lib\asyncio\base_events.py:1910: RuntimeWarning: coroutine 'Job.run' was never awaited
handle = None # Needed to break cycles when an exception occurs.
RuntimeWarning: Enable tracemalloc to get the object allocation traceback
Код бота:
import requests
import datetime
from config import open_weather_token, bot_token
from aiogram import Bot, types
from aiogram.dispatcher import Dispatcher
from aiogram.utils import executor
from aiogram.types import InlineKeyboardButton, InlineKeyboardMarkup
import aioschedule as schedule
import time
import asyncio
bot= Bot(token=bot_token)
dp= Dispatcher(bot)
@dp.message_handler(commands=["start"])
async def start_command(message: types.Message):
await message.reply ("Привет, {0.first_name}! Напиши мне название своего города и я пришлю сводку погоды!".format(message.from_user))
@dp.message_handler()
async def get_weather(message: types.Message):
code_to_smile= {
"Clear": "Ясно \U00002600",
"Clouds": "Облачно \U00002601",
"Rain": "Дождь \U00002614",
"Drizzle": "Дождь \U00002614",
"Thunderstorm": "Гроза \U000026A1",
"Snow": "Снег \U0001F328",
"Mist": "Туман \U0001F32B"
}
try:
r= requests.get(
f"http://api.openweathermap.org/data/2.5/weather?q={message.text}&appid={open_weather_token}&units=metric")
data= r.json()
city = data["name"]
cur_weather= data["main"]["temp"]
weather_description= data["weather"][0]["main"]
if weather_description in code_to_smile:
wd= code_to_smile[weather_description]
else:
wd= "Посмотри в окно, не пойму что там за погода!"
humidity = data["main"]["humidity"]
pressure = data["main"]["pressure"]
wind = data["wind"]["speed"]
sunrise_timestamp = datetime.datetime.fromtimestamp(data["sys"]["sunrise"])
sunset_timestamp = datetime.datetime.fromtimestamp(data["sys"]["sunset"])
length_of_the_day = datetime.datetime.fromtimestamp(data["sys"]["sunset"]) - datetime.datetime.fromtimestamp(
data["sys"]["sunrise"])
await message.reply(f"***{datetime.datetime.now().strftime('%Y-%m-%d %H:%M')}***\n"
f"Погода в городе: {city}\nТемпература: {cur_weather}C° {wd}\n"
f"Влажность: {humidity}%\nДавление: {pressure} мм.рт.ст\nВетер: {wind} м/с\n"
f"Восход солнца: {sunrise_timestamp}\nЗакат солнца: {sunset_timestamp}\nПродолжительность светового дня: {length_of_the_day}\n"
f"Хорошего дня!"
)
except:
await message.reply('Проверьте название города')
@dp.message_handler()
async def job(message: types.Message):
await message.reply("привет привет")
async def scheduler():
schedule.every().day.at("13:05").do(get_weather)
while True:
await schedule.run_pending()
await asyncio.sleep(0.1)
async def on_startup(_):
asyncio.create_task(scheduler())
if __name__ == "__main__":
executor.start_polling(dp, skip_updates=True, on_startup=on_startup)
Простой
