【FFA 2026】AI Agent Apache Flink Fluss Gateway 构建Agent 实时数据层：Fluss Gateway 的设计、实践与演进（探索）

构建Agent实时数据层:FlussGateway的设计、实践与演进(探索)王俊博ApacheFlussContributorAgent为什么需要实时上下文核心设计Agent实时上下文背景:Agent为什么需要实时上下文Before:PoorContextBefore:PoorContext推测:直接大模型调用依据:静态知识/用户描述结果:泛化结果知识问答.客服:发货能走什么快递?.员工:出差报销标准?补贴怎么算?.工程师:设备出现xx现象是什么问题?After:RealContextAfter:RealContext实时上下文:现在发生了什么?依据:最新状态/日志/配置结果:高质量回答和下一步动作真实业务场景.风控:这条告警为什么触发?.客服/客户:退款为什么不到账?.开发:这条数据为什么不对?Agent从Γ知道什么」到Γ确认现在,并决定下一步动作」Agent实时上下文的问题MysqlMysqlMysqlMysqlkafkaMongoDBkafkaMongoDBRedisRedis直连业务系统无法查询数据新鲜度不够当前Agent实时上下文的痛点?数据未清洗扩展,难理解数据新鲜度低,数据未清洗扩展,难理解Agent拿到就已失效权限和访问控制复杂权限和访问控制复杂系统运维成本高、可维护性差证据链不完整,结果难解释、难审计,证据链不完整,结果难解释、难审计,Agent难以稳定进入生产场景理想的实时上下文底座需要什么?Point/PrefixLookup((查询实体当前状态,快速定位追溯历史事件与变化轨迹统一查询视图统一查询视图统一查询入口CurrentState+EventEvidence+QuerypathFlussArchitecture业务事件:订单/支付/退款/物流/工单CurrentContextViewQueryableQEvidenceCurrentContextViewStateChanges状态变化:配置/部署/服务状态/实例状态Observability观测数据:log/metrics/trace/alertObservability观测数据:log/metrics/trace/alert语言:语言:非Java协议:不支持写入:仅Flink/Spark/JavaFluss核心能力点查/前缀点查外部生态AgentFluss已具备实时上下文底层能力,但外部生态缺乏统一交互层!Gateway面向Agent的实时上下文查询入口与多协议数据接入Agent点查/前缀点查Agent点查/前缀点查ObservabilityDatafusionGatewayDatafusionGatewayGateway两条核心路径Query/ExplorationFlussFlussDatafusionDatafusionPath2:Ingestion/CollectionFlussFlussSQLPath+IngestionSQLPath+IngestionPath共享FlussRust底座Gateway核心优势统一多协议入口共享FlussRust统一多协议入口共享FlussRust底座IngestionPath解耦Agent实时上下文AgentRealtimeContextEngineAgent客户在线咨询Agent客户在线咨询GatewayGateway订单表支付事件表退款记录表民工单表用户信息表…昨天申请的退款为什么显示订单已取消,但是退款没到账?ContextBundle订单状态退款状态支付状态昨天申请的退款为什么显示订单已取消,但是退款没到账?ContextBundle订单状态退款状态支付状态用户身份信息输入上下文+实时上下文=>Agent决策和动作AgentRealtimeContextEngineDemoOpenclaw:Agent风控Demo与实践OpenClawFluss-hookOpenClawFluss-hook.无侵入嵌入Agent运行时.采集全生命周期节点事件.内部行为转为结构化事件流.高性能RESTGateway.端到端延迟秒级钉钉IM告警→高危风险输出至钉钉,实现秒级告警..AIfunction调用大模型进行语义级风险研Gateway的生态位、演进方向与社区进展EcosystemRole.Fluss数据接入.RealtimeContextEngi