从“用户主动调用AI”,走向“企业业务发生变化后,AI自动响应”。
前面的章节,我们已经逐步构建了一套企业AI技术体系:
LLM ↓ RAG ↓ Agent ↓ Tool Calling ↓ Agent Runtime ↓ Workflow Engine ↓ Enterprise AI Operating System第21章解决:
Agent如何运行?
第22章解决:
复杂业务流程如何编排?
而第23章继续解决一个非常关键的问题:
Workflow什么时候启动?
传统应用通常是:
User ↓ API ↓ Application ↓ Database用户不操作,系统就不一定发生动作。
但企业真实业务并不是这样。
很多业务变化来自:
订单创建 库存不足 设备异常 客户投诉 付款完成 合同到期 员工入职 生产异常 物流延迟这些都属于:
Business Event
如果能够让AI监听这些事件:
Business Event ↓ Event Bus ↓ AI Workflow ↓ Agent ↓ Tool ↓ Enterprise System那么AI就从:
被动响应
逐渐进入:
事件驱动的主动执行。
一、什么是Event?
Event,中文通常称为:
事件。
在企业系统里,一个Event代表:
某个已经发生的事实。
例如:
OrderCreated表示:
一个订单已经创建。
又例如:
InventoryLow表示:
某个SKU库存已经低于安全库存。
例如:
PaymentCompleted表示:
一笔付款已经完成。
例如:
EquipmentAlert表示:
某台设备产生异常告警。
Event和Command有一个非常重要的区别。
二、Event ≠ Command
Command通常表示:
请执行某件事情。
例如:
CreatePurchaseOrder意思是:
创建采购订单。
Event则表示:
某件事情已经发生。
例如:
PurchaseOrderCreated意思是:
采购订单已经创建。
可以简单理解:
Command = “请做这个事情” Event = “这个事情已经发生了”例如:
CreateOrder ↓ 执行 ↓ OrderCreated所以:
Command → Action Event → Fact这是事件驱动架构的基础。
三、为什么企业AI需要Event Bus?
假设企业没有Event Bus。
库存系统发现:
SKU-001 库存 = 5 安全库存 = 20那么系统可能直接:
Inventory System ↓ 调用AI API ↓ AI分析问题很快就出现。
如果未来还有:
采购系统 销售系统 BI系统 消息系统 Agent Workflow都需要知道:
库存不足。
那么库存系统可能需要:
Inventory ├── AI ├── Procurement ├── BI ├── Notification ├── Mobile └── Reporting系统之间会产生大量直接依赖。
最终形成:
A → B A → C A → D A → E B → C B → D ...系统越来越难维护。
Event Bus的作用就是:
把事件生产者和事件消费者解耦。
四、Event Bus是什么?
可以简单理解:
Producer ↓ Event Bus ↓ Consumer例如:
WMS ↓ InventoryLow Event ↓ Event Bus ├── Procurement Workflow ├── BI ├── Notification └── AI AgentWMS不需要知道:
谁会消费这个事件。
它只需要:
发布事件。
这就是解耦。
五、Enterprise AI Event Architecture
完整架构可以设计成:
Enterprise Systems │ ┌──────────────────┼──────────────────┐ ↓ ↓ ↓ ERP WMS MES │ │ │ └──────────────────┼──────────────────┘ ↓ Event Producer │ ↓ Event Bus │ ┌──────────────┼──────────────┐ ↓ ↓ ↓ Event Router Event Store Event Monitor │ ┌─────┼─────┐ ↓ ↓ ↓ Workflow Agent BI │ │ ↓ ↓ Workflow Agent │ │ └──┬──┘ ↓ Tool ↓ Enterprise API这样企业AI就进入了:
Event-driven AI Architecture
六、企业Event通常来自哪里?
Event来源非常多。
1. ERP
OrderCreated InvoiceCreated PaymentCompleted PurchaseApproved2. WMS
InventoryLow InventoryAdjusted StockInCompleted StockOutCompleted OrderPicked3. MES
ProductionStarted ProductionCompleted EquipmentAlert QualityDefect ProductionDelay4. CRM
CustomerCreated CustomerComplaint LeadCreated OpportunityUpdated5. OA
ApprovalSubmitted ApprovalCompleted EmployeeJoined EmployeeResigned6. IoT
TemperatureHigh PressureHigh DeviceOffline SensorAlert因此:
ERP WMS MES CRM OA IoT ↓ Events会成为企业AI的重要输入。
七、Event Schema
Event不能只是:
“库存不足”企业系统需要结构化Event。
例如:
{ "event_id": "evt-20260925-00001", "event_type": "InventoryLow", "event_version": "1.0", "timestamp": "2026-09-25T09:00:00+08:00", "tenant_id": "tenant-001", "source": "WMS", "data": { "warehouse_id": "WH01", "sku": "SKU-001", "available_qty": 5, "safety_stock": 20 } }这里最重要的字段包括:
event_id event_type event_version timestamp tenant_id source data八、为什么Event必须有Event ID?
因为消息系统可能发生:
重复投递 网络重试 消费者重启 消息重新消费例如:
Event ↓ Consumer ↓ 处理成功 ↓ ACK失败 ↓ Event再次投递于是:
Event A Event A可能出现两次。
如果没有Event ID,系统很难判断:
这是新事件,还是重复事件?
因此:
event_id通常应该是全局唯一的。
九、Event Version
企业系统一定会变化。
例如:
InventoryLow v1后来增加:
warehouse_zone于是:
InventoryLow v2如果消费者仍然只理解v1怎么办?
因此Event需要:
event_type + event_version例如:
InventoryLow.v1 InventoryLow.v2这样可以支持:
Event Schema Evolution
即:
事件结构持续演进。
十、Event Timestamp
事件必须记录:
timestamp因为企业系统经常需要回答:
这个事件什么时候发生?
例如:
库存不足 发生时间: 08:32:15但是事件可能:
08:32产生 08:32:20进入Event Bus 08:32:30被消费所以至少要区分:
Event Time Processing Time即:
事件发生时间 ≠ 事件处理时间这在实时分析和延迟监控中非常重要。
十一、Event Producer
产生Event的系统叫:
Producer。
例如:
WMS ↓ InventoryLowWMS就是Producer。
或者:
MES ↓ EquipmentAlertMES就是Producer。
Producer通常负责:
检测业务变化 ↓ 构造Event ↓ 发布Event十二、Event Consumer
消费Event的系统叫:
Consumer。
例如:
InventoryLow ↓ Procurement Workflow那么:
Procurement Workflow就是Consumer。
同一个Event可以有多个Consumer:
InventoryLow ↓ Event Bus ┌────┼──────┬───────┐ ↓ ↓ ↓ ↓ AI BI Notification Procurement这就是事件驱动架构的核心优势。
十三、Topic
在Kafka等消息系统中,通常会使用:
Topic。
例如:
inventory.events order.events payment.events equipment.events customer.events例如:
inventory.events │ ├── InventoryLow ├── InventoryAdjusted ├── StockIn └── StockOut消费者可以订阅:
inventory.events然后进一步根据:
event_type进行处理。
十四、Queue
Queue与Topic有一些不同。
可以简单理解:
Queue = 一条任务队列 Topic = 一个事件流例如:
Order Processing Queue消费者通常从队列中获取任务。
而:
order.events可以允许多个Consumer Group分别消费。
十五、Consumer Group
这是企业事件架构中的一个重要概念。
例如:
order.events │ ┌────┼───────┐ ↓ ↓ ↓ CRM BI AI Workflow三个系统分别有自己的Consumer Group:
crm-group bi-group ai-workflow-group那么:
一个OrderCreated事件可以分别被三个系统消费。
这使得系统之间实现解耦。
十六、Event Routing
Event Bus不仅负责传递消息。
还需要:
Event Routing。
例如:
InventoryLow │ ↓ Event Router │ ┌────┼────┐ ↓ ↓ ↓ WMS AI BI再进一步:
InventoryLow AND available_qty < safety_stock * 0.5才触发:
Emergency Procurement Workflow因此可以:
Event ↓ Filter ↓ Route ↓ Workflow十七、Event Filter
并不是所有事件都需要触发AI。
例如每天可能产生:
InventoryChanged100万条。
如果每条都触发Agent:
100万 Events ↓ 100万 Agent Calls成本会非常高。
因此需要:
Event Filter例如:
available_qty < safety_stock才进入Workflow。
进一步:
available_qty < safety_stock * 0.5才进入高级AI分析。
因此:
Event ↓ Filter ↓ Condition ↓ Workflow十八、Event Trigger
Workflow Engine可以订阅Event。
例如:
InventoryLow ↓ Event Trigger ↓ Inventory Replenishment WorkflowWorkflow Definition:
Trigger: event_type = InventoryLow之后:
WMS ↓ InventoryLow ↓ Event Bus ↓ Workflow Trigger ↓ Workflow Engine这样Workflow就不需要用户主动点击。
十九、Event-driven AI Workflow
这就是本章最重要的概念:
Business Event ↓ Event Bus ↓ Event Trigger ↓ AI Workflow ↓ Agent ↓ Tool ↓ Enterprise System例如:
库存不足 ↓ AI分析 ↓ 查询历史销量 ↓ 查询供应商 ↓ 预测需求 ↓ 生成采购建议 ↓ 人工审批 ↓ 创建采购订单这已经不是:
AI Chatbot。
而是:
AI Business Automation。
二十、完整案例:库存自动补货
继续使用第22章的企业采购案例。
原来的流程:
员工 ↓ 提交采购申请 ↓ AI分析 ↓ 库存检查 ↓ 风险判断 ↓ 人工审批 ↓ 采购订单现在加入Event:
WMS ↓ 库存下降 ↓ InventoryLow ↓ Event Bus ↓ AI Procurement Workflow完整流程:
InventoryLow ↓ Event Bus ↓ Workflow Trigger ↓ Receive Event ↓ Validate Event ↓ Check Inventory ↓ Query Historical Sales ↓ AI Demand Analysis ↓ Generate Purchase Recommendation ↓ Risk Check ↓ Condition ┌────┴─────┐ ↓ ↓ Low Risk High Risk ↓ ↓ Auto Human Approval Process ↓ ↓ Approved? └────┬──────┤ ↓ ↓ Create Purchase Order ↓ ERP ↓ Notify ↓ End这就是:
Event-driven Procurement Agent。
二十一、Event如何进入Workflow?
完整调用链:
WMS ↓ Business Event ↓ Event Producer ↓ Event Bus ↓ Event Router ↓ Event Filter ↓ Event Trigger ↓ Workflow Engine ↓ Task ↓ Agent ↓ Tool ↓ ERP可以发现:
Event Bus实际上连接了企业系统与AI Workflow。
二十二、Event Bus与Agent Runtime
第21章的Runtime负责:
Task Agent Tool MCP Memory第22章Workflow Engine负责:
Workflow DAG State Scheduler Human Approval Retry Timeout第23章Event Bus负责:
Event Routing Delivery Trigger Replay三者组合:
Event ↓ Event Bus ↓ Workflow ↓ Task ↓ Agent ↓ Tool ↓ Enterprise System可以理解为:
Event Bus = “为什么启动” Workflow = “按照什么流程” Agent = “如何智能处理” Tool = “如何操作系统”二十三、Event Delivery
事件系统最重要的问题之一:
消息到底能不能可靠送到?
常见Delivery模式包括:
At-most-once At-least-once Exactly-once二十四、At-most-once
意思:
最多发送一次。
可能:
发送 ↓ 成功也可能:
发送 ↓ 丢失优点:
简单 低延迟缺点:
可能丢消息。
适合:
非关键通知 实时状态刷新二十五、At-least-once
意思:
至少送达一次。
如果处理失败:
Retry因此:
Event ↓ Consumer ↓ Failed ↓ Retry可能产生:
重复消息所以Consumer必须支持:
Idempotency
即:
幂等处理。
企业系统中这是非常常见的模式。
二十六、Exactly-once
意思:
业务效果只发生一次。
这是最理想的状态,但实际实现非常复杂。
尤其当事件跨越:
Event Bus + Workflow + ERP + Database + External API时,很难简单保证真正意义上的Exactly-once。
因此企业实践中经常使用:
At-least-once + Idempotency + Deduplication实现业务层面的:
Exactly-once Effect。
二十七、Idempotency
例如:
Create Purchase Order如果事件重复:
Event A Event A不能创建:
PO001 PO002而应该确保:
Event A ↓ PO001 Event A再次到达 ↓ 发现已处理 ↓ 返回PO001可以使用:
event_id idempotency_key business_key例如:
idempotency_key = tenant_id + event_id二十八、Deduplication
消费者可以维护:
Processed Event Store例如:
event_id status processed_at result收到事件:
Event ID ↓ 查询Processed Event如果已经存在:
直接返回否则:
执行 ↓ 保存Event ID这样可以防止重复执行。
二十九、Retry
消息失败以后,需要Retry。
例如:
Attempt 1 ↓ Failed ↓ Retry ↓ Attempt 2 ↓ Failed ↓ Retry ↓ Attempt 3但是Retry需要考虑:
Transient Error Permanent Error临时错误:
Network Timeout 503 Connection Reset适合Retry。
永久错误:
Invalid Parameter Permission Denied Business Rule Violation通常不应该无限Retry。
三十、Dead Letter Queue
如果一条消息反复失败:
Event ↓ Retry ↓ Retry ↓ Retry ↓ Failed不能永远卡在主队列。
因此可以进入:
Dead Letter Queue(DLQ)
架构:
Event ↓ Queue ↓ Consumer ↓ Failed ↓ Retry ↓ Retry ↓ Retry ↓ DLQ然后管理员可以:
查看 分析 修复 重新投递这就是:
Dead Letter + Replay
三十一、Event Replay
企业系统经常需要:
把历史事件重新执行一次。
例如:
昨天AI Workflow有Bug修复以后:
历史Event ↓ Replay ↓ 新版本Workflow因此Event系统最好能够保存:
Event Event ID Event Type Timestamp Payload Version Source这样可以实现:
Event Replay。
三十二、为什么Event Store很重要?
如果只把Event当成:
消息消费完成以后就删除,那么很多问题难以追踪。
例如:
“昨天这个订单为什么没有触发AI Workflow?”
如果没有历史事件:
无法确认如果保存Event:
OrderCreated ↓ Event ID ↓ Event Timestamp ↓ Event Delivery ↓ Workflow Trigger就可以追踪完整链路。
因此:
Event不仅是消息,也是企业AI系统的重要审计数据。
三十三、Event与Audit Log
Event和Audit Log不是一回事。
Event:
描述业务事实。
Audit Log:
描述系统做了什么。
例如:
Event: InventoryLow表示:
库存不足。
Audit:
AI Workflow started Agent called Tool executed Human approved Purchase order created所以:
Event = 业务事实 Audit = 系统行为两者应该分别管理。
三十四、Event Observability
事件驱动系统很容易出现一个问题:
消息到底卡在哪里?
因此需要完整Trace:
Event ID ↓ Event Bus ↓ Topic ↓ Partition ↓ Consumer Group ↓ Workflow ID ↓ Task ID ↓ Agent ID ↓ Tool Call ↓ Enterprise API例如:
event_id: evt-001 workflow_id: wf-8821 task_id: task-39281 agent_id: procurement-agent tool: create_purchase_order这样FDE可以做到:
从一个业务事件追踪到最终系统操作。
三十五、Event Latency
事件系统需要关注:
Event Produced ↓ Event Consumed ↓ Workflow Started ↓ Agent Started ↓ Tool Executed可以计算:
Event Latency = Consume Time - Event Time以及:
Workflow Trigger Latency = Workflow Start - Event Consume最终:
End-to-End Latency = Business Event → Business Action例如:
库存低于安全库存 08:30:00 AI Workflow启动 08:30:02 AI分析完成 08:30:08 采购建议生成 08:30:10 人工审批 08:31:20 ERP订单创建 08:31:25这样企业才能真正衡量:
AI自动化到底快了多少。
三十六、Event Storm
事件系统还有一个特殊风险:
Event Storm
例如:
MES ↓ 设备异常 ↓ 10000 Events ↓ Event Bus如果每个Event都触发AI:
10000 Events ↓ 10000 Workflows ↓ 10000 Agents可能导致:
Token暴增 Tool Calls暴增 数据库压力 Workflow队列堆积 模型并发超限 成本暴增因此必须设计:
Rate Limit Backpressure Batching Debounce Aggregation Priority三十七、Debounce
例如:
10秒内 设备连续产生100条相同告警不一定需要:
100个Workflow可以进行:
Debounce最终:
100 Events ↓ Aggregation ↓ 1 Workflow这对于IoT、MES、监控系统非常重要。
三十八、Event Aggregation
例如:
SKU-001 库存变化短时间内发生:
+10 -3 -4 -2 -1如果每次都触发AI:
5 Events → 5 AI Calls其实没有必要。
可以聚合:
5 Events ↓ Current Inventory = 5 ↓ 1 AI Workflow因此:
Event驱动并不意味着每个Event都立即调用AI。
三十九、Priority
企业事件还需要优先级。
例如:
P0 生产线停机 P1 关键设备异常 P2 库存不足 P3 普通业务通知Workflow Engine可以:
P0 ↓ 立即执行 P3 ↓ 排队执行这样可以避免:
普通任务占满AI资源,导致关键任务无法执行。
四十、Event-driven Agent
到了这里,Agent的运行方式发生了变化。
传统:
User ↓ Chat ↓ Agent现在:
Event ↓ Agent例如:
EquipmentAlert ↓ Maintenance AgentAgent可以:
读取设备历史 ↓ 查询维修记录 ↓ 分析故障 ↓ 生成维修建议 ↓ 创建维修任务这就是:
Event-driven Agent。
四十一、Event-driven Workflow
更进一步:
Event ↓ Workflow ↓ Agent ↓ Tool例如:
客户投诉 ↓ CustomerComplaint ↓ Customer Service Workflow ↓ Complaint Agent ↓ 查询客户历史 ↓ 分析投诉 ↓ 生成处理方案 ↓ 人工审核 ↓ CRM更新AI已经从:
“回答客服问题”
进入:
“自动运行客服业务流程”。
四十二、Event-driven Enterprise AI
最终:
Enterprise AI OS │ Event Bus │ ┌───────────────────┼───────────────────┐ ↓ ↓ ↓ ERP WMS MES │ │ │ └───────────────────┼───────────────────┘ ↓ Event Bus │ ┌──────────┼──────────┐ ↓ ↓ ↓ Workflow Agent BI │ │ ↓ ↓ Runtime Runtime │ │ └────┬─────┘ ↓ Tool / MCP ↓ AI Gateway ↓ Enterprise Systems这就是:
Event-driven Enterprise AI Architecture
四十三、Event Bus与Enterprise AI OS
到了第23章,我们可以进一步完善Enterprise AI OS。
Enterprise AI Operating System │ ├── Control Plane │ ├── Model Registry │ ├── Agent Registry │ ├── Tool Registry │ ├── Workflow Registry │ ├── Event Registry │ ├── Knowledge Registry │ ├── Tenant Registry │ └── Policy Registry │ ├── Runtime Plane │ ├── Agent Runtime │ ├── Workflow Runtime │ ├── Task Runtime │ ├── Tool Runtime │ ├── MCP Runtime │ ├── Memory Runtime │ └── Event Runtime │ └── Governance Plane ├── Security ├── Evaluation ├── Cost ├── Audit ├── Compliance └── Observability可以看到:
Event已经成为企业AI平台的一等公民。
四十四、Event Registry
既然Event越来越多,也需要统一管理。
例如:
Event Registry记录:
Event Name Event Version Producer Schema Consumers Security Retention Retry Policy Priority例如:
InventoryLow v1.0 Producer: WMS Consumers: Procurement Workflow BI Notification这样企业就不会出现:
“这个Event是谁发的?” “谁在消费?” “字段是什么?” “版本是多少?”四十五、Event Security
Event同样需要权限控制。
例如:
EmployeeSalaryChanged这是敏感事件。
不能:
任何Agent ↓ 读取需要:
Tenant ↓ Role ↓ Data Permission ↓ Event Permission ↓ Consumer例如:
HR Agent → 可以消费EmployeeSalaryChanged WMS Agent → 不允许消费所以:
Event本身也应该成为权限控制对象。
四十六、Event Multi-Tenant
在第17章,我们学习了Multi-Tenant。
Event同样需要Tenant隔离。
例如:
Tenant A ↓ InventoryLow不能被:
Tenant B Agent消费。
所以Event必须携带:
tenant_id并在Consumer侧进行校验:
Event Tenant ↓ Tenant Context ↓ Authorization ↓ Workflow不能只相信Event Payload里的tenant_id。
应该通过:
Trusted Event Source + Authentication + Authorization建立可信Tenant Context。
四十七、Event与Cost Governance
事件驱动AI还有一个非常重要的问题:
Event越多,AI成本可能越高。
例如:
每天10万Events如果:
10万 Events → 10万 Agent Calls成本可能非常高。
所以必须:
Event ↓ Filter ↓ Aggregation ↓ Priority ↓ Model Routing ↓ Agent例如:
Low Risk Event → Small Model Medium Risk → Medium Model High Risk → Large Model + Human Approval这就把第16章的Cost Governance重新连接起来。
四十八、Event + Workflow + Agent + Cost
完整优化链路:
Event ↓ Filter ↓ Deduplication ↓ Aggregation ↓ Priority ↓ Workflow ↓ Task ↓ Model Routing ↓ Agent ↓ Tool可以减少:
无效Workflow 无效Agent Call 无效Tool Call 无效Token最终实现:
Event-driven AI Cost Governance
四十九、Event + Evaluation
事件驱动Workflow同样需要Evaluation。
例如:
InventoryLow应该验证:
是否触发Workflow? 是否触发正确Workflow? 是否调用正确Agent? 是否调用正确Tool? 是否进入正确分支? 是否创建正确订单?可以定义:
Event Trigger Success Rate Workflow Trigger Success Rate Agent Task Success Rate Tool Success Rate Business Completion Rate例如:
10000 InventoryLow Events 9900 正确触发 9800 正确完成可以得到:
Trigger Success Rate = 99% Business Completion Rate = 98%这比单纯统计:
LLM Accuracy更加接近企业真实业务价值。
五十、FDE如何设计Event-driven AI?
当客户说:
“我们想让AI自动处理库存异常。”
FDE不要直接开始写Agent。
应该先问:
什么事件代表库存异常?例如:
available_qty < safety_stock然后:
谁产生这个事件?答案:
WMS接着:
事件需要哪些字段?例如:
warehouse sku available_qty safety_stock timestamp然后:
谁消费?Procurement Workflow再问:
什么情况下需要AI?例如:
历史销量异常 供应商异常 需求预测最后:
什么情况下需要人工?例如:
高金额 高风险 关键物料最终得到:
WMS Event ↓ Event Bus ↓ Filter ↓ Procurement Workflow ↓ Agent ↓ Risk Check ↓ Human Approval ↓ ERP这才是完整的FDE方案。
五十一、FDE的Event Discovery方法
做企业项目时,可以从以下几个方向发现Event。
1. 业务状态变化
订单创建 订单取消 库存不足 库存恢复 合同到期2. 系统告警
设备异常 接口失败 库存异常 支付异常3. 用户行为
客户提交投诉 员工提交申请 用户上传文档 销售创建商机4. 时间事件
每天08:00 每月1日 合同到期前30天这些实际上可以转化为:
Scheduled Event五十二、FDE Event设计Checklist
设计企业Event系统时:
□ Event是否代表已经发生的事实? □ Event是否有唯一Event ID? □ Event Type是否明确? □ Event Version是否明确? □ Timestamp是否存在? □ Tenant是否明确? □ Producer是否可信? □ Schema是否结构化? □ 是否支持Schema Evolution? □ 是否需要Event Filter? □ 是否需要Event Routing? □ 是否需要Priority? □ 是否需要Retry? □ 是否需要DLQ? □ 是否需要Replay? □ Consumer是否幂等? □ 是否需要Deduplication? □ 是否需要Event Store? □ 是否需要Audit? □ 是否需要Trace? □ 是否有权限控制? □ 是否考虑Tenant Isolation? □ 是否考虑Event Storm? □ 是否考虑Backpressure? □ 是否考虑Cost? □ 是否需要Evaluation?五十三、一个完整的Enterprise Event Architecture
最终可以形成:
Enterprise AI OS │ ┌────────────────────────┼────────────────────────┐ ↓ ↓ ↓ Control Plane Runtime Plane Governance Plane │ │ │ Event Registry Event Runtime Security Workflow Registry Workflow Runtime Policy Agent Registry Agent Runtime Audit Tool Registry Task Runtime Evaluation Model Registry Tool Runtime Cost │ │ Compliance └───────────────┬────────┴────────────────────┘ ↓ Event Bus │ ┌─────────────┼─────────────┐ ↓ ↓ ↓ ERP WMS MES │ │ │ └─────────────┼─────────────┘ ↓ Events ↓ Event Filter / Router ↓ Workflow Trigger ↓ Workflow Engine ↓ ┌──────────┼──────────┐ ↓ ↓ ↓ Agent Tool Human │ │ ↓ ↓ RAG MCP │ │ └─────┬────┘ ↓ AI Gateway ↓ Model / API / Tools五十四、从API驱动到Event驱动
传统企业系统:
User ↓ API ↓ SystemAI应用:
User ↓ Agent ↓ Tool ↓ SystemAI Workflow:
User ↓ Workflow ↓ Agent ↓ ToolEvent-driven AI:
Business Event ↓ Event Bus ↓ Workflow ↓ Agent ↓ Tool ↓ System这是一条非常重要的演进路线:
API-driven ↓ Agent-driven ↓ Workflow-driven ↓ Event-driven五十五、从“用户使用AI”到“企业运行AI”
这是本章真正想表达的变化。
早期:
用户 ↓ 问AI ↓ AI回答然后:
用户 ↓ Agent ↓ Tool ↓ 执行任务再后来:
用户 ↓ Workflow ↓ Agent ↓ 企业流程现在:
业务事件 ↓ Event Bus ↓ Workflow ↓ Agent ↓ Tool ↓ 企业系统最终:
企业不再只是“使用AI”,而是在“运行AI”。
五十六、FDE能力再次升级
到了Event-driven AI阶段,FDE需要掌握的能力继续扩展:
Software Engineering + AI Engineering + Business Process + Workflow Engineering + Event-driven Architecture + Enterprise Integration技术栈也进一步扩展:
API DB Docker Cloud Kafka RabbitMQ Event Bus Workflow Agent RAG Tool MCP LLM Observability Evaluation Security Cost Governance因此FDE正在逐渐接近:
Enterprise AI Architect
五十七、企业AI完整演进路线
到第23章,我们可以把整个教程的技术演进重新整理:
01 FDE ↓ 02 Customer Discovery ↓ 03 T-shaped Skills ↓ 04 Delivery Workflow ↓ 05 Software Engineering ↓ 06 AI Engineering ↓ 07 RAG ↓ 08 Agent ↓ 09 Tool Calling ↓ 10 Agent Project ↓ 11 Production ↓ 12 Security ↓ 13 Observability ↓ 14 Agent Platform ↓ 15 Governance ↓ 16 Cost Governance ↓ 17 Multi-Tenant ↓ 18 Agent Mesh ↓ 19 Enterprise AI OS ↓ 20 Control Plane ↓ 21 Runtime ↓ 22 Workflow Engine ↓ 23 Event Bus下一步将进入:
Event-driven Enterprise AI五十八、本章核心总结
第23章最重要的不是Kafka、RabbitMQ或者某一个消息队列产品。
真正重要的是:
企业AI需要从Request-driven逐渐走向Event-driven。
核心架构:
Business Event ↓ Event Bus ↓ Event Router ↓ Event Filter ↓ Workflow Trigger ↓ Workflow Engine ↓ Task ↓ Agent ↓ Tool / MCP ↓ Enterprise System核心职责可以总结为:
Event → 描述发生了什么 Event Bus → 负责事件传递 Workflow → 决定流程怎么运行 Agent → 负责智能判断 Tool → 负责系统操作 Human → 负责关键决策 Runtime → 负责实际执行 Governance → 负责安全、成本、审计与控制最终:
Event决定“什么时候发生”,Workflow决定“接下来怎么做”,Agent决定“如何智能处理”,Tool负责“真正执行”。
五十九、下一篇预告
《FDE前沿部署工程师实战教程》24
Enterprise AI Data Plane:数据、知识、Memory与企业上下文统一管理
前面的架构已经解决:
Model Agent Tool Workflow Event Runtime Governance但还有一个非常关键的问题:
AI到底在使用什么数据?
企业AI真正运行以后,会同时面对:
ERP数据 WMS数据 MES数据 CRM数据 OA数据 企业文档 知识库 向量数据 业务数据库 Agent Memory Conversation Event下一章将进一步进入:
Enterprise AI Data Plane重点讨论:
Enterprise Data Knowledge Vector DB Document Metadata Memory Conversation Business Context Event Data Data Permission Data Lineage Data Governance最终形成:
Enterprise AI OS │ ┌───────────────┼────────────────┐ ↓ ↓ ↓ Control Plane Runtime Plane Governance │ │ │ └───────────────┼────────────────┘ ↓ Enterprise AI Data Plane │ ┌────────────────┼────────────────┐ ↓ ↓ ↓ Business Data Knowledge Memory │ │ │ └────────────────┼────────────────┘ ↓ Agent / Workflow ↓ Enterprise Systems从这里开始,Enterprise AI将从:
“能够运行”
进一步进入:
“能够理解企业全部上下文”。
合并重复的事件架构内容修正时间线与编号一致性增加可运行的事件代码示例