class Tracking_Car:
    def __init__(self, profile_path, logger_) -> None:
        # ...其他初始化代碼...
        
        # Redis連接
        self.redis_db = redis.StrictRedis(
            host=conf.redis_server.ip,
            port=conf.redis_server.port,
            db=conf.redis_server.db,
            socket_keepalive=True,
            socket_connect_timeout=10
        )
        
        # 超時存儲的Redis key前綴
        self.TIMEOUT_KEY_PREFIX = "tracking_car:timeout:"

    def re_stream(self, logger_):
        pub = self.redis_db.pubsub()
        pub.subscribe(self.topic)
        msgs = pub.listen()
        
        for msg in msgs:
            if msg["type"] == "message":
                json_data = json.loads(msg["data"])
                ip = json_data["ip"]
                
                # 檢查是否在暫停列表 - 使用Redis自動過期
                timeout_key = f"{self.TIMEOUT_KEY_PREFIX}{camera_ip}"
                if self.redis_db.exists(timeout_key):
                    # 獲取剩余時間并記錄日志
                    ttl = self.redis_db.ttl(timeout_key)
                    skip_msg = f"跳過{ip }的消息：處于暫停時段({ttl}s剩余)"
                    continue
                
                # ...正常處理邏輯...

    def write_database(self, cv_list, logger_: MyLogger):
        # 計算時間差
        current_time = time.time()
        _ts = cv_list['timestamp']
        diff_time = current_time - _ts
        
        # 如果時間差超過300秒，使用Redis自動過期設(shè)置
        if diff_time > 300:
            camera_ip = cv_list["ip"]
            logger_.warning(f"IP {camera_ip} 延時超過300秒({diff_time:.2f}s)，加入暫停列表")
            
            # 設(shè)置Redis鍵，自動在300秒后過期
            timeout_key = f"{self.TIMEOUT_KEY_PREFIX}{camera_ip}"
            self.redis_db.setex(timeout_key, 300, "1")  # 值可以是任意內(nèi)容
            
            # 刪除相關(guān)圖片并跳過處理
            self.redis_db.unlink(cv_list["path"])
            return
        
        # ...正常處理邏輯...