lintoai/linto-diarization-pybk

LinTO-diarization

LinTO-diarization是LinTO的说话人分轨服务。

LinTO-diarization既可作为独立的分轨服务使用，也可部署为微服务。

• 先决条件

• 部署

  • HTTP模式
  • 微服务模式

• 使用方法

  • HTTP API
    • /healthcheck
    • /diarization
    • /docs
  • 使用Celery

• 许可证

---

先决条件

Docker

该分轨服务需要Docker已安装并运行。

（微服务）消息代理和共享文件夹

在任务模式下，分轨服务的唯一入口是发布到Redis消息代理的任务。此外，为避免大型音频通过消息代理传输，分轨服务使用挂载到/opt/audio的共享存储文件夹。

部署

linto-diarization可通过以下方式部署：

• 作为独立分轨服务，通过HTTP API提供服务。
• 作为连接到消息代理的微服务。

1- 第一步：构建镜像

bash
git clone https://github.com/linto-ai/linto-diarization.git
cd linto-diarization
docker build . -t linto-diarization-pybk:latest -f pybk/Dockerfile 

HTTP模式

1- 配置.env文件

https://github.com/linto-ai/linto-diarization/blob/master/pybk/.envdefault%E6%8F%90%E4%BE%9B%E4%BA%86.env%E6%96%87%E4%BB%B6%E7%A4%BA%E4%BE%8B%E3%80%82

参数说明：

2- 运行容器

bash
docker run --rm \
-v SHARED_FOLDER:/opt/audio \
-p HOST_SERVING_PORT:80 \
--env-file .env \
linto-diarization:latest

此命令将运行一个容器，提供绑定到主机HOST_SERVING_PORT端口的HTTP API。

参数说明：

*分轨服务会使用所有可用CPU，增加工作进程会共享可用CPU，从而降低并发请求的处理速度

使用Celery

LinTO-diarization可使用Celery部署为微服务。在此模式下，容器会启动Celery工作进程，等待消息代理上的分轨任务。

需要在SERVICES_BROKER地址运行消息代理。

1- 配置.env文件

https://github.com/linto-ai/linto-diarization/blob/master/pybk/.envdefault%E6%8F%90%E4%BE%9B%E4%BA%86.env%E6%96%87%E4%BB%B6%E7%A4%BA%E4%BE%8B%E3%80%82

参数说明：

2- 配置docker-compose.yml

#docker-compose.yml

yaml
version: '3.7'

services:
  punctuation-service:
    image: linto-diarization-pybk:latest
    volumes:
      - /path/to/shared/folder:/opt/audio
    env_file: .env
    deploy:
      replicas: 1
    networks:
      - your-net

networks:
  your-net:
    external: true

3- 使用docker compose运行

bash
docker stack deploy --resolve-image always --compose-file docker-compose.yml your_stack

队列名称：

默认服务队列名称使用SERVICE_NAME和LANGUAGE生成：diarization_{LANGUAGE}_{SERVICE_NAME}。

可通过QUEUE_NAME环境变量覆盖队列名称。

服务发现：

作为微服务时，实例会在服务注册中心注册自身以便发现。服务信息以JSON对象形式存储在Redis的db0中，键为service:{HOST_NAME}。

注册的信息如下：

json
{
  "service_name": $SERVICE_NAME,
  "host_name": $HOST_NAME,
  "service_type": "diarization",
  "service_language": $LANGUAGE,
  "queue_name": $QUEUE_NAME,
  "version": "1.2.0", # 此仓库的版本
  "info": $MODEL_INFO,
  "last_alive": 65478213,
  "concurrency": 1
}

使用方法

HTTP API

/healthcheck

返回API状态

方法：GET

健康检查通过时返回"1"。

/diarization

分轨API

• 方法：POST
• 响应内容：application/json
• 文件：Wave文件
• speaker_count:（整数，可选）说话人数量。若留空，分轨服务将自动聚类。
• max_speaker:（整数，可选）当speaker_count未知时的最大说话人数量。

返回结构化JSON对象，格式如下：

json
{
  "speakers": [
      {"spk_id": "spk5", "duration": 2.0, "nbr_seg": 1},
      ...
  ],
  "segments": [
      {"seg_id": 1, "spk_id": "spk5", "seg_begin": 0.0, "seg_end": 2.0},
      ...
  ]
}

/docs

/docs路由提供OpenAPI/swagger界面。

通过消息代理

分轨工作进程接受包含以下参数的请求：

• file_path:（字符串）文件在共享文件夹中的位置。/.../SHARED_FOLDER/{file_path}
• speaker_count:（整数，默认None）固定说话人数量。
• max_speaker:（整数，默认None）当speaker_count=None时的最大说话人数量。

返回格式

成功分轨后，返回的JSON对象结构如下：

json
{
  "speakers": [
      {"spk_id": "spk5", "duration": 2.0, "nbr_seg": 1},
      ...
  ],
  "segments": [
      {"seg_id": 1, "spk_id": "spk5", "seg_begin": 0.0, "seg_end": 2.0},
      ...
  ]
}

• speakers字段包含说话人数组，包含总时长和段数。
• segments字段包含每个音频段，包含关联的说话人ID、开始时间和结束时间。

测试

Curl

可使用curl测试HTTP API：

bash
curl -X POST "http://YOUR_SERVICE:PORT/diarization" -H  "accept: application/json" -H  "Content-Type: multipart/form-data" -F "file=@YOUR_FILE.wav;type=audio/x-wav" -F "speaker_count=NUMBER_OF_SPEAKERS"

许可证

本项目基于AGPLv3许可证开发（见LICENSE）。

致谢

• https://github.com/josepatino/pyBK%E5%88%86%E8%BD%A8%E6%A1%86%E6%9E%B6%EF%BC%88MIT%E8%AE%B8%E5%8F%AF%E8%AF%81%EF%BC%89%E3%80%82