async def handle_payment_notification(self):
    print("收到支付通知")
    
    # ..接收參數(shù)，解析參數(shù)等等..
    
    #處理其他邏輯，其中包括20秒延遲
    await self.other_handler()  # 這里包含await asyncio.sleep(20)
    
    # 返回成功響應(yīng)
    self.write({"code": "SUCCESS"})

async def handle_with_transaction():
    db_transaction = DbTransaction()
    try:
        await db_transaction.begin()
        # 業(yè)務(wù)邏輯...
        await db_transaction.commit()  # 如果協(xié)程被取消，這里不會執(zhí)行
    except Exception as e:
        await db_transaction.rollback()  # 如果協(xié)程被取消，這里也不會執(zhí)行

async def handle_payment_notification(self):
    # 解析支付信息...
    
    # 創(chuàng)建后臺任務(wù)處理業(yè)務(wù)邏輯，而不是等待它完成
    asyncio.create_task(self.other_handler())
    
    # 立即返回成功響應(yīng)
    self.write({"code": "SUCCESS"})

async def process_with_cancellation():
    try:
        await asyncio.sleep(20)
        # 其他操作...
    except asyncio.CancelledError:
        # 執(zhí)行必要的清理
        print("操作被取消")
        # 重要：重新引發(fā)異常，告訴Python我們已正確處理取消
        raise

class DbTransaction:
    async def __aenter__(self):
        await self.begin()
        return self
        
    async def __aexit__(self, exc_type, exc_val, exc_tb):
        if exc_type:  # 包括CancelledError
            await self.rollback()
        else:
            await self.commit()

# 使用方式
async def safe_transaction():
    async with DbTransaction() as tran:
        # 業(yè)務(wù)邏輯...
    # 退出上下文后，無論是正常完成還是被取消，連接都會被正確關(guān)閉

async def process_payment_notification(payment_id):
    lock_key = f"payment_processing:{payment_id}"
    
    # 嘗試獲取鎖
    if not await acquire_lock(lock_key, timeout=5):
        return  # 已有進(jìn)程在處理
        
    try:
        # 處理支付邏輯...
    finally:
        # 確保釋放鎖
        await release_lock(lock_key)

async def monitor_connection_pool():
    """定期監(jiān)控數(shù)據(jù)庫連接池狀態(tài)"""
    async def monitor_pool:
        
        stats = get_pool_stats()
        if stats['used'] / stats['total'] > 0.8:  # 超過80%使用率
            logging.warning(f"數(shù)據(jù)庫連接池接近容量上限: {stats}")
            
        if stats['used'] > stats['total'] * 0.9:  # 超過90%使用率
            logging.error("連接池可能泄漏，嘗試重置")
            await reset_connection_pool()

async def api_with_timeout(request_handler):
    """裝飾器：為API添加超時控制"""
    async def wrapper(self, *args, **kwargs):
        try:
            return await asyncio.wait_for(
                request_handler(self, *args, **kwargs),
                timeout=5.0  # 5秒超時
            )
        except asyncio.TimeoutError:
            self.set_status(504)  # Gateway Timeout
            return self.write({"error": "請求處理超時"})
    return wrapper

def setup_global_exception_handler(app):
    """設(shè)置全局異常處理器"""
    async def exception_middleware(request, handler):
        try:
            return await handler(request)
        except Exception as e:
            logging.error(f"未捕獲異常: {e}", exc_info=True)
            # 嘗試重置關(guān)鍵資源
            await emergency_resource_cleanup()
            # 返回錯誤響應(yīng)
            return error_response(500, "服務(wù)器內(nèi)部錯誤")
    
    app.add_middleware(exception_middleware)