administrator/frigate
1
0
Fork 0
mirror of https://github.com/blakeblackshear/frigate.git synced 2026-02-05 18:55:23 +03:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Send mqtt message when audio is detected

Browse Source
This commit is contained in:
Nick Mowen 2023-07-14 07:51:40 -06:00
parent 598ae98bfe
commit 09451e7c16
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
frigate/events/audio.py
View File

@ -214,6 +214,10 @@ class AudioEventMaintainer(threading.Thread):
"last_detection" "last_detection"
] = datetime.datetime.now().timestamp() ] = datetime.datetime.now().timestamp()
else: else:
self.inter_process_communicator.queue.put(
(f"{self.config.name}/audio/{label}", True)
)
resp = requests.post( resp = requests.post(
f"{FRIGATE_LOCALHOST}/api/events/{self.config.name}/{label}/create", f"{FRIGATE_LOCALHOST}/api/events/{self.config.name}/{label}/create",
json={"duration": None, "source_type": "audio"}, json={"duration": None, "source_type": "audio"},
@ -238,6 +242,10 @@ class AudioEventMaintainer(threading.Thread):
now - detection.get("last_detection", now) now - detection.get("last_detection", now)
> self.config.audio.max_not_heard > self.config.audio.max_not_heard
): ):
self.inter_process_communicator.queue.put(
(f"{self.config.name}/audio/{detection['label']}", True)
)
resp = requests.put( resp = requests.put(
f"{FRIGATE_LOCALHOST}/api/events/{detection['id']}/end", f"{FRIGATE_LOCALHOST}/api/events/{detection['id']}/end",
json={ json={
@ -245,6 +253,7 @@ class AudioEventMaintainer(threading.Thread):
+ self.config.record.events.post_capture + self.config.record.events.post_capture
}, },
) )
if resp.status_code == 200: if resp.status_code == 200:
self.detections[detection["label"]] = None self.detections[detection["label"]] = None
else: else: