Initial commit

2025-12-07 16:15:45 +01:00
commit 1ad5f4a306
6 changed files with 256 additions and 0 deletions
@@ -0,0 +1,19 @@
 [Unit]
 Description=RaspberryPi Camera Web Service
 # Optional: Wartet, bis das Netzwerk bereit ist
 After=network.target
 [Service]
 # Der vollständige Pfad zu deinem Skript
 ExecStart=/home/jens/work/picam/run.sh 
 # Startet den Service bei einem Fehler neu
 Restart=always 
 # Der Benutzer, unter dem der Service läuft (z.B. root, wenn nötig)
 #User=dein_benutzername 
 # Optional: Arbeitsverzeichnis
 #WorkingDirectory=/pfad/zum/projektordner 
 [Install]
 # Sorgt dafür, dass der Service beim Booten startet
 WantedBy=multi-user.target
@@ -0,0 +1,38 @@
 #!/usr/bin/python3
 import socket
 from threading import Event
 from picamera2 import Picamera2
 from picamera2.encoders import JpegEncoder
 from picamera2.outputs import PyavOutput
 picam2 = Picamera2()
 video_config = picam2.create_video_configuration({"size": (1280, 720), 'format': 'YUV420'})
 picam2.configure(video_config)
 encoder = H264Encoder(bitrate=10000000)
 encoder.audio = True
 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
    sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    sock.bind(("0.0.0.0", 8888))
    while True:
        print("Waiting")
        sock.listen()
        conn, addr = sock.accept()
        print("Connected")
        output = PyavOutput(f"pipe:{conn.fileno()}", format="mpeg")
        event = Event()
        output.error_callback = lambda e: event.set()  # noqa
        picam2.start_recording(JpegEncoder(), output)
        event.wait()
        print("Disconnected")
        picam2.stop_recording()
@@ -0,0 +1,101 @@
 #!/usr/bin/python3
 # Mostly copied from https://picamera.readthedocs.io/en/release-1.13/recipes2.html
 # Run this script, then point a web browser at http:<this-ip-address>:8000
 # Note: needs simplejpeg to be installed (pip3 install simplejpeg).
 import io
 import logging
 import socketserver
 from http import server
 from threading import Condition
 from picamera2 import Picamera2
 from picamera2.encoders import H264Encoder
 from picamera2.outputs import PyavOutput
 PAGE = """\
 <html>
 <head>
 <title>picamera2 MJPEG streaming demo</title>
 </head>
 <body>
 <h1>Picamera2 MJPEG Streaming Demo</h1>
 <img src="stream.mjpg" width="640" height="480" />
 </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 output.condition:
                        output.condition.wait()
                        frame = output.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
 picam2 = Picamera2()
 picam2.configure(picam2.create_video_configuration(main={"size": (640, 480)}))
 #output = StreamingOutput()
 encoder = H264Encoder(bitrate=10000000)
 output = PyavOutput("rtsp://127.0.0.1:8554/cam", format="rtsp")
 picam2.start_recording(encoder, output)
 try:
    address = ('', 8554)
    server = StreamingServer(address, StreamingHandler)
    server.serve_forever()
 finally:
    picam2.stop_recording()
@@ -0,0 +1,96 @@
 #!/usr/bin/python3
 # Mostly copied from https://picamera.readthedocs.io/en/release-1.13/recipes2.html
 # Run this script, then point a web browser at http:<this-ip-address>:8000
 # Note: needs simplejpeg to be installed (pip3 install simplejpeg).
 import io
 import logging
 import socketserver
 from http import server
 from threading import Condition
 from picamera2 import Picamera2
 from picamera2.encoders import JpegEncoder
 from picamera2.outputs import FileOutput
 PAGE = """\
 <html>
 <head>
 <title>picamera2 MJPEG streaming demo</title>
 </head>
 <body>
 <h1>Picamera2 MJPEG Streaming Demo</h1>
 <img src="stream.mjpg" width="640" height="480" />
 </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 output.condition:
                        output.condition.wait()
                        frame = output.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
 picam2 = Picamera2()
 picam2.configure(picam2.create_video_configuration(main={"size": (640, 480)}))
 output = StreamingOutput()
 picam2.start_recording(JpegEncoder(), FileOutput(output))
 try:
    address = ('', 8000)
    server = StreamingServer(address, StreamingHandler)
    server.serve_forever()
 finally:
    picam2.stop_recording()
@@ -0,0 +1,2 @@
 #!/bin/env bash
 exec python3 /home/jens/work/picam/rpi_camera_surveillance_system_mjpeg.py
		`@@ -0,0 +1,2 @@`
							`#!/bin/env bash`
							`exec python3 /home/jens/work/picam/rpi_camera_surveillance_system_mjpeg.py`