Есть вебсокет канал, в него прилетают чанки аудиозаписи. Нужно их склеивать, преобразовывать в файл, делать различные операции и т.п. Результат нужно отправлять в гугл. Результат от гугла - отправлять обратно на фронт.
Думаю это всё разделить на два сервиса и делать параллельно. С потоками/процессами раньше не работал. Поэтому прошу подсказать.
Вижу примерно следующее.
создать первый сервис, в котором будут производится различные операции с чанками, файлом. Результат ложить в очередь.
создать второй сервис, в котором будут доставаться данные из очереди, будут отправляться в гугл и результат уже - на фронт.
Пример вебсокет консюмера:
class ConnectionManager:
def __init__(self):
self.active_connections: List[WebSocket] = []
self.words_list: Dict[str, dict] = {}
async def connect(self, websocket: WebSocket):
await websocket.accept()
if websocket not in self.active_connections:
self.active_connections.append(websocket)
if str(websocket.url) not in self.words_list:
self.words_list[str(websocket.url)] = {"chunks": "", "text": ""}
async def disconnect(self, websocket: WebSocket):
await websocket.send_text(self.words_list[str(websocket.url)]["text"])
self.active_connections.remove(websocket)
async def broadcast(self, message: str, websocket: WebSocket):
new_chunks = merge_base64(
self.words_list[str(websocket.url)]["chunks"], message
)
text = recognition_voice_data(new_chunks)
if not text or self.words_list[str(websocket.url)]["text"].endswith(
text
):
for connection in self.active_connections:
if connection.url == websocket.url:
await connection.send_text(text)
self.words_list[str(websocket.url)]["text"] = ""
self.words_list[str(websocket.url)]["chunks"] = ""
else:
self.words_list[str(websocket.url)]["text"] += text
self.words_list[str(websocket.url)]["chunks"] = new_chunks
Вопросы:
Как всё это организовать? Что нужно, процессы, или потоки? Погуглив, я пришёл к выводу, что мне нужны потоки. Так лиэто?
Каким образом второй сервис будет понимать, что в очереди появились новые данные?
В качество очереди думаю использовать питоновский queue
if queue.size()
в циклеwhile True
? Не костыльно ли это? Что имеете в виду подwait
? – Dima 2 дня назадevent = Event(); thread = Thread(); thread(event); event.wait()
? – Dima 2 дня назад