如何使用 Opencv 从网络摄像头获取最新帧?

How to take the latest frame from an ip camera with Opencv?

我需要拍摄连接到我的 raspberry pi 3 b+ 的网络摄像机的快照。我正在使用 python3 和 opencv。相机中有一个定时器,所以我可以检查快照是否在正确的时刻拍摄。

此脚本在我的 Windows PC 上运行良好,但在 raspberry 上运行不佳。脚本每秒拍一张快照,但拍摄的帧不正确,是旧的。

在 raspberry pi 中,我 运行 使用 VLC 和 omxplayer 的视频及其 运行 流畅,所以我认为问题出在 Opencv 和我的代码中。我的印象是帧存储在缓冲区中,树莓派太慢无法实时从缓冲区中获取所有帧,因此随着时间的推移,最后一个真实帧和获取的帧之间会有更多延迟。

import threading
import time
import cv2

cap = cv2.VideoCapture(‘rtsp://192.168.0.88’)
cap.set(cv2.CAP_PROP_BUFFERSIZE, 3)
counter = 0

while True:
   ret, frame = cap.read()
   if ret:
       cv2.imwrite(str(counter) + '.jpg', frame)
       counter = counter + 1
   time.sleep(1)

任何人都知道如何只从相机拍摄最新的一帧? 我想说明一下,分辨率是 1920x1080,视频格式是 h264。此外,在实际应用中,我需要帧之间的时间为 0.1 秒。

这是一个小部件,它每隔 x 秒保存一次最新帧的屏幕截图。这个想法是创建另一个线程来获取帧,因为 cv2.VideoCapture.read() 是一个阻塞操作。通过将此操作放入一个单独的专用线程中,该线程仅专注于抓取帧,我们可以确保我们拥有最新的帧而没有任何缓冲区。这将通过减少 I/O 延迟来提高性能,因为主线程不必等到有新帧出现。我使用自己的 RTSP 流 link 并每 1 秒保存一次屏幕截图。将其更改为您的 RTSP link,无论您想保存多长时间的屏幕截图

from threading import Thread
import cv2
import time

class VideoScreenshot(object):
    def __init__(self, src=0):
        # Create a VideoCapture object
        self.capture = cv2.VideoCapture(src)

        # Take screenshot every x seconds
        self.screenshot_interval = 1

        # Default resolutions of the frame are obtained (system dependent)
        self.frame_width = int(self.capture.get(3))
        self.frame_height = int(self.capture.get(4))

        # Start the thread to read frames from the video stream
        self.thread = Thread(target=self.update, args=())
        self.thread.daemon = True
        self.thread.start()

    def update(self):
        # Read the next frame from the stream in a different thread
        while True:
            if self.capture.isOpened():
                (self.status, self.frame) = self.capture.read()

    def show_frame(self):
        # Display frames in main program
        if self.status:
            cv2.imshow('frame', self.frame)

        # Press Q on keyboard to stop recording
        key = cv2.waitKey(1)
        if key == ord('q'):
            self.capture.release()
            cv2.destroyAllWindows()
            exit(1)

    def save_frame(self):
        # Save obtained frame periodically
        self.frame_count = 0
        def save_frame_thread():
            while True:
                try:
                    cv2.imwrite('frame_{}.png'.format(self.frame_count), self.frame)
                    self.frame_count += 1
                    time.sleep(self.screenshot_interval)
                except AttributeError:
                    pass
        Thread(target=save_frame_thread, args=()).start()

if __name__ == '__main__':
    rtsp_stream_link = 'your stream link!'
    video_stream_widget = VideoScreenshot(rtsp_stream_link)
    video_stream_widget.save_frame()
    while True:
        try:
            video_stream_widget.show_frame()
        except AttributeError:
            pass