主页 / 问题 / 1595441
Accepted
Ivan
Asked:2024-10-02 03:22:26 +0000 UTC2024-10-02 03:22:26 +0000 UTC

垃圾收集器错误，python

  • 772

垃圾收集器正在尝试清理未签入的连接 <AdaptedConnection <Connection(Thread-3, started daemon 19576)>>

该错误与会话有关，这是代码

使用会话

engine = create_async_engine(os.getenv('DB_LITE'), echo=True)

session_maker = async_sessionmaker(bind=engine, class_=AsyncSession, expire_on_commit=False)

async def create_session():
    async with session_maker() as session:
        return session

函数本身

@post_router.message(F.text)
async def post_delete():
    session= await create_session()
    for post in await orm_get_all_post(session):
        date_today = datetime.now()
        date_meet = post.date
        date_meet = datetime(2024, int(date_meet.split('.')[1]), int(date_meet.split('.')[0]))
        if (date_meet-date_today).days==-2:
            await orm_delete_post(session, post.product_name)

她的挑战

async def main():
    dp.startup.register(on_startup)
    dp.shutdown.register(on_shutdown)

    scheduler=AsyncIOScheduler(timezone='Europe/Moscow')
    scheduler.add_job(post_delete, trigger='interval', seconds=5)
    scheduler.start()

    dp.update.middleware(DataBaseSession(session_pool=session_maker))

    await bot.delete_webhook(drop_pending_updates=True)
    await dp.start_polling(bot, allowed_updates=dp.resolve_used_update_types())

asyncio.run(main())

问题是它是一个后台函数：如果你使用 kwargs，它就会变成一个类。如果有人知道请帮忙！

python

1 个回答

  1. Best Answer

    尝试...

    @post_router.message(F.text)
async def post_delete():
    async with session_maker() as session:
        try:
            for post in await orm_get_all_post(session):
                date_today = datetime.now()
                date_meet = post.date
                date_meet = datetime(2024,
                                     int(date_meet.split('.')[1]),
                                     int(date_meet.split('.')[0])
                                     )
                if (date_meet - date_today).days == -2:
                    await orm_delete_post(session, post.product_name)
        except Exception as e:
            print(f"Ошибка: {e}")
    • 0

相关问题