使用树莓派和摄像头搭建家庭监控系统

import picamera

import cv2

import subprocess

import time

from http.server import SimpleHTTPRequestHandler

from socketserver import TCPServer

# 设置输出的 HLS 目录

hls_output_dir = "/path/to/hls"

# 设置 HTTP 服务器的监听地址和端口

http_server_address = ("", 8080)

# 初始化摄像头

with picamera.PiCamera() as camera:

    # 设置摄像头分辨率

    camera.resolution = (640, 480)

    # 初始化视频流

    video_stream = cv2.VideoWriter_fourcc(*"H264")

    video_output = cv2.VideoWriter("appsrc ! videoconvert ! video/x-raw,format=I420 ! x264enc speed-preset=ultrafast tune=zerolatency bitrate=500 ! h264parse ! matroskamux ! tcpserversink host=0.0.0.0 port=5000", video_stream, 25, (640, 480))

    try:

        # 使用 ffmpeg 将视频流推送到 HLS

        ffmpeg_cmd = f"ffmpeg -f rawvideo -pix_fmt bgr24 -s 640x480 -r 25 -i - -c:v libx264 -preset ultrafast -tune zerolatency -b:v 500k -f hls -hls_time 4 -hls_list_size 10 -hls_wrap 10 {hls_output_dir}/output.m3u8"

        ffmpeg_process = subprocess.Popen(ffmpeg_cmd, shell=True, stdin=subprocess.PIPE)

        # 启动 HTTP 服务器

        with TCPServer(http_server_address, SimpleHTTPRequestHandler) as http_server:

            print(f"HTTP Server running at http://{http_server_address[0]}:{http_server_address[1]}/")

            # 主循环，不断捕获摄像头帧并推送到视频流和 ffmpeg 进程中

            while True:

                # 获取摄像头帧

                frame = camera.capture()

                # 处理帧（如果需要）

                # 将帧写入视频流

                video_output.write(frame)

                # 将帧写入 ffmpeg 进程

                ffmpeg_process.stdin.write(frame.tobytes())

                ffmpeg_process.stdin.flush()

                # 等待一段时间，可根据需要调整

                time.sleep(0.04)

    except KeyboardInterrupt:

        # 用户中断时清理资源

        video_output.release()

        ffmpeg_process.stdin.close()

        ffmpeg_process.wait()

# 关闭摄像头

camera.close()

import picamera

import cv2

import subprocess

import time

import numpy as np

from datetime import datetime

# 设置输出的 HLS 目录

hls_output_dir = "/home/disk/xxx"

# 初始化摄像头

with picamera.PiCamera() as camera:

    # 设置摄像头分辨率

    camera.resolution = (640, 480)

    # 初始化视频流

    video_stream = cv2.VideoWriter_fourcc(*"H264")

    video_output = cv2.VideoWriter("appsrc ! videoconvert ! video/x-raw,format=I420 ! x264enc speed-preset=ultrafast tune=zerolatency bitrate=500 ! h264parse ! matroskamux ! tcpserversink host=0.0.0.0 port=5000", video_stream, 25, (640, 480))

    try:

        # 使用 ffmpeg 将视频流推送到 HLS

        ffmpeg_cmd = f"ffmpeg -f rawvideo -pix_fmt bgr24 -s 640x480 -r 5 -i - -c:v libx264 -preset ultrafast -tune zerolatency -b:v 500k -f hls -hls_time 1 -hls_list_size 10 -hls_wrap 10 -hls_flags delete_segments {hls_output_dir}/output.m3u8"

        ffmpeg_process = subprocess.Popen(ffmpeg_cmd, shell=True, stdin=subprocess.PIPE)

        # 调整帧率和循环时间

        frame_rate = 15

        wait_time = 1 / frame_rate

        # 主循环，不断捕获摄像头帧并推送到视频流和 ffmpeg 进程中

        while True:

            # 获取摄像头帧

            frame = np.empty((camera.resolution[1] * camera.resolution[0] * 3,), dtype=np.uint8)

            camera.capture(frame, 'bgr', use_video_port=True)

            frame = frame.reshape((camera.resolution[1], camera.resolution[0], 3))

            # 处理帧（如果需要）

            # 在左上角添加当前时间

            current_time = datetime.now().strftime('%Y-%m-%d %H:%M:%S')

            cv2.putText(frame, current_time, (10, 30), cv2.FONT_HERSHEY_SIMPLEX, 1, (255, 100, 100), 2, cv2.LINE_AA)

            # 将帧写入视频流

            video_output.write(frame)

            # 将帧写入 ffmpeg 进程

            ffmpeg_process.stdin.write(frame.tobytes())

            ffmpeg_process.stdin.flush()

            # 等待一段时间，可根据需要调整

            time.sleep(wait_time)

    except KeyboardInterrupt:

        # 用户中断时清理资源

        video_output.release()

        ffmpeg_process.stdin.close()

        ffmpeg_process.wait()

# 关闭摄像头

camera.close()