# Deepgram 参考架构 ## 概述用于使用 Deepgram 构建可扩展、生产就绪的转录系统的参考架构。 ## 架构模式 ### 1\.同步API 直接API调用适合小文件和低延迟要求。 ### 2\.异步队列针对批量工作负载的基于队列的处理。 ### 3\.实时串流基于 WebSocket 的实时转录。 ### 4\.混合架构针对不同用例的模式组合。 ## 模式 1：同步 API 架构 +----------+ +------------+ +----------+ | 客户| --> | API服务器| --> |深度图 | +----------+ +------------+ +----------+ | v +------------+ |数据库| +------------+ **最适合：** * 短音频文件（<60 秒） * 低延迟要求 * 简单集成 ### 实施 // 架构/sync/server.ts 从“快递”进口快递；从'@deepgram/sdk'导入{createClient}；从 './database' 导入 { db }; 常量应用程序 = Express(); const deepgram = createClient(process.env.DEEPGRAM_API_KEY!); app.post('/transcribe', async (req, res) => { const { audioUrl, userId } = req.body; 尝试{ const { 结果，错误 } = 等待 deepgram.listen.prerecorded.transcribeUrl( { url:audioUrl }, { 型号：'nova-2'，smart_format：true } ）； if（错误）抛出错误； const 转录本 = result.results.channels[0].alternatives[0].transcript; // 存储结果等待 db.transcripts.create({ 用户 ID, 音频网址, 成绩单，元数据：结果.元数据， }); res.json({ 成绩单, requestId: result.metadata.request_id }); } 捕获（错误）{ res.status(500).json({ error: '转录失败' }); } }); ## 模式 2：异步队列架构 +--------+ +--------+ +--------+ +------------+ | 客户| --> |队列| --> |工人| --> |深度图 | +--------+ +--------+ +--------+ +------------+ ^ | | v | +------------+ +----------------------|数据库| （民意调查/网络钩子）+------------+ **最适合：** * 长音频文件 * 批处理 * 高吞吐量 ### 实施 // 架构/async/ Producer.ts 从“bullmq”导入{队列}；从 'uuid' 导入 { v4 as uuidv4 }；从'./redis'导入{redis}； consttranscriptionQueue = new Queue('转录', { 连接：redis， }); 导出异步函数submitTranscription( 音频网址：字符串，选项：{ 优先级？：数字；用户 ID?: 字符串 } = {} ): 承诺<字符串> { const jobId = uuidv4(); 等待转录队列.add( '转录', { audioUrl, userId: 选项.userId }, { 职位编号, 优先级：选项.优先级？ 0, 尝试次数：3，退避：{ 类型：'指数'，延迟：5000， }, } ）；返回工作ID； } // 架构/async/worker.ts 从 'bullmq' 导入 { Worker, Job }; 从'@deepgram/sdk'导入{createClient}；从 './database' 导入 { db }; 从'./notifications'导入{notifyClient}； const deepgram = createClient(process.env.DEEPGRAM_API_KEY!); 常量工人 = 新工人（ '转录', 异步（作业：作业）=> { const { audioUrl, userId } = job.data; const { 结果，错误 } = 等待 deepgram.listen.prerecorded.transcribeUrl( { url:audioUrl }, { 型号：'nova-2'，smart_format：true } ）； if（错误）抛出错误； const 转录本 = result.results.channels[0].alternatives[0].transcript; 等待 db.transcripts.create({ jobId: 工作.id, 用户 ID, 音频网址, 成绩单，元数据：结果.元数据， }); 等待notifyClient（用户ID，{ jobId: 工作.id, 状态：“已完成”，成绩单， }); 返回{成绩单}； }, { 连接：redis，并发数：10， } ）； worker.on('已完成', (工作) => { console.log(`作业 ${job.id} 已完成`); }); worker.on('失败', (作业, 错误) => { console.error(`作业 ${job?.id} 失败：`, error); }); ## 模式 3：实时流架构 +----------+ +------------+ +----------+ | 客户| <-> | WebSocket | <-> |深度图 | +----------+ | 服务器| | 直播 | +------------+ +----------+ | v +------------+ | 存储| +------------+ **最适合：** * 实时转录 * 语音接口 * 实时应用 ### 实施 // 架构/streaming/server.ts 从 'ws' 导入 { WebSocketServer, WebSocket }; 从“@deepgram/sdk”导入{createClient，LiveTranscriptionEvents}； const wss = new WebSocketServer({ 端口: 8080 }); const deepgram = createClient(process.env.DEEPGRAM_API_KEY!); wss.on('连接', (clientWs: WebSocket) => { console.log('客户端已连接'); // 创建 Deepgram 连接 const dgConnection = deepgram.listen.live({ 型号：'nova-2'，智能格式：真，临时结果：正确， }); dgConnection.on(LiveTranscriptionEvents.Open, () => { console.log('Deepgram 已连接'); }); dgConnection.on(LiveTranscriptionEvents.Transcript, (数据) => { clientWs.send(JSON.stringify({ 类型：'成绩单'，成绩单：data.channel.alternatives[0].transcript， isFinal: data.is_final, })); }); dgConnection.on(LiveTranscriptionEvents.Error, (错误) => { clientWs.send(JSON.stringify({ 类型：'错误'，错误：错误消息， })); }); // 将音频从客户端转发到 Deepgram clientWs.on('消息', (数据: Buffer) => { dgConnection.send(数据); }); clientWs.on('关闭', () => { dgConnection.finish(); console.log('客户端已断开连接'); }); }); ## 模式 4：混合架构 +----------------+ +--> |同步处理程序| --> 深度图 | +----------------+ +----------+ +--------+ | | 客户| --> |路由器| | +----------------+ +----------+ +--------+ +--> |异步队列 | --> 工作人员 --> Deepgram | +----------------+ | | +----------------+ +--> |流处理程序| <-> Deepgram 直播 +----------------+ ### 实施 // 架构/hybrid/router.ts 从“快递”进口快递；从'./handlers/sync'导入{syncHandler}；从'./handlers/async'导入{asyncHandler}；从'./handlers/stream'导入{streamHandler}；常量应用程序 = Express(); // 根据请求特征进行路由 app.post('/transcribe', async (req, res) => { const { audioUrl, mode, audioDuration } = req.body; // 如果未指定，则根据音频持续时间自动选择模式让选定模式=模式；如果（！selectedMode）{ 如果（音频持续时间&&音频持续时间<60）{ 选择模式 = '同步'; } else if (audioDuration && audioDuration > 300) { 选择模式 = '异步'; } 否则{ 选择模式 = '同步'; // 默认为未知 } } 开关（选择模式）{ 案例“同步”：返回syncHandler(req, res); 案例“异步”：返回 asyncHandler(req, res); 案例“流”：返回streamHandler(req, res); 默认：返回syncHandler(req, res); } }); ## 企业架构 +------------------+ | 负载均衡器| +------------------+ | +----------------------------------------++----------------------------------------+ | | | +----------------+ +----------------+ +----------------+ | API服务器| | API服务器| | API服务器| | （A区） | | （B区） | | （C区） | +----------------+ +----------------+ +----------------+ | | | 维维维 +----------------+ +----------------+ +----------------+ | Redis 集群 |<------------->| Redis 集群 |<------------->| Redis集群 | +----------------+ +----------------+ +----------------+ | | | 维维维 +----------------+ +----------------+ +----------------+ |工人池 | |工人池 | |工人池 | +----------------+ +----------------+ +----------------+ | | | +----------------------------------------++----------------------------------------+ | +------------------+ | Deepgram API | +------------------+ ### 企业实施 // 架构/企业/config.ts 导出常量配置= { 区域：['us-east-1'、'us-west-2'、'eu-west-1']、雷迪斯：{ 集群：真实，节点：[ { 主机：'redis-us-east.example.com'，端口：6379 }， { 主机：'redis-us-west.example.com'，端口：6379 }， { 主机：'redis-eu-west.example.com'，端口：6379 }， ], }, 工人：{ 并发数：20，最大重试次数：5， }, 速率限制：{ 每分钟最大请求数：1000，最大并发数：100， }, 监控：{ 指标端点：'/指标'，健康端点：'/健康'，跟踪已启用：true， }, }; // 架构/企业/load-balancer.ts 从 'express' 导入 { Router } ；从 './health' 导入 { getHealthyRegion }；从'./proxy'导入{forwardRequest}； const 路由器 = Router(); router.use('/transcribe', async (req, res) => { // 找到最健康的区域 const 区域 = 等待 getHealthyRegion(); 如果（！区域）{ return res.status(503).json({ error: '服务不可用' }); } // 转发请求等待forwardRequest（请求，资源，区域）； }); 导出默认路由器； ## 监控架构 // 架构/监控/dashboard.ts 从'prom-client'导入{Registry，collectDefaultMetrics，Counter，Histogram，Gauge}；导出常量注册表=新注册表（）； collectDefaultMetrics({ 注册：注册表 }); // 指标导出 const requestsTotal = 新计数器({ 名称： 'transcription_requests_total', help: '总转录请求', labelNames: ['状态', '型号', '地区'], 寄存器：[注册表]， }); 导出常量延迟直方图=新直方图（{ 名称：'转录延迟秒'， help: '转录延迟', 标签名称：['型号']，桶：[0.5, 1, 2, 5, 10, 30, 60, 120], 寄存器：[注册表]， }); 导出常量队列深度=新仪表（{ 名称：'转录队列深度'， help: '队列中的作业数量', 寄存器：[注册表]， }); 导出 const activeConnections = new Gauge({ 名称：'deepgram_active_connections'， help: '活跃的 Deepgram 连接', 寄存器：[注册表]， }); ## 资源 * [Deepgram 架构指南]() * [高可用性模式]() * [扩展最佳实践]() ## 后续步骤继续进行“deepgram-multi-env-setup”进行多环境配置。

Deepgram 参考架构

包含技能