python">class VideoCapture:def __init__(self, name):self.cap = cv2.VideoCapture(name)self.q = queue.Queue()t = threading.Thread(target=self._reader)t.daemon = Truet.start()# 帧可用时立即读取帧，只保留最新的帧def _reader(self):while True:ret, frame = self.cap.read()if not ret:breakif not self.q.empty():try:self.q.get_nowait()  # 删除上一个（未处理的）帧except queue.Empty:passself.q.put(frame)def read(self):return self.q.get()

python">@app.route('/ZL00132/front',methods=["GET"])
def index():# vehicle = request.args.get('vehicle')# direction = request.args.get('direction')# 直播流URL# stream_url = 'http://127.0.0.1:8096/z/live/'+vehicle+'/'+direction+'.flv'# 尝试打开直播流# 检查直播流是否成功打开# if not cap.isOpened():#     print("Error: Could not open video stream.")#     exit()# frame_count = 0  # 用于给截图命名的计数器stimestamp = time.time()while True:# 读取一帧frame = cap.read()now = datetime.datetime.now()date_str = now.strftime("%Y-%m-%d-%H:%M:%S")filename = f'/home/zhanyuan/static/{date_str}.jpg'cv2.imwrite(filename, frame)date_str1 = now.strftime("%Y-%m-%d-%H-%M-%S")etimestamp = time.time()print(f"文件 :{filename} 时间：{date_str1} 时间差: {etimestamp - stimestamp}")if etimestamp - stimestamp > 0.01:breakurl = f"http://127.0.0.1:10800/static/{date_str}.jpg"etimestamp1 = time.time()print(f"时间差: {etimestamp1 - stimestamp}")return f"{url}"