M
Переслано от MrSmitix
Мб кто подскажет как сделать так, что бы в воркере тоже была возможность юзать бд. Для него подключение к бд не доступно, или типо того. Он его не видит. aiogram + tortoise
Size: a a a
2020 December 30
M
M
В итоге сделал сейчас 2 отдельных скрипта. В обоих подключаюсь и к бд, и к тг. Работает, но выглядит как-то не очень
OA
M
Перед тем как попробую сделать вопрос, тогда он может взаимодействовать с бд?
Р
Ребят есть готовый пример хостинга бота aiogram на дебиане nginx gunicorn ?
ZR
Перед тем как попробую сделать вопрос, тогда он может взаимодействовать с бд?
Взаимодействовать - да, может
ZR
Ребят есть готовый пример хостинга бота aiogram на дебиане nginx gunicorn ?
Таких примеров нету, то что вы говорите это же элементарно
B
напомните плз, как стопать дальнейшее продвижение из миддлварьки
в плане, останавливать обработку апдейта дальше
в плане, останавливать обработку апдейта дальше
ZR
Добрый день. Первый раз столкнулся с aiogram и почти сразу наткнулся на проблему.
Стек: aiogram + tortoise
Задача: Нужно реализовать телеграмм бота, через которого пользователи смогут добавлять задачи, а воркер их с некоторой периодичностью будет выполнять. В случает неудачи будет сообщать о проблеме пользователю. Но только не догоняю как воркера и бота соединить в пределах 1 проекта. Создавал функцию воркера и добавлял её в on_startup executor-а. Перед этим была инициализация бд. Но вот только воркер с бд никак работать не мог. Скорее всего проблема в неправильной архитектуре, но лучше я не придумал. Мб кто-то что-то такое реализовывал и знает как сделать правильно?
Стек: aiogram + tortoise
Задача: Нужно реализовать телеграмм бота, через которого пользователи смогут добавлять задачи, а воркер их с некоторой периодичностью будет выполнять. В случает неудачи будет сообщать о проблеме пользователю. Но только не догоняю как воркера и бота соединить в пределах 1 проекта. Создавал функцию воркера и добавлял её в on_startup executor-а. Перед этим была инициализация бд. Но вот только воркер с бд никак работать не мог. Скорее всего проблема в неправильной архитектуре, но лучше я не придумал. Мб кто-то что-то такое реализовывал и знает как сделать правильно?
async def scheduled(wait_for):
while True:
await asyncio.sleep(wait_for)
# тут делаем проверку которую вам нужно
if name == 'main':
dp.loop.create_task(scheduled(10))
executor.start_polling(dp, skip_updates=True)DK
напомните плз, как стопать дальнейшее продвижение из миддлварьки
в плане, останавливать обработку апдейта дальше
в плане, останавливать обработку апдейта дальше
raise CancelHandler()
B
raise CancelHandler()
а разве не Skip?
B
но сяпки
DK
а разве не Skip?
Skip просто пускает обработку дальше из одного хендлера в другой, но из миддлвари не помню, как он себя ведёт
B
ага, наес, работает
B
сяп
ЕС
В итоге сделал сейчас 2 отдельных скрипта. В обоих подключаюсь и к бд, и к тг. Работает, но выглядит как-то не очень
Sleep обычный разве не потокоблокирующая функция? Используй из набора asyncio
M
Sleep обычный разве не потокоблокирующая функция? Используй из набора asyncio
Он и используется
й
у тебя on_startup функция ждёт выполнения
а воркер бесконечный
аигорам вообще так работать не должен
если запускаешь что-то бесконечное - делай отдельный таск через asyncio.create_task
а воркер бесконечный
аигорам вообще так работать не должен
если запускаешь что-то бесконечное - делай отдельный таск через asyncio.create_task
типа worker() просто обернуть aiogram.create_task?
👑️
Да. Корутину ему передай