【FFA 2026】平台AI实践 数据驱动下的AI Agent 代码理解实战 AI Agent、静态分析与知识图谱如何为复杂代码仓库建立可靠上下文

数据驱动下的AIAgent代码理解实战AIAgent、静态分析与知识图谱如何为复杂代码仓库建立可靠上下文YuxiangYuxiangLinUnderstandAnythingcreator/maintainer这不是“让AI读代码”UnderstandAnything的设计也不知道文件之间的真实关系。调用、配置、数据流和模块边界背景：为什么代码理解是AI开发工具的关键问题复杂仓库里，生成代码之前先要拿到正确上下文大模型的能力边界代码理解层的价值结构化文件、函数、类、模块、配置可复用节点解释和分析结果UnderstandAnything的整体设计思路把代码仓库转化为可检索、可浏览、可复用的结构化知识层UnderstandAnything的核心目标不是画一张“复杂但好看”的图，而是把仓库整理成一层人和Agent都能使用的项目知识。这层知识由三类信息组成：代码对象、关系边和解释信息。静态分析负责稳定抽取结构，LLM负责补充可读解释，知识图谱从代码仓库到知识图谱：核心架构与数据流解析与抽取建图与持久化沿调用、依赖、配置和领域关系把解释落回源码、测试、配置交互式代码理解体验设计从全局进入先看全局结构再追一条主链路实战二：依赖追踪与业务逻辑理解业务逻辑通常分布在入口、状态、配置、异常路径和测试中依赖追踪业务理解Agent稳定性真实案例与开源反馈从onboarding、依赖追踪到AIcoding前置上下文典型使用场景迭代方向总结与展望：AIAgent开发工具的下一步从“让AI写代码”走向“让AI真正理解项目”代码理解层会成为未来AIIDE、开发者工具和自动化软件工程的重要基础设施。Anything尝试提供的就是这样一层项目上下文基础设施。AIAgent不是来取代人的而是帮助大家更好地工作我们的理念是：AIAgent并不是来取代人的，而是帮助大家更好地工作。它应该减少重复找上下文、重复解释项目结构、重复确认影响面的成本，让工程师把时间花在判断、设计、验证和负责上。后续UnderstandAnything项目会由Egonex-AI和我共同维护。AIAgent不是来取代人的而是帮助大家更好地工作我们的理念是：AIAgent并不是来取代人的，而是帮助大家更好地工作。它应该减少重复找上下文、重复解释项目结构、重复确认影响面的成本，让工程师把时间花在判断、设计、验证和负责上。后续UnderstandAnything项目会由Egonex-AI和我共同维护。AIAgent不是来取代人的而是帮助大家更好地工作我们的理念是：AIAgent并不是来取代人的，而是帮助大家更好地工作。它应该减少重复找上下文、重复解释项目结构、重复确认影响面的成本，让工程师把时间花在判断、设计、验证和负责上。后续UnderstandAnything项目会由Egonex-AI和我共同维护。Flink生态与Python生态的鸿沟PyFlink在腾讯内部的产品化和应用实践PyFlink产品与内核迭代路线背景与现状腾讯AI实时计算业务的现状PythononFlink常见场景与痛点广告实时特征广告实时特征实时推理实时推理开发效率低运维成本高实时训练运维成本高实时训练连接PythonAI生态和Flink实时计算生态的桥梁Pandas/NumpyTriton/vLLMFlinkPythonAPI支持进程/线程双模式支持PythonUDFPythonAPIPythonCSE优化Python算子指标监控Notebook交互式开发算PyFlink是解决业务痛点的钥匙实时平台产品化实时平台产品化业务案例Python原生支持可观测性性能优化引入PyFlink打通实时AI计算链路广告特征生产实时推理广告特征生产实时推理CV/Torch推理+实时特征异步调用LLM/Embedding入库在线样本拼接入库训练业务场景层OceanusPyFlink核心能力层原生的PythonAPI统一的PythonUDF•Python算子级监控•Python进程资源监控Notebook提交入口•Python和PyFlink混编Python代码提交入口•统一Python依赖管理PythonSDK状态管理K8s/Yarn资源调度Connector生态流批一体res=env.execute_sql(“selectdet(f1)fromres=env.execute_sql(“selectdet(f1)froms1”)res.print_notebook()•pythonrequirements依赖项配置•jupyterkernel资源配置Session模式提交env.execute()PythonSDKenv.execute_sql(“insertintot1•requirements文件Per-Job模式提交•Python文件包依赖包上传•requirements文件下载•Python依赖安装•Checkpoint配置•Python环境构建•StreamGraph生成Python代码入口Notebook代码提交入口selectdet(f1)froms1”)Notebook交互式开发调试上下文连贯数据探索上下文连贯数据探索即时响应交互式AI即时响应迭代闭环迭代闭环Notebook交互式开发调试Notebook前端Python代码PyFlink代码Markdown文本Notebook后端NotebookkernelFlinkSession集群TaskManagersOperatorPodTaskManagersTMPodTMPod2kenel1kenelkenel2kernel注册JobManagerPod富文本编辑和内容展示代码内容转发和结果推送•Python代码和PyFlink代码执行•kernel内部代码上下文共享进程模式vs线程模式•Java和Python共线程•仅支持CPython解释器JavaOperatorPython/CAPICPythonUDFJavaOperatorPythonworker•Java和Python独立进程，不受•资源隔离，Python进程崩溃不影Python算子可观测性JavaOperatorPython(Worker进程)inputdatainputdataAbstractPythonFunctionOperatorprocessElement()①Java序列化encodeTimeMsencodeBytesBeamPythonFunctionRunner②Bundle累积bundleCountprocessTimeMs•threadCount•gc.collectionGen0/Gen1/Gen2executionTimeMsinvocations③Python解码decodeTimeMsdecodeCount⑤Python编码encodeTimeMsencodeCount•cpuPercent•memoryRssBytesState访问getTimeMsputTimeMsPython进程监控BeamHandlerPython算子公共子表达式消除（CSE）优化INSERTINTOSinkTableSEINSERTINTOSinkTableSE优化前Det(s)Det(s)Det(s)Det(s)UDF执行3次内层PythonCalc内层PythonCalc算子计算Det(s)结果，并记外层PythonCalcRefReuse算子Det(s)结果按照index表重Det(s)Det(s)Det(s)Det(s)去重后仅执行1次PythonIndex={0,0,0}PyFlink在广告实时特征场景落地PythonUDFPythonUDFPythonUDF原生PythonUDF原生PythonFlink2.x+PyFlinkFlinkFlink