mirror of
https://github.com/blakeblackshear/frigate.git
synced 2024-11-21 19:07:46 +01:00
cedd082b30
* Add basic config and face recognition table * Reconfigure updates processing to handle face * Crop frame to face box * Implement face embedding calculation * Get matching face embeddings * Add support face recognition based on existing faces * Use arcface face embeddings instead of generic embeddings model * Add apis for managing faces * Implement face uploading API * Build out more APIs * Add min area config * Handle larger images * Add more debug logs * fix calculation * Reduce timeout * Small tweaks * Use webp images * Use facenet model
67 lines
1.8 KiB
Python
67 lines
1.8 KiB
Python
"""Facilitates communication between processes."""
|
|
|
|
from enum import Enum
|
|
from typing import Callable
|
|
|
|
import zmq
|
|
|
|
SOCKET_REP_REQ = "ipc:///tmp/cache/embeddings"
|
|
|
|
|
|
class EmbeddingsRequestEnum(Enum):
|
|
embed_description = "embed_description"
|
|
embed_thumbnail = "embed_thumbnail"
|
|
generate_search = "generate_search"
|
|
register_face = "register_face"
|
|
|
|
|
|
class EmbeddingsResponder:
|
|
def __init__(self) -> None:
|
|
self.context = zmq.Context()
|
|
self.socket = self.context.socket(zmq.REP)
|
|
self.socket.bind(SOCKET_REP_REQ)
|
|
|
|
def check_for_request(self, process: Callable) -> None:
|
|
while True: # load all messages that are queued
|
|
has_message, _, _ = zmq.select([self.socket], [], [], 0.01)
|
|
|
|
if not has_message:
|
|
break
|
|
|
|
try:
|
|
(topic, value) = self.socket.recv_json(flags=zmq.NOBLOCK)
|
|
|
|
response = process(topic, value)
|
|
|
|
if response is not None:
|
|
self.socket.send_json(response)
|
|
else:
|
|
self.socket.send_json([])
|
|
except zmq.ZMQError:
|
|
break
|
|
|
|
def stop(self) -> None:
|
|
self.socket.close()
|
|
self.context.destroy()
|
|
|
|
|
|
class EmbeddingsRequestor:
|
|
"""Simplifies sending data to EmbeddingsResponder and getting a reply."""
|
|
|
|
def __init__(self) -> None:
|
|
self.context = zmq.Context()
|
|
self.socket = self.context.socket(zmq.REQ)
|
|
self.socket.connect(SOCKET_REP_REQ)
|
|
|
|
def send_data(self, topic: str, data: any) -> str:
|
|
"""Sends data and then waits for reply."""
|
|
try:
|
|
self.socket.send_json((topic, data))
|
|
return self.socket.recv_json()
|
|
except zmq.ZMQError:
|
|
return ""
|
|
|
|
def stop(self) -> None:
|
|
self.socket.close()
|
|
self.context.destroy()
|