如何根据触发器捕获RTSP流并捕获磁盘的RTSP流？

Question

我认为我要问的是类似于有关如何捕获雷击的FFMPEG帖子（ https://trac.ffmpeg.org/wiki/capture/lightning ）。

我在RTSP上有一个带有IP摄像头的Raspberry Pi，我想知道如何保持连续5秒的实时视频缓冲区，直到我触发一个“保存”命令，该命令将把5秒的缓冲区送到磁盘，然后继续将实时视频流式传输到磁盘，直到我将其关闭。

本质上，Pi启动，这个神奇的黑匣子进程开始并将实时视频保存到固定尺寸的5秒缓冲区中，然后是一个小时后 - 我单击一个按钮，然后将5秒的缓冲区冲洗到磁盘上的文件，并继续将视频传输到磁盘上，直到我单击“取消”为止。

在我的环境中，我可以使用FFMPEG，GSTREAMER或OPERRTSP。对于每个这些，我都可以连接到我的RTSP流并将其保存到磁盘上，但是我不确定如何创建这个永远存在的5秒缓存。

我觉得Gstreamer文档在这里暗示它（ https://gstreamer.freedesktop.org/documentation/application-development/advanced/buffering.html?gi-language=c ）触发的保存。从那篇文章中，我的印象是，该视频的末日是事先知道的（我可以人为地限制我的。

我没有一个很好的位置，可以在文件进行后处理，因此使用OpenRTSP之类的东西，保存了一大堆视频段，然后将它们合并并不是真正的选择。

注意：成功保存成功后，我无需保存另一个视频左右，因此5秒的缓存有足够的时间填写，然后在下一个之前，

这是我发现的最接近的类似问题： https://video.stackexchange.com/questions/questions/18514/ffmpeg-buffered-recorder-record-record-record-record-record-record-recorping

Answer 1

嘿，

我不知道您是否对Python有知识，但是有一个名为Pyav的性欲，这是FFMPEG的花哨的Python包装器/界面。

您可以从RTSP源读取您的帧，然后根据需要处理框架。

这只是您所描述的想法/骇客实现，您需要设计框架。当您知道自己从相机中获得25 fps时，您可以将队列大小限制在125。

import av
import time
import queue
from threading import Thread, Event


class LightingRecorder(Thread):

    def __init__(self, source: str = ""):
        Thread.__init__(self)
        self.source = source
        self.av_instance = None
        self.connected = False
        self.frame_buffer = queue.Queue()
        self.record_event = Event()

    def open_rtsp_stream(self):
        try:
            self.av_instance = av.open(self.source, 'r')
            self.connected = True
            print ("Connected")
        except av.error.HTTPUnauthorizedError:
            print ("aHTTPUnauthorizedError")
        except Exception as Error:
            # Catch other pyav errors if you want, just for example
            print (Error)

    def run(self):
        self.open_rtsp_stream()

        while 1:
            if self.connected:
                for packet in self.av_instance.demux():
                    for frame in packet.decode():
                        if packet.stream.type == 'video':
                            # TODO:
                            # Handle clearing of Framebuffer, remove frames that are older as a specific timestamp
                            # Or calculate FPS per seconds and store that many frames on framebuffer
                            print ("Add Frame to framebuffer", frame)
                            self.frame_buffer.put(frame)

                        if self.record_event.is_set():
                            [frame.to_image().save('frame-%04d.jpg' % frame.index) for frame in self.frame_buffer]
            else:
                time.sleep(10)

LightingRecorder(source='rtsp://root:[email protected]/axis-media/media.amp').start()

Answer 2

ispy/agentDvr可以准确地做您想要的 https://wwww.ispyconnect.com/userguide.com/userguide-comorge.com/userguide-recording .aspx ：

缓冲区：这是在内存中进行缓冲区视频的秒数。
此功能使ISPY能够捕获导致的完整事件
运动检测事件。

编辑：
ISPY仅在Windows上运行，与AgentDVR不同，该版本还具有Linux/OSX/RPI的版本。