def __init__(self, session):
super().__init__()
self.session = session
async def get_owner_ids(self):
repo = Dbcommands(await create_pool(user=user, password=password, host=host, database=database))
user_ids = await repo.get_all_owners_user_ids()
owner_ids = []
for i in user_ids:
owner_ids.append(i[0])
return owner_ids
async def pre_process(self, obj, data, *args):
data["repo"] = Dbcommands(self.session)
owner_ids = await self.get_owner_ids()
print(owner_ids)
async def post_process(self, obj, data, *args):
del data["repo"]
Всем привет! у меня к вам такой вопросик. У меня в любой момент может появиться человек с "ролью" Owner. И у меня такой вопрос что для этого использовать:
1) apscheduler который каждые N минут обновляет список, и передает его через LifetimController
2) или как в данном случае постоянно запускать корутину которая в момент запуска берет user_id из баз данных и передает его через LifetimController
Или есть более хороший вариант для фильтрования юзеров ? Прошу вас подскажите ! Заранее всем спасибо !
Почему в первом методе ты заново создаешь пул, если у тебя уже есть сессия в объекте
И почему get_all_owners_user_id() возвращает что-то помимо списка user_id?
Обсуждают сегодня