AIDAWORK / SEQUENCE

Message Center:PG + pg_notify

独立图页 ↗
机制说明(SoT)图是辅读 · 结论以说明与证据为准

消息中心在会话、Conversation Interaction、Scheduler、Workflow 与外部事件之上持久化通知读模型。它保存收件箱摘要、来源指针、动作契约与状态,不取代上游业务实体;用户处理后仍由原始业务系统或运行时决定终态。

本页可直接往下读完整机制说明,不需要「演示 / 播放故事」。术语不熟先看 术语表。

先读机制说明,结论以说明与证据为准 · 基于固定代码版本核验 · 部署状态另行确认

机制说明(全文)

Message Center 通知读模型

不是业务实体的 SoT

消息中心在会话、Conversation Interaction、Scheduler、Workflow 与外部事件之上持久化通知读模型。它保存收件箱摘要、来源指针、动作契约与状态,不取代上游业务实体;用户处理后仍由原始业务系统或运行时决定终态。

写入走 NotificationService.emit:偏好只决定是否实时打扰;新建且允许实时时在 Config DB 事务内 INSERT notifications 后 pg_notify('aida_notification', ids)。各实例 LISTEN 后由 NotificationConnectionRegistry 扇出到 /api/notifications/stream。未配置 CONFIG_DB_URL + CONFIG_ENC_KEY 时用户通知路由返回 501,没有生产级内存降级。

证据与范围

  • aida-agent · docs/architecture/message-center.md L1–35 · 77fe76838aa4(历史引用:该文档已在 aida-agent 44d63e20 退役,钉点 e2adc9a3c325 无此文件;见 ATLAS-DEBT)
  • aida-agent · packages/agent/src/notifications/service.ts L21–51 · NOTIFICATION_NOTIFY_CHANNEL · e2adc9a3c325
  • aida-agent · packages/agent/src/notifications/connection-registry.ts L35–65 · NotificationConnectionRegistry · e2adc9a3c325

结论来自固定版本的静态源码与合同阅读;实现存在、默认开关和生产启用分别判断。本站代码证据面板列出声明状态与具体限制。

机制说明

Message Center 通知读模型

不是业务实体的 SoT

消息中心在会话、Conversation Interaction、Scheduler、Workflow 与外部事件之上持久化通知读模型。它保存收件箱摘要、来源指针、动作契约与状态,不取代上游业务实体;用户处理后仍由原始业务系统或运行时决定终态。

写入走 NotificationService.emit:偏好只决定是否实时打扰;新建且允许实时时在 Config DB 事务内 INSERT notifications 后 pg_notify('aida_notification', ids)。各实例 LISTEN 后由 NotificationConnectionRegistry 扇出到 /api/notifications/stream。未配置 CONFIG_DB_URL + CONFIG_ENC_KEY 时用户通知路由返回 501,没有生产级内存降级。

证据与范围

  • aida-agent · docs/architecture/message-center.md L1–35 · 77fe76838aa4(历史引用:该文档已在 aida-agent 44d63e20 退役,钉点 e2adc9a3c325 无此文件;见 ATLAS-DEBT)
  • aida-agent · packages/agent/src/notifications/service.ts L21–51 · NOTIFICATION_NOTIFY_CHANNEL · e2adc9a3c325
  • aida-agent · packages/agent/src/notifications/connection-registry.ts L35–65 · NotificationConnectionRegistry · e2adc9a3c325

结论来自固定版本的静态源码与合同阅读;实现存在、默认开关和生产启用分别判断。本站代码证据面板列出声明状态与具体限制。

代码证据

引用核验检查固定 commit 的文件与范围;实现结论来自代码阅读。自动检查不证明生产环境已启用。

已核验实现

消息中心是持久化通知读模型,不取代上游业务实体;用户处理后终态仍由原始业务系统或运行时决定。

aida-agentpackages/agent/src/notifications/publisher.ts:14–447f2e519936b57902d4907ed8026fe1ecdd146e82符号:NotificationService.emit
已核验实现

NotificationService.emit 在 Config DB 写入 notifications 后对新建且允许实时的记录执行 pg_notify(aida_notification);每实例 LISTEN 后由 NotificationConnectionRegistry 扇出 SSE。

aida-agentpackages/agent/src/notifications/service.ts:26–567f2e519936b57902d4907ed8026fe1ecdd146e82符号:NOTIFICATION_NOTIFY_CHANNEL
aida-agentpackages/agent/src/notifications/connection-registry.ts:35–657f2e519936b57902d4907ed8026fe1ecdd146e82符号:NotificationConnectionRegistry