After much trial and error, I have a working picamera2 with libcamera and rpi camera wide angle v3. Streams MJPG to a web page (port 8000) and records mp4 files to sdcard. Checks for file rotation based on n days.
store mp4 files in a date directoy under /home/pi/html-php-scripts/mp4/ (Apache2 website so I can browse recorded mp4 files. mapped to ./html-php-scripts/ root folder)
Adds date timestamp to MJPG stream and also adds timestamp to recorded mp4.
Basic info about rpi:
Linux rpi-xxxxxxxxxx 6.1.21-v8+ #1642 SMP PREEMPT Mon Apr 3 17:24:16 BST 2023 aarch64 GNU/Linux
Bullseye
rpi camera v3 wide angle
See below code:
================================================================
#!/usr/bin/python3
#afullagar@gmail.com blog.fullys.xyz
import logging
import time
import datetime
import io
import cv2
import socketserver
from http import server
from threading import Condition, Thread
from picamera2 import MappedArray,Picamera2
from picamera2.encoders import MJPEGEncoder
from picamera2.encoders import H264Encoder
from picamera2.outputs import FfmpegOutput
from picamera2.outputs import FileOutput
import shutil
import pathlib
import os
OUTPUTPATH = "/home/pi/html-php-scripts/mp4/"
CLIPLENGTH = 30
colour = (0, 255, 0)
origin = (0, 30)
font = cv2.FONT_HERSHEY_SIMPLEX
scale = 1
thickness = 2
frameCount = 0
def apply_timestamp(request):
global frameCount
frameCount = frameCount+1
timestamp = str(time.strftime("%Y-%m-%d %X")) + " frame count = " + str(frameCount)
with MappedArray(request, "main") as m:
cv2.putText(m.array, timestamp, origin, font, scale, colour, thickness)
PAGE = """\
<html>
<head>
<title>picamera2 MJPEG streaming demo</title>
</head>
<body>
<h1>Picamera2 MJPEG Streaming Demo</h1>
<img src="stream.mjpg"/>
</body>
</html>
"""
class StreamingOutput(io.BufferedIOBase):
def __init__(self):
self.frame = None
self.condition = Condition()
def write(self, buf):
with self.condition:
self.frame = buf
self.condition.notify_all()
class StreamingHandler(server.BaseHTTPRequestHandler):
def do_GET(self):
if self.path == '/':
self.send_response(301)
self.send_header('Location', '/index.html')
self.end_headers()
elif self.path == '/index.html':
content = PAGE.encode('utf-8')
self.send_response(200)
self.send_header('Content-Type', 'text/html')
self.send_header('Content-Length', len(content))
self.end_headers()
self.wfile.write(content)
elif self.path == '/stream.mjpg':
self.send_response(200)
self.send_header('Age', 0)
self.send_header('Cache-Control', 'no-cache, private')
self.send_header('Pragma', 'no-cache')
self.send_header('Content-Type', 'multipart/x-mixed-replace; boundary=FRAME')
self.end_headers()
try:
while True:
with output1.condition:
output1.condition.wait()
frame = output1.frame
self.wfile.write(b'--FRAME\r\n')
self.send_header('Content-Type', 'image/jpeg')
self.send_header('Content-Length', len(frame))
self.end_headers()
self.wfile.write(frame)
self.wfile.write(b'\r\n')
except Exception as e:
logging.warning(
'Removed streaming client %s: %s',
self.client_address, str(e))
else:
self.send_error(404)
self.end_headers()
class StreamingServer(socketserver.ThreadingMixIn, server.HTTPServer):
allow_reuse_address = True
daemon_threads = True
def h264_encode():
while not encode_abort:
now = datetime.datetime.now()
#DEBUG - Motion Object path
try:
#Create Directory if it does not exist - sort in days
objectPath = OUTPUTPATH+now.strftime("%Y-%m-%d")+'/'
if not os.path.exists(objectPath):
os.makedirs(objectPath, mode=0o755, exist_ok=True)
except Exception as e:
print("Exception occurred creating the current date ::: ", e)
pass
picam2.pre_callback = apply_timestamp
encoder2 = H264Encoder()
fileNameMp4 = "stream-" + now.strftime("%Y-%m-%d--%H-%M-%S-%f")+".mp4"
output2 = FfmpegOutput('/home/pi/html-php-scripts/mp4/'+now.strftime("%Y-%m-%d")+'/'+fileNameMp4)
picam2.start_recording(encoder2, output2)
time.sleep(CLIPLENGTH)
picam2.stop_encoder(encoder2)
#############
#Check and delete old mp4 files are n+ days
#date and time now
now = datetime.datetime.now()
try:
#delete old files older than
n = 5
#Debug
#delete files older than x days
date_N_days_ago = datetime.datetime.now() - datetime.timedelta(days=n)
#remove directoy n days ago
shutil.rmtree('/home/pi/html-php-scripts/mp4/'+date_N_days_ago.strftime("%Y-%m-%d"))
except Exception as e:
print("Exception deleting old date files ::: ",e)
pass
#############
try:
#picam2.start()
picam2 = Picamera2()
picam2.configure(picam2.create_video_configuration(main={"size": (1980, 1020)}))
output1 = StreamingOutput()
encoder1 = MJPEGEncoder()
picam2.start_recording(encoder1, FileOutput(output1))
encode_abort = False
encode_thread = Thread(target=h264_encode, daemon=False)
encode_thread.start()
#encode_thread.join()
address = ('', 8000)
server = StreamingServer(address, StreamingHandler)
server.serve_forever()
except Exception as e:
print("Exception occurred ::: ",e)
pass
finally:
picam2.stop()