Dependencies/olgram
1
0
Fork 1
mirror of https://github.com/civsocit/olgram.git synced 2023-07-22 01:29:12 +03:00
Code Issues Packages Projects Releases Wiki Activity

увеличить время хранения идентификаторов для уже состоявшихся диалогов

Browse Source
This commit is contained in:
mihalin 2022-05-26 13:52:47 +03:00
parent e268e5a895
commit b2243587a5
1 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
olgram/migrations/custom.py
View File

@ -1,7 +1,8 @@
"""Наши собственные миграции, которые нельзя описать на языке SQL и с которыми не справится TortoiseORM/Aerich""" """Наши собственные миграции, которые нельзя описать на языке SQL и с которыми не справится TortoiseORM/Aerich"""
import aioredis
from tortoise import transactions, Tortoise from tortoise import transactions, Tortoise
from olgram.settings import TORTOISE_ORM from olgram.settings import TORTOISE_ORM, ServerSettings
from olgram.models.models import MetaInfo, Bot from olgram.models.models import MetaInfo, Bot
import logging import logging
@ -22,8 +23,21 @@ async def upgrade_1():
await meta_info.save() await meta_info.save()
logging.info("done") logging.info("done")
async def upgrade_2():
"""Отменяем малый TTL для старых сообщений"""
con = await aioredis.create_connection(ServerSettings.redis_path())
client = aioredis.Redis(con)
i, keys = await client.scan()
for key in keys:
if not key.startswith(b"thread"):
await client.pexpire(key, ServerSettings.redis_timeout_ms())
# Не забудь добавить миграцию в этот лист! # Не забудь добавить миграцию в этот лист!
_migrations = [upgrade_1] _migrations = [upgrade_1, upgrade_2]
async def migrate(): async def migrate():