mirror of
https://github.com/alexbelgium/hassio-addons.git
synced 2026-01-24 13:36:29 +01:00
736 lines
26 KiB
Markdown
736 lines
26 KiB
Markdown
# Microphone considerations
|
|
The critical element is the microphone quality : a Boya By-lm 40 or clippy EM272 (with a very good aux-usb converter) is key to improve the quality of detections.
|
|
Here is some example tests I did (whole threads are really interesting also): https://github.com/mcguirepr89/BirdNET-Pi/discussions/39#discussioncomment-9706951
|
|
https://github.com/mcguirepr89/BirdNET-Pi/discussions/1092#discussioncomment-9706191
|
|
|
|
My recommendation :
|
|
- Best entry system (< 50€) : Boya By-lm40 (30€) + deadcat (10 €)
|
|
- Best middle end system (< 150 €) : Clippy EM272 (55€) + Rode AI micro trrs to usb (70€) + Rycote deadcat (27€)
|
|
- Best high end system (<400 €) : Clippy EM272 XLR (85€) or LOM Ucho Pro (75€) + Focusrite Scarlet 2i2 4th Gen (200€) + Bubblebee Pro Extreme deadcat (45€)
|
|
|
|
# App settings recommendation
|
|
I've tested lots of settings by running 2 versions of my HA birdnet-pi addon in parallel using the same rtsp feed, and comparing impact of parameters.
|
|
My conclusions aren't universal, as it seems to be highly dependent on the region and type of mic used. For example, the old model seems to be better in Australia, while the new one better in Europe.
|
|
|
|
- Model
|
|
- Version : 6k_v2,4 _(performs better in Europe at least, the 6k performs better in Australia)_
|
|
- Species range model : v1 _(uncheck v2.4 ; seems more robust in Europe)_
|
|
- Species occurence threshold : 0,001 _(was 0,00015 using v2.4 ; use the Species List Tester to check the correct value for you)_
|
|
- Audio settings
|
|
- Default
|
|
- Channel : 1 _(doesn't really matter as analysis is made on mono signal ; 1 allows decreased saved audio size but seems to give slightly messed up spectrograms in my experience)_
|
|
- Recording Length : 18 _(that's because I use an overlap of 0,5 ; so it analysis 0-3s ; 2,5-5,5s ; 5-8s ; 7,5-10,5 ; 10-13 ; 12,5-15,5 ; 15-18)_
|
|
- Extraction Length : 9s _(could be 6, but I like to hear my birds :-))_
|
|
- Audio format : mp3 _(why bother with something else)_
|
|
- Birdnet-lite settings
|
|
- Overlap : 0,5s
|
|
- Minimum confidence : 0,7
|
|
- Sigmoid sensitivity : 1,25 _(I've tried 1,00 but it gave much more false positives ; as decreasing this value increases sensitivity)_
|
|
|
|
# Set RTSP server (https://github.com/mcguirepr89/BirdNET-Pi/discussions/1006#discussioncomment-6747450)
|
|
|
|
<details>
|
|
<summary>On your desktop</summary>
|
|
|
|
- Download imager
|
|
- Install raspbian lite 64
|
|
</details>
|
|
|
|
<details>
|
|
<summary>With ssh, install requisite softwares</summary>
|
|
|
|
###
|
|
```
|
|
# Update
|
|
|
|
sudo apt-get update -y
|
|
sudo apt-get dist-upgrade -y
|
|
|
|
# Disable useless services
|
|
sudo systemctl disable hciuart
|
|
sudo systemctl disable bluetooth
|
|
sudo systemctl disable triggerhappy
|
|
sudo systemctl disable avahi-daemon
|
|
sudo systemctl disable dphys-swapfile
|
|
|
|
# Install RTSP server
|
|
sudo apt-get install -y micro ffmpeg lsof
|
|
sudo -s cd /root && wget -c https://github.com/bluenviron/mediamtx/releases/download/v1.9.1/mediamtx_v1.9.1_linux_arm64v8.tar.gz -O - | sudo tar -xz
|
|
```
|
|
|
|
</details>
|
|
|
|
|
|
<details>
|
|
<summary>Configure Audio</summary>
|
|
|
|
### Find right device
|
|
```
|
|
# List audio devices
|
|
arecord -l
|
|
|
|
# Check audio device parameters. Example :
|
|
arecord -D hw:1,0 --dump-hw-params
|
|
```
|
|
|
|
### Add startup script
|
|
sudo nano startmic.sh && chmod +x startmic.sh
|
|
```
|
|
#!/bin/bash
|
|
echo "Starting birdmic"
|
|
|
|
# Disable gigabit ethernet
|
|
sudo ethtool -s eth0 speed 100 duplex full autoneg on
|
|
|
|
# Run GStreamer RTSP server if installed
|
|
if command -v gst-launch-1.0 &>/dev/null; then
|
|
./rtsp_audio_server.py & sleep 2 >/tmp/log_rtsp 2>/tmp/log_rtsp_error &
|
|
gst_pid=$!
|
|
else
|
|
echo "GStreamer not found, skipping to ffmpeg fallback"
|
|
gst_pid=0
|
|
fi
|
|
|
|
# Wait for a moment to let GStreamer initialize
|
|
sleep 5
|
|
|
|
# Check if the RTSP stream can be accessed (i.e., the feed can be read)
|
|
if ! ffmpeg -rtsp_transport tcp -i rtsp://localhost:8554/birdmic -t 1 -f null - > /dev/null 2>&1; then
|
|
echo "GStreamer RTSP stream is not accessible, switching to ffmpeg"
|
|
|
|
# Kill the GStreamer process if it's still running
|
|
if [ "$gst_pid" -ne 0 ]; then
|
|
kill "$gst_pid"
|
|
fi
|
|
|
|
# Start mediamtx first and give it a moment to initialize
|
|
./mediamtx &
|
|
sleep 5
|
|
|
|
# Run ffmpeg as fallback
|
|
ffmpeg -nostdin -use_wallclock_as_timestamps 1 -fflags +genpts -f alsa -acodec pcm_s16be -ac 2 -ar 96000 \
|
|
-i plughw:0,0 -ac 2 -f rtsp -acodec pcm_s16be rtsp://localhost:8554/birdmic -rtsp_transport tcp \
|
|
-buffer_size 512k 2>/tmp/rtsp_error &
|
|
else
|
|
echo "GStreamer RTSP stream is running successfully"
|
|
fi
|
|
|
|
# Set microphone volume
|
|
sleep 5
|
|
MICROPHONE_NAME="Line In 1 Gain" # for Focusrite Scarlett 2i2
|
|
sudo amixer -c 0 sset "$MICROPHONE_NAME" 40
|
|
|
|
sleep 60
|
|
|
|
# Run focusrite and autogain scripts if present
|
|
if [ -f "$HOME/focusrite.sh" ]; then
|
|
"$HOME/focusrite.sh" >/tmp/log_focusrite 2>/tmp/log_focusrite_error &
|
|
fi
|
|
|
|
if [ -f "$HOME/autogain.py" ]; then
|
|
"$HOME/autogain.py" >/tmp/log_autogain 2>/tmp/log_autogain_error &
|
|
fi
|
|
```
|
|
|
|
</details>
|
|
|
|
<details>
|
|
<summary>Optional : use gstreamer instead of ffmpeg</summary>
|
|
|
|
```
|
|
# Install gstreamer
|
|
sudo apt-get update
|
|
#sudo apt-get install -y \
|
|
# gstreamer1.0-rtsp \
|
|
# gstreamer1.0-tools \
|
|
# gstreamer1.0-alsa \
|
|
# gstreamer1.0-plugins-base \
|
|
# gstreamer1.0-plugins-good \
|
|
# gstreamer1.0-plugins-bad \
|
|
# gstreamer1.0-plugins-ugly \
|
|
# gstreamer1.0-libav
|
|
apt-get install libgstreamer1.0-dev libgstreamer-plugins-base1.0-dev libgstreamer-plugins-bad1.0-dev gstreamer1.0-plugins-base gstreamer1.0-plugins-good gstreamer1.0-plugins-bad gstreamer1.0-plugins-ugly gstreamer1.0-libav gstreamer1.0-tools gstreamer1.0-x gstreamer1.0-alsa gstreamer1.0-gl gstreamer1.0-gtk3 gstreamer1.0-qt5 gstreamer1.0-pulseaudio -y
|
|
```
|
|
|
|
Create a script named rtsp_audio_server.py
|
|
```
|
|
#!/usr/bin/env python3
|
|
|
|
import gi
|
|
import sys
|
|
import logging
|
|
import os
|
|
import signal
|
|
|
|
gi.require_version('Gst', '1.0')
|
|
gi.require_version('GstRtspServer', '1.0')
|
|
|
|
from gi.repository import Gst, GstRtspServer, GLib
|
|
|
|
# Initialize GStreamer
|
|
Gst.init(None)
|
|
|
|
# Configure Logging
|
|
LOG_FILE = "gst_rtsp_server.log"
|
|
logging.basicConfig(
|
|
filename=LOG_FILE,
|
|
filemode='a',
|
|
format='%(asctime)s %(levelname)s: %(message)s',
|
|
level=logging.DEBUG # Set to DEBUG for comprehensive logging
|
|
)
|
|
logger = logging.getLogger(__name__)
|
|
|
|
class AudioFactory(GstRtspServer.RTSPMediaFactory):
|
|
def __init__(self):
|
|
super(AudioFactory, self).__init__()
|
|
self.set_shared(True) # Allow multiple clients to access the stream
|
|
self.set_latency(500) # Increase latency to 500ms to improve stream stability
|
|
self.set_suspend_mode(GstRtspServer.RTSPSuspendMode.NONE) # Prevent suspension of the stream when no clients are connected
|
|
logger.debug("AudioFactory initialized: shared=True, latency=500ms, suspend_mode=NONE.")
|
|
|
|
def do_create_element(self, url):
|
|
"""
|
|
Create and return the GStreamer pipeline for streaming audio.
|
|
"""
|
|
pipeline_str = (
|
|
"alsasrc device=plughw:0,0 do-timestamp=true buffer-time=2000000 latency-time=1000000 ! " # Increased buffer size
|
|
"queue max-size-buffers=0 max-size-bytes=0 max-size-time=0 ! " # Add queue to handle buffer management
|
|
"audioconvert ! " # Convert audio to a suitable format
|
|
"audioresample ! " # Resample audio if necessary
|
|
"audio/x-raw,format=S16BE,channels=2,rate=48000 ! " # Set audio properties (rate = 48kHz)
|
|
"rtpL16pay name=pay0 pt=96" # Payload for RTP
|
|
)
|
|
logger.debug(f"Creating GStreamer pipeline: {pipeline_str}")
|
|
try:
|
|
pipeline = Gst.parse_launch(pipeline_str)
|
|
if not pipeline:
|
|
logger.error("Failed to parse GStreamer pipeline.")
|
|
return None
|
|
return pipeline
|
|
except Exception as e:
|
|
logger.error(f"Exception while creating pipeline: {e}")
|
|
return None
|
|
|
|
class GstServer:
|
|
def __init__(self):
|
|
self.server = GstRtspServer.RTSPServer()
|
|
self.server.set_service("8554") # Set the RTSP server port
|
|
self.server.set_address("0.0.0.0") # Listen on all network interfaces
|
|
logger.debug("RTSP server configured: address=0.0.0.0, port=8554.")
|
|
|
|
factory = AudioFactory()
|
|
mount_points = self.server.get_mount_points()
|
|
mount_points.add_factory("/birdmic", factory) # Mount point
|
|
logger.debug("Factory mounted at /birdmic.")
|
|
|
|
self.server.attach(None) # Attach the server to the default main context
|
|
logger.info("RTSP server attached and running.")
|
|
|
|
def main():
|
|
# Create GstServer instance
|
|
server = GstServer()
|
|
print("RTSP server is running at rtsp://localhost:8554/birdmic")
|
|
logger.info("RTSP server is running at rtsp://localhost:8554/birdmic")
|
|
|
|
# Set up the main loop with proper logging
|
|
loop = GLib.MainLoop()
|
|
|
|
# Handle termination signals to ensure graceful shutdown
|
|
def shutdown(signum, frame):
|
|
logger.info(f"Shutting down RTSP server due to signal {signum}.")
|
|
print("\nShutting down RTSP server.")
|
|
loop.quit()
|
|
|
|
# Register signal handlers for graceful termination
|
|
signal.signal(signal.SIGINT, shutdown)
|
|
signal.signal(signal.SIGTERM, shutdown)
|
|
|
|
try:
|
|
loop.run()
|
|
except Exception as e:
|
|
logger.error(f"Main loop encountered an exception: {e}")
|
|
finally:
|
|
logger.info("RTSP server has been shut down.")
|
|
|
|
if __name__ == "__main__":
|
|
# Ensure log file exists
|
|
if not os.path.exists(LOG_FILE):
|
|
open(LOG_FILE, 'w').close()
|
|
|
|
main()
|
|
```
|
|
|
|
</details>
|
|
|
|
<details>
|
|
<summary>Optional : Startup automatically</summary>
|
|
|
|
```
|
|
chmod +x startmic.sh
|
|
crontab -e # select nano as your editor
|
|
```
|
|
Paste in `@reboot $HOME/startmic.sh` then save and exit nano.
|
|
Reboot the Pi and test again with VLC to make sure the RTSP stream is live.
|
|
|
|
</details>
|
|
|
|
<details>
|
|
<summary>Optional : optimize config.txt</summary>
|
|
|
|
sudo nano /boot/firmware/config.txt
|
|
```
|
|
# Enable audio and USB optimizations
|
|
dtparam=audio=off # Disable the default onboard audio to prevent conflicts
|
|
dtoverlay=disable-bt # Disable onboard Bluetooth to reduce USB bandwidth usage
|
|
dtoverlay=disable-wifi # Disable onboard wifi
|
|
# Limit Ethernet to 100 Mbps (disable Gigabit Ethernet)
|
|
dtparam=eth_max_speed=100
|
|
# USB optimizations
|
|
dwc_otg.fiq_fix_enable=1 # Enable FIQ (Fast Interrupt) handling for improved USB performance
|
|
max_usb_current=1 # Increase the available USB current (required if Scarlett is powered over USB)
|
|
# Additional audio settings (for low-latency operation)
|
|
avoid_pwm_pll=1 # Use a more stable PLL for the audio clock
|
|
# Optional: HDMI and other settings can be turned off if not needed
|
|
hdmi_blanking=1 # Disable HDMI (save power and reduce interference)
|
|
```
|
|
|
|
</details>
|
|
|
|
<details>
|
|
<summary>Optional : install Focusrite driver</summary>
|
|
|
|
```
|
|
sudo apt-get install make linux-headers-$(uname -r)
|
|
curl -LO https://github.com/geoffreybennett/scarlett-gen2/releases/download/v6.9-v1.3/snd-usb-audio-kmod-6.6-v1.3.tar.gz
|
|
tar -xzf snd-usb-audio-kmod-6.6-v1.3.tar.gz
|
|
cd snd-usb-audio-kmod-6.6-v1.3
|
|
KSRCDIR=/lib/modules/$(uname -r)/build
|
|
make -j4 -C $KSRCDIR M=$(pwd) clean
|
|
make -j4 -C $KSRCDIR M=$(pwd)
|
|
sudo make -j4 -C $KSRCDIR M=$(pwd) INSTALL_MOD_DIR=updates/snd-usb-audio modules_install
|
|
sudo depmod
|
|
sudo reboot
|
|
dmesg | grep -A 5 -B 5 -i focusrite
|
|
```
|
|
|
|
</details>
|
|
|
|
<details>
|
|
<summary>Optional : add RAM disk</summary>
|
|
|
|
```
|
|
sudo cp /usr/share/systemd/tmp.mount /etc/systemd/system/tmp.mount
|
|
sudo systemctl enable tmp.mount
|
|
sudo systemctl start tmp.mount
|
|
```
|
|
|
|
</details>
|
|
|
|
<details>
|
|
<summary>Optional : Configuration for Focusrite Scarlett 2i2</summary>
|
|
|
|
Add this content in "$HOME/focusrite.sh" && chmod +x "$HOME/focusrite.sh"
|
|
```
|
|
#!/bin/bash
|
|
|
|
# Set PCM controls for capture
|
|
sudo amixer -c 0 cset numid=31 'Analogue 1' # 'PCM 01' - Set to 'Analogue 1'
|
|
sudo amixer -c 0 cset numid=32 'Analogue 1' # 'PCM 02' - Set to 'Analogue 1'
|
|
sudo amixer -c 0 cset numid=33 'Off' # 'PCM 03' - Disabled
|
|
sudo amixer -c 0 cset numid=34 'Off' # 'PCM 04' - Disabled
|
|
|
|
# Set DSP Input controls (Unused, set to Off)
|
|
sudo amixer -c 0 cset numid=29 'Off' # 'DSP Input 1'
|
|
sudo amixer -c 0 cset numid=30 'Off' # 'DSP Input 2'
|
|
|
|
# Configure Line In 1 as main input for mono setup
|
|
sudo amixer -c 0 cset numid=8 'Off' # 'Line In 1 Air' - Keep 'Off'
|
|
sudo amixer -c 0 cset numid=14 off # 'Line In 1 Autogain' - Disabled
|
|
sudo amixer -c 0 cset numid=6 'Line' # 'Line In 1 Level' - Set level to 'Line'
|
|
sudo amixer -c 0 cset numid=21 on # 'Line In 1 Safe' - Enabled to avoid clipping / noise impact ?
|
|
|
|
# Disable Line In 2 to minimize interference (if not used)
|
|
sudo amixer -c 0 cset numid=9 'Off' # 'Line In 2 Air'
|
|
sudo amixer -c 0 cset numid=17 off # 'Line In 2 Autogain' - Disabled
|
|
sudo amixer -c 0 cset numid=16 0 # 'Line In 2 Gain' - Set gain to 0 (mute)
|
|
sudo amixer -c 0 cset numid=7 'Line' # 'Line In 2 Level' - Set to 'Line'
|
|
sudo amixer -c 0 cset numid=22 off # 'Line In 2 Safe' - Disabled
|
|
|
|
# Set Line In 1-2 controls
|
|
sudo amixer -c 0 cset numid=12 off # 'Line In 1-2 Link' - No need to link for mono
|
|
sudo amixer -c 0 cset numid=10 on # 'Line In 1-2 Phantom Power' - Enabled for condenser mics
|
|
|
|
# Set Analogue Outputs to use the same mix for both channels (Mono setup)
|
|
sudo amixer -c 0 cset numid=23 'Mix A' # 'Analogue Output 01' - Set to 'Mix A'
|
|
sudo amixer -c 0 cset numid=24 'Mix A' # 'Analogue Output 02' - Same mix as Output 01
|
|
|
|
# Set Direct Monitor to off to prevent feedback
|
|
sudo amixer -c 0 cset numid=53 'Off' # 'Direct Monitor'
|
|
|
|
# Set Input Select to Input 1
|
|
sudo amixer -c 0 cset numid=11 'Input 1' # 'Input Select'
|
|
|
|
# Optimize Monitor Mix settings for mono output
|
|
sudo amixer -c 0 cset numid=54 153 # 'Monitor 1 Mix A Input 01' - Set to 153 (around -3.50 dB)
|
|
sudo amixer -c 0 cset numid=55 153 # 'Monitor 1 Mix A Input 02' - Set to 153 for balanced output
|
|
sudo amixer -c 0 cset numid=56 0 # 'Monitor 1 Mix A Input 03' - Mute unused channels
|
|
sudo amixer -c 0 cset numid=57 0 # 'Monitor 1 Mix A Input 04'
|
|
|
|
# Set Sync Status to Locked
|
|
sudo amixer -c 0 cset numid=52 'Locked' # 'Sync Status'
|
|
|
|
echo "Mono optimization applied. Only using primary input and balanced outputs."
|
|
```
|
|
</details>
|
|
|
|
<details>
|
|
<summary>Optional : Autogain script for microphone</summary>
|
|
|
|
Add this content in "$HOME/autogain.py" && chmod +x "$HOME/autogain.py"
|
|
|
|
```python
|
|
#!/usr/bin/env python3
|
|
"""
|
|
Microphone Gain Adjustment Script
|
|
|
|
This script captures audio from an RTSP stream using GStreamer if available,
|
|
or falls back to ffmpeg if GStreamer is not installed. The script processes
|
|
the audio to calculate the RMS within the 2000-4000 Hz frequency band and
|
|
adjusts the microphone gain based on predefined noise thresholds and trends.
|
|
|
|
Dependencies:
|
|
- numpy
|
|
- scipy
|
|
- ffmpeg or GStreamer (installed and accessible in PATH)
|
|
- amixer (for microphone gain control)
|
|
|
|
Author: OpenAI ChatGPT
|
|
Date: 2024-04-27
|
|
|
|
Changelog:
|
|
- 2024-04-27: Initial version of the script that captures RTSP stream, calculates RMS, and adjusts gain.
|
|
- 2024-10-17: Added support for GStreamer as the preferred RTSP stream capture tool, with ffmpeg as a fallback.
|
|
Implemented a debug log system to provide detailed logs with timestamps.
|
|
Added trend-based microphone gain adjustment and noise RMS calculation.
|
|
Enhanced error handling for both GStreamer and ffmpeg.
|
|
"""
|
|
|
|
import subprocess
|
|
import numpy as np
|
|
from scipy.signal import butter, sosfilt
|
|
import time
|
|
import re
|
|
|
|
# ---------------------------- Configuration ----------------------------
|
|
|
|
# Microphone Settings
|
|
MICROPHONE_NAME = "Line In 1 Gain" # Adjust to match your microphone's control name
|
|
MIN_GAIN_DB = 20 # Minimum gain in dB
|
|
MAX_GAIN_DB = 45 # Maximum gain in dB
|
|
DECREASE_GAIN_STEP_DB = 1 # Gain decrease step in dB
|
|
INCREASE_GAIN_STEP_DB = 5 # Gain increase step in dB
|
|
|
|
# Noise Thresholds
|
|
NOISE_THRESHOLD_HIGH = 0.001 # Upper threshold for noise RMS amplitude
|
|
NOISE_THRESHOLD_LOW = 0.00035 # Lower threshold for noise RMS amplitude
|
|
|
|
# Trend Detection
|
|
TREND_COUNT_THRESHOLD = 1 # Number of consecutive trends needed to adjust gain
|
|
|
|
# RTSP Stream URL
|
|
RTSP_URL = "rtsp://192.168.178.124:8554/birdmic" # Replace with your RTSP stream URL
|
|
|
|
# Debug Mode (1 for enabled, 0 for disabled)
|
|
DEBUG = 1
|
|
|
|
# -----------------------------------------------------------------------
|
|
|
|
def debug(msg):
|
|
"""
|
|
Prints debug messages if DEBUG mode is enabled.
|
|
|
|
:param msg: The debug message to print.
|
|
"""
|
|
if DEBUG:
|
|
current_time = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
|
|
print(f"[{current_time}] [DEBUG] {msg}")
|
|
|
|
|
|
def get_gain_db(mic_name):
|
|
"""
|
|
Retrieves the current gain setting of the specified microphone using amixer.
|
|
|
|
:param mic_name: The name of the microphone control in amixer.
|
|
:return: The current gain in dB as a float, or None if retrieval fails.
|
|
"""
|
|
cmd = ['amixer', 'sget', mic_name]
|
|
try:
|
|
output = subprocess.check_output(cmd, stderr=subprocess.STDOUT).decode()
|
|
match = re.search(r'\[(-?\d+(\.\d+)?)dB\]', output)
|
|
if match:
|
|
gain_db = float(match.group(1))
|
|
debug(f"Retrieved gain: {gain_db} dB")
|
|
return gain_db
|
|
else:
|
|
debug("No gain information found in amixer output.")
|
|
return None
|
|
except subprocess.CalledProcessError as e:
|
|
debug(f"amixer sget failed: {e}")
|
|
return None
|
|
|
|
|
|
def set_gain_db(mic_name, gain_db):
|
|
"""
|
|
Sets the gain of the specified microphone using amixer.
|
|
|
|
:param mic_name: The name of the microphone control in amixer.
|
|
:param gain_db: The desired gain in dB.
|
|
:return: True if the gain was set successfully, False otherwise.
|
|
"""
|
|
cmd = ['amixer', 'sset', mic_name, f'{gain_db}dB']
|
|
try:
|
|
subprocess.check_call(cmd, stderr=subprocess.STDOUT)
|
|
debug(f"Set gain to: {gain_db} dB")
|
|
return True
|
|
except subprocess.CalledProcessError as e:
|
|
debug(f"amixer sset failed: {e}")
|
|
return False
|
|
|
|
|
|
def check_gstreamer_available():
|
|
"""
|
|
Checks if GStreamer is available on the system.
|
|
"""
|
|
try:
|
|
subprocess.check_call(['which', 'gst-launch-1.0'], stdout=subprocess.PIPE, stderr=subprocess.PIPE)
|
|
debug("GStreamer is available.")
|
|
return True
|
|
except subprocess.CalledProcessError:
|
|
debug("GStreamer is not available.")
|
|
return False
|
|
|
|
|
|
def calculate_noise_rms_gstream(rtsp_url, bandpass_sos, num_bins=5):
|
|
"""
|
|
Captures audio using GStreamer from an RTSP stream, applies a bandpass filter,
|
|
divides the audio into segments, and calculates the RMS of the quietest segment.
|
|
|
|
:param rtsp_url: The RTSP stream URL.
|
|
:param bandpass_sos: Precomputed bandpass filter coefficients (Second-Order Sections).
|
|
:param num_bins: Number of segments to divide the audio into.
|
|
:return: The RMS amplitude of the quietest segment as a float, or None on failure.
|
|
"""
|
|
cmd = [
|
|
'gst-launch-1.0',
|
|
'rtspsrc', f'location={rtsp_url}', '!',
|
|
'decodebin', '!', 'audioconvert', '!',
|
|
'audioresample', '!', 'audio/x-raw,rate=32000,channels=1',
|
|
'!', 'filesink', 'location=/dev/stdout'
|
|
]
|
|
|
|
try:
|
|
debug(f"Starting GStreamer audio capture from {rtsp_url}")
|
|
process = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
|
|
stdout, stderr = process.communicate()
|
|
|
|
if process.returncode != 0:
|
|
debug(f"GStreamer failed with error: {stderr.decode()}")
|
|
return None
|
|
|
|
audio = np.frombuffer(stdout, dtype=np.int16).astype(np.float32) / 32768.0
|
|
debug(f"Captured {len(audio)} samples from GStreamer.")
|
|
|
|
if len(audio) == 0:
|
|
debug("No audio data captured.")
|
|
return None
|
|
|
|
filtered = sosfilt(bandpass_sos, audio)
|
|
debug("Applied bandpass filter to audio data.")
|
|
total_samples = len(filtered)
|
|
bin_size = total_samples // num_bins
|
|
|
|
if bin_size == 0:
|
|
debug("Bin size is 0; insufficient audio data.")
|
|
return 0.0
|
|
|
|
trimmed_filtered = filtered[:bin_size * num_bins]
|
|
segments = trimmed_filtered.reshape(num_bins, bin_size)
|
|
debug(f"Divided audio into {num_bins} bins of {bin_size} samples each.")
|
|
rms_values = np.sqrt(np.mean(segments ** 2, axis=1))
|
|
min_rms = rms_values.min()
|
|
debug(f"Minimum RMS value among segments: {min_rms}")
|
|
return min_rms
|
|
|
|
except Exception as e:
|
|
debug(f"Exception during noise RMS calculation with GStreamer: {e}")
|
|
return None
|
|
|
|
|
|
def calculate_noise_rms_ffmpeg(rtsp_url, bandpass_sos, num_bins=5):
|
|
"""
|
|
Captures audio using FFmpeg from an RTSP stream, applies a bandpass filter,
|
|
divides the audio into segments, and calculates the RMS of the quietest segment.
|
|
|
|
:param rtsp_url: The RTSP stream URL.
|
|
:param bandpass_sos: Precomputed bandpass filter coefficients (Second-Order Sections).
|
|
:param num_bins: Number of segments to divide the audio into.
|
|
:return: The RMS amplitude of the quietest segment as a float, or None on failure.
|
|
"""
|
|
cmd = [
|
|
'ffmpeg',
|
|
'-loglevel', 'error',
|
|
'-rtsp_transport', 'tcp',
|
|
'-i', rtsp_url,
|
|
'-vn',
|
|
'-f', 's16le',
|
|
'-acodec', 'pcm_s16le',
|
|
'-ar', '32000',
|
|
'-ac', '1',
|
|
'-t', '5',
|
|
'-'
|
|
]
|
|
|
|
try:
|
|
debug(f"Starting FFmpeg audio capture from {rtsp_url}")
|
|
process = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
|
|
stdout, stderr = process.communicate()
|
|
|
|
if process.returncode != 0:
|
|
debug(f"FFmpeg failed with error: {stderr.decode()}")
|
|
return None
|
|
|
|
audio = np.frombuffer(stdout, dtype=np.int16).astype(np.float32) / 32768.0
|
|
debug(f"Captured {len(audio)} samples from FFmpeg.")
|
|
|
|
if len(audio) == 0:
|
|
debug("No audio data captured.")
|
|
return None
|
|
|
|
filtered = sosfilt(bandpass_sos, audio)
|
|
debug("Applied bandpass filter to audio data.")
|
|
total_samples = len(filtered)
|
|
bin_size = total_samples // num_bins
|
|
|
|
if bin_size == 0:
|
|
debug("Bin size is 0; insufficient audio data.")
|
|
return 0.0
|
|
|
|
trimmed_filtered = filtered[:bin_size * num_bins]
|
|
segments = trimmed_filtered.reshape(num_bins, bin_size)
|
|
debug(f"Divided audio into {num_bins} bins of {bin_size} samples each.")
|
|
rms_values = np.sqrt(np.mean(segments ** 2, axis=1))
|
|
min_rms = rms_values.min()
|
|
debug(f"Minimum RMS value among segments: {min_rms}")
|
|
return min_rms
|
|
|
|
except Exception as e:
|
|
debug(f"Exception during noise RMS calculation with FFmpeg: {e}")
|
|
return None
|
|
|
|
|
|
def calculate_noise_rms(rtsp_url, bandpass_sos, num_bins=5):
|
|
"""
|
|
Attempts to capture audio from an RTSP stream using GStreamer first,
|
|
and falls back to FFmpeg if GStreamer is unavailable.
|
|
"""
|
|
if check_gstreamer_available():
|
|
return calculate_noise_rms_gstream(rtsp_url, bandpass_sos, num_bins)
|
|
else:
|
|
return calculate_noise_rms_ffmpeg(rtsp_url, bandpass_sos, num_bins)
|
|
|
|
|
|
def main():
|
|
"""
|
|
Main loop that continuously monitors background noise and adjusts microphone gain.
|
|
"""
|
|
TREND_COUNT = 0
|
|
PREVIOUS_TREND = 0
|
|
|
|
LOWCUT = 2000
|
|
HIGHCUT = 4000
|
|
FILTER_ORDER = 5
|
|
|
|
sos = butter(FILTER_ORDER, [LOWCUT, HIGHCUT], btype='band', fs=44100, output='sos')
|
|
debug("Precomputed Butterworth bandpass filter coefficients.")
|
|
|
|
success = set_gain_db(MICROPHONE_NAME, MAX_GAIN_DB)
|
|
if success:
|
|
print(f"Microphone gain set to {MAX_GAIN_DB} dB at start.")
|
|
else:
|
|
print("Failed to set microphone gain at start. Exiting.")
|
|
return
|
|
|
|
while True:
|
|
min_rms = calculate_noise_rms(RTSP_URL, sos, num_bins=5)
|
|
|
|
if min_rms is None:
|
|
print("Failed to compute noise RMS. Retrying in 1 minute...")
|
|
time.sleep(60)
|
|
continue
|
|
|
|
print(f"Converted RMS Amplitude: {min_rms}")
|
|
debug(f"Current background noise (RMS amplitude): {min_rms}")
|
|
|
|
if min_rms > NOISE_THRESHOLD_HIGH:
|
|
CURRENT_TREND = 1
|
|
elif min_rms < NOISE_THRESHOLD_LOW:
|
|
CURRENT_TREND = -1
|
|
else:
|
|
CURRENT_TREND = 0
|
|
|
|
debug(f"Current trend: {CURRENT_TREND}")
|
|
|
|
if CURRENT_TREND != 0:
|
|
if CURRENT_TREND == PREVIOUS_TREND:
|
|
TREND_COUNT += 1
|
|
else:
|
|
TREND_COUNT = 1
|
|
PREVIOUS_TREND = CURRENT_TREND
|
|
else:
|
|
TREND_COUNT = 0
|
|
|
|
debug(f"Trend count: {TREND_COUNT}")
|
|
|
|
CURRENT_GAIN_DB = get_gain_db(MICROPHONE_NAME)
|
|
|
|
if CURRENT_GAIN_DB is None:
|
|
print("Failed to get current gain level. Retrying in 1 minute...")
|
|
time.sleep(60)
|
|
continue
|
|
|
|
debug(f"Current gain: {CURRENT_GAIN_DB} dB")
|
|
|
|
if TREND_COUNT >= TREND_COUNT_THRESHOLD:
|
|
if CURRENT_TREND == 1:
|
|
NEW_GAIN_DB = CURRENT_GAIN_DB - DECREASE_GAIN_STEP_DB
|
|
if NEW_GAIN_DB < MIN_GAIN_DB:
|
|
NEW_GAIN_DB = MIN_GAIN_DB
|
|
success = set_gain_db(MICROPHONE_NAME, NEW_GAIN_DB)
|
|
if success:
|
|
print(f"Decreased gain to {NEW_GAIN_DB} dB")
|
|
debug(f"Gain adjusted to {NEW_GAIN_DB} dB")
|
|
else:
|
|
print("Failed to set new gain.")
|
|
elif CURRENT_TREND == -1:
|
|
NEW_GAIN_DB = CURRENT_GAIN_DB + INCREASE_GAIN_STEP_DB
|
|
if NEW_GAIN_DB > MAX_GAIN_DB:
|
|
NEW_GAIN_DB = MAX_GAIN_DB
|
|
success = set_gain_db(MICROPHONE_NAME, NEW_GAIN_DB)
|
|
if success:
|
|
print(f"Increased gain to {NEW_GAIN_DB} dB")
|
|
debug(f"Gain adjusted to {NEW_GAIN_DB} dB")
|
|
else:
|
|
print("Failed to set new gain.")
|
|
TREND_COUNT = 0
|
|
else:
|
|
debug("No gain adjustment needed.")
|
|
|
|
time.sleep(60)
|
|
|
|
|
|
if __name__ == "__main__":
|
|
main()
|
|
```
|
|
|
|
</details>
|