用途:在身份验证(KYC)流水线中实现失败任务处理,配合 worker_pool_agent 使用,捕获超过最大重试次数的关键任务(face_match、OCR、liveness 等),避免任务直接丢失。
主要能力:按任务类型配置最大重试次数(在 Celery 配置中定义 TASK_MAX_RETRIES);建立 DLQ 数据表模型保存任务名、task_id、参数、异常、traceback、重试次数与状态(pending、reprocessed、discarded);通过 Celery 的 task_failure 信号把耗尽重试的任务写入 DLQ;提供查询和管理的 API 端点(列出 pending 条目、按条目重处理);周期任务分析近期失败模式并在超过阈值时告警;定义 DLQ 指标计数;按保留天数清理旧条目。
使用方式:在 Celery 配置中设定各任务重试上限,定义 DeadLetterEntry 模型,连接 task_failure 信号处理器,注册 /dlq/entries 查询与 /dlq/entries/{entry_id}/reprocess 重处理端点,并配置 dlq_analysis 分析任务、DLQ_METRICS 指标与 dlq_cleanup 清理任务。
限制与注意:DLQ 条目须按 GDPR/LOPD 匿名化生物与个人数据,只存会话引用,绝不存图像或人脸嵌入;从 DLQ 手动重处理必须经过与原流程相同的反欺诈校验,防止绕过安全;需持续监控 DLQ 增长作为系统健康指标。资料未提供具体部署环境、收费与价格、支持平台等信息。