ЮЧ
спасибо
Size: a a a
2020 January 10
AT
Кто нибудь использует asyncio.Queue вместе с ботом на aiogram?
OA
Кто нибудь использует asyncio.Queue вместе с ботом на aiogram?
AT
Хочу сделать в боте отложенные задачи. Пробовал добавлять в тот же цикл что и крутится с ботом таски produce/consume из примеров asyncio.Queue но не взлетело, хотел спросить: есть ли какие-то нюансы
ЮЧ
Хочу сделать в боте отложенные задачи. Пробовал добавлять в тот же цикл что и крутится с ботом таски produce/consume из примеров asyncio.Queue но не взлетело, хотел спросить: есть ли какие-то нюансы
просто берёшь apshedulder и не паришь себе голову
t
Хочу сделать в боте отложенные задачи. Пробовал добавлять в тот же цикл что и крутится с ботом таски produce/consume из примеров asyncio.Queue но не взлетело, хотел спросить: есть ли какие-то нюансы
покажи как делаешь
t
по сути, у тебя должен быть раннер тасок, который сам будет отдельной таской
С
AsyncIOScheduler
С
просто элементарный до невозможности
Ｆ
Хочу сделать в боте отложенные задачи. Пробовал добавлять в тот же цикл что и крутится с ботом таски produce/consume из примеров asyncio.Queue но не взлетело, хотел спросить: есть ли какие-то нюансы
создаешь таблицу в базе с полями айди, тип задачи, статус и время когда нужно стартануть
ЮЧ
AsyncIOScheduler
это же часть апшедульдера🤔
Ｆ
раз в Н времени смотришь таблицу посортированную по времени и выбираешь нужные таски
AT
по сути, у тебя должен быть раннер тасок, который сам будет отдельной таской
Именно так я и хотел добавить, но в примере исполнитель запускается так
loop.run_until_complete(asyncio.gather(producer_coro, consumer_coro))
А в aiogram цикл внутри запускается и без gather
loop.run_until_complete(asyncio.gather(producer_coro, consumer_coro))
А в aiogram цикл внутри запускается и без gather
С
это же часть апшедульдера🤔
ну да, только как раз для asyncio
t
Именно так я и хотел добавить, но в примере исполнитель запускается так
loop.run_until_complete(asyncio.gather(producer_coro, consumer_coro))
А в aiogram цикл внутри запускается и без gather
loop.run_until_complete(asyncio.gather(producer_coro, consumer_coro))
А в aiogram цикл внутри запускается и без gather
loop.create_task(asyncio.gather(...)), в
on_startupЮЧ
создаешь таблицу в базе с полями айди, тип задачи, статус и время когда нужно стартануть
велосипеееедыыы
Ｆ
AsyncIOScheduler
он умрет от 1000 задач стопроц
AT
loop.create_task(asyncio.gather(...)), в
on_startupспасибо, попробую
ЮЧ
он умрет от 1000 задач стопроц
он их будет хранить там где ты скажешь
Ｆ
велосипеееедыыы
ваш апшедулер это велосипед