本文介绍Flink AI智能助手的功能与使用方法。
功能简介
Flink AI智能助手是基于大语言模型（LLM）构建的智能开发与运维工具，深度集成于实时计算控制台。通过自然语言交互，可以理解业务需求，协助完成SQL代码生成、作业诊断、故障排查等全流程工作。
智能助手提供以下核心能力。
能力 | 说明 |
智能问答 | 基于Flink知识库的自然语言问答，回复支持Markdown、代码块和表格渲染。 |
作业开发 | 支持SQL生成与校验、草稿创建与部署、作业启停，覆盖从草稿创建到作业运行的全流程。 |
智能诊断 | 通过 @ 引用作业等实体后，深度分析运行时指标，输出包含根因分析、修复建议和操作按钮的结构化诊断报告。 |
智能调优 | 支持基于部署作业的资源分析、应用并开启智能调优托管、配置定时调优计划。 |
技能调用 | 通过 |
自然语言驱动：使用自然语言即可完成问答、诊断和作业开发，降低实时数据开发门槛。
实体感知：支持 @ 引用工作空间中的真实实体（部署、草稿、Session集群等），诊断与分析基于实际运行数据。
诊断修复闭环：诊断报告提供可执行的修复建议，可一键跳转智能助手协助处理。
技能可扩展：内置技能覆盖作业开发与运维高频操作，支持通过技能管理页查看和管理。
使用限制
智能助手当前处于公测中，期间不会产生任何费用。
使用智能助手如果涉及创建作业草稿等开发操作，请确保具备对应的操作权限，详情请参见开发控制台授权。
AI助手的回答具有一定幻觉和时效性，可能生成语法正确但功能不存在的参数，也可能因版本迭代导致参数已废弃。辅助使用时，请结合官方文档验证参数准确性，以官方文档内容为准。
功能入口
登录实时计算控制台。
单击目标工作空间操作列下的控制台。
单击左侧导航栏的切换至 AI Native Ops，进入Flink AI Native Ops（智能运维平台）页面。
在左侧导航栏，单击新建对话，进入对话页面。
在页面底部的输入框中输入自然语言开始对话。输入框支持通过 @ 引用实体、通过 / 调用技能，也可以单击快捷问题直接发送。
首次进入显示欢迎页，展示品牌介绍、能力卡片和快捷问题。能力卡片包括智能问答、智能诊断、智能调优、作业开发等，单击卡片可切换对应的快捷问题。
左侧导航栏还提供以下入口：切换至控制台返回实时计算控制台；智能巡检进入巡检页面；技能管理查看和管理技能；历史对话查看并继续过往对话。
能力介绍
智能问答
智能问答基于Flink知识库回答产品使用、SQL语法、连接器参数等问题，回复支持Markdown、代码块和表格渲染。
在输入框中直接输入问题即可。提问时提供具体的业务背景，可以获得更有针对性的回答。
资源规划咨询
扩容或配置Flink计算资源（CU）之前，可以根据业务规模进行容量预估。提问时建议明确以下信息：
数据吞吐量：每秒处理的消息数量（TPS/QPS）或数据流量大小（MB/s）。
计算逻辑复杂度：主要操作类型，例如简单过滤、多流Join、大窗口聚合。
时效性要求：对延迟的容忍度，例如秒级延迟、分钟级延迟。
示例：
我需要从Kafka读取数据，QPS约为50,000条/秒，单条数据大小1KB。逻辑是进行字段重命名和简单过滤，然后写入Hologres。请推荐合适的并发度和CU数量。回答包含结论和依据两部分：结论部分给出推荐的并发度和CU数量，依据部分从QPS处理能力、并发度设置、外部系统瓶颈、窗口函数影响等维度进行分析。
参数查询
提问时说明连接器类型和需要实现的功能，智能助手将列出相关参数并说明作用、取值、适用场景和参考文档。
示例：
Hologres实现部分列写入，有什么参数可以实现？作业开发
作业开发能力覆盖从SQL生成到作业启停的全流程。SQL生成与校验、草稿创建与部署由 /草稿开发 技能提供，作业启停由 /作业启停运维 技能提供。在输入框中输入 / 选择对应技能，或直接使用自然语言描述需求。
生成作业SQL
向助手描述数据的输入源（Source）与输出端（Sink），指明连接器类型（如Kafka、JDBC、HBase）、字段名称和数据类型，并说明过滤、聚合、窗口、Join等处理逻辑，助手将生成包含CREATE TABLE语句和WITH参数配置的完整SQL，可直接复制到SQL编辑器使用。
示例：
请编写一个Flink SQL作业。数据源为Kafka的user_behavior topic，包含user_id和timestamp。请计算每5分钟的滚动窗口内独立用户（UV）的访问量，并将结果写入MySQL的uv_stats表。除内置技能外，Flink还提供可外部安装的Skill，可在编码工具中完成工作空间管理与作业开发，详情请参见使用 Flink Skills 管理工作空间和使用 Flink Python Coding Skill 开发作业。
草稿创建与部署
生成SQL后，可以继续通过对话完成草稿创建、SQL校验和作业部署，操作结果以卡片形式展示。可以通过以下方式触发：
生成SQL后直接描述创建与部署意图，助手沿用当前对话中的SQL继续处理。
在输入框中输入 / 选择
草稿开发技能，描述草稿创建、深度检查或部署需求。
示例：
请用上面的SQL创建草稿，名称为uv_stats_job，校验通过后部署。作业启停
作业部署完成后，可以继续通过对话启动、停止作业或调整资源。可以通过以下方式触发：
在输入框中输入 / 选择
作业启停运维技能，描述启停需求。在对话中直接使用自然语言描述，描述时明确提供目标作业的Deployment ID或Job ID。
示例
请查看Deployment ID为d-xxxx的作业是否在运行，如果在运行请停止它。启停操作会改变作业运行状态，执行前请确认目标作业与操作影响。
智能诊断
智能诊断深度分析作业运行时指标，定位问题根因，输出结构化诊断报告，包含根因分析、修复建议和操作按钮。
诊断可以通过以下方式触发：
在对话中通过 @ 引用目标作业后，使用自然语言描述问题。
在运维中心作业运维页面，失败的作业会显示AI智能诊断图标，单击即可发起诊断。
在作业日志页面右上角，单击AI智能诊断，对错误日志进行分析。
诊断完成后，针对报告中的修复建议，可以单击立即处理，跳转至对话页由智能助手协助处理。
智能调优
智能调优分析部署作业的资源使用情况，协助完成调优配置。在输入框中输入 / 选择资源调优技能，或直接使用自然语言描述调优需求。常见场景：
资源分析：了解作业资源使用情况，为调优决策提供依据。
调优托管：应用并开启智能调优托管。开启后，系统按照调优策略自动优化作业资源。
定时调优计划：配置定时调优计划，系统按计划自动执行调优。
示例：
帮我诊断Deployment ID为d-xxxx作业的扩缩容策略是否合理，并给出建议调优策略与计划配置的详细说明，请参见配置自动调优。
引用实体
在输入框中输入 @ 唤起级联选择面板，可以引用工作空间中的实体作为对话上下文。支持的实体类型包括：元数据、作业草稿、部署作业、Session集群。
选中实体后，实体以引用形式插入输入框。
也可以直接输入实体名称，系统自动识别并关联。存在同名实体时，会弹出交互确认。
技能管理
在Flink AI Native Ops页面左侧导航栏，单击技能管理。技能管理页用于管理和扩展智能助手能力，以卡片形式展示所有内置技能，卡片包含技能名称、简介和内置标识，单击卡片可查看技能详情。
内置技能说明如下。
技能 | 说明 |
草稿开发 | 查询和解读Flink作业草稿信息，覆盖草稿生命周期、深度检查、部署流程、编辑锁等知识。 |
部署管理 | 查询和解读Flink作业的部署信息，覆盖SQL、YAML、JAR、Python四种作业类型的部署配置与参数含义。 |
作业启停运维 | 操作Flink作业的运行状态与生命周期，覆盖作业状态、启动/停止策略、动态扩缩容。 |
Session集群管理 | 查询和解读Session集群信息，覆盖Session集群配置、状态、创建参数等知识。 |
作业诊断 | 深度诊断Flink作业问题，包括问题识别、根因分析和修复建议。 |
资源配置 | 查询和解读Flink作业资源配置信息，覆盖基础模式（粗粒度）和专家模式（细粒度）两种资源模式。 |
运行参数 | 查询Flink作业运行参数配置。 |
资源调优 | 查询和修改 Autopilot 自动调优配置，覆盖智能调优策略（扩缩容规则、调优上限、静默期、高级规则、开关）和定时调优计划（创建、修改、删除）。 |