Получение кадров с потока Ip камеры для дальнейшей обработки

class Camera:
    last_frame = None
    last_ready = None
    last_ready2 = None
    lock = Lock()
    capture=None
 
    def __init__(self, link):
        self.capture = cv2.VideoCapture(link)
        self.signal=1
        thread = threading.Thread(target=self.rtsp_cam_buffer, args=(), name="rtsp_read_thread")
        thread.daemon = True
        thread.start()
 
    def rtsp_cam_buffer(self):
        while True:
            with self.lock:
                self.last_ready = self.capture.grab()
 
    def getFrame(self):
        if (self.last_ready):
            self.last_ready2,self.last_frame=self.capture.retrieve()
            if (self.last_ready2):
                return self.last_frame.copy()
            else:
                return -1
        else:
            return -1
    
    def delete(self):
        self.capture.release()
 
Пример вызова:
 
Capture=Camera('http://162.168.0.14:8001')
CamImage=Capture.getFrame()
 
[size="1"][color="grey"][I]Добавлено через 38 минут[/I][/color][/size]
Привет. Это снова я. Отрыл в сети то, что может помочь. Пока не тестил, но выглядит перспективно. Однако не уверен, будет ли это работать с потоком, а не с видеофайлом.
(Вытащил отсюда [url]https://stackoverflow.com/questions/33311153/python-extracting-and-saving-video-frames[/url])
 
import sys
import argparse
import cv2
print(cv2.__version__)
 
def extractImages(pathIn, pathOut):
    count = 0
    vidcap = cv2.VideoCapture(pathIn)
    success,image = vidcap.read()
    success = True
    while success:
        vidcap.set(cv2.CAP_PROP_POS_MSEC,(count*1000))    # added this line 
        success,image = vidcap.read()
        print ('Read a new frame: ', success)
        cv2.imwrite( pathOut + "\\frame%d.jpg" % count, image)     # save frame as JPEG file
        count = count + 1
 
if __name__=="__main__":
    a = argparse.ArgumentParser()
    a.add_argument("--pathIn", help="path to video")
    a.add_argument("--pathOut", help="path to images")
    args = a.parse_args()
    print(args)
    extractImages(args.pathIn, args.pathOut)

import cv2
 
def getFrame():
    global vidcap
    count = 0
    success = True
    while (success and count<100):
        success = vidcap.grab()
        count += 1
    success,image =vidcap.retrieve()
    cv2.imshow("Now",image)
  
vidcap = cv2.VideoCapture(0)
success,image = vidcap.read()
cv2.imshow("Now",image)
while(True):
    getFrame()
    if cv2.waitKey(10) == 27:                     # exit if Escape is hit
      break

Cap=VideoCapture(0)

flag,image=Cap.read()

flag1=Cap.grab()
flag2,image=Cap.retrieve()

self.cap.set(cv2.CAP_PROP_BUFFERSIZE, 3)  # set buffer size