Volcano Engine Serverless Flink Skill
📖 技能介紹
name: volc-flink-skill
description: 火山引擎 Flink 版統一管理技能，智慧路由到合適的子技能處理 Flink 相關問題。包括工具管理、專案配置、資源管理、連線管理、任務開發、任務運維、監控診斷等全流程功能。Use this skill as the entrypoint when the user expresses a concrete Flink intent on a concrete object, such as installing volc_flink, listing projects, inspecting catalog tables, configuring Kafka endpoints, creating SQL/JAR jobs, stopping/restarting jobs, checking logs/metrics, or diagnosing checkpoint/OOM failures. Always trigger when the request includes an action + target object in the Flink domain, rather than only generic words like "Flink" or "任務".
required_binaries:
- volc_flink
may_access_config_paths:
- ~/.volc_flink
- $VOLC_FLINK_CONFIG_DIR
credentials:
primary: volc_flink_local_config
optional_env_vars:
- VOLCENGINE_ACCESS_KEY
- VOLCENGINE_SECRET_KEY
- VOLCENGINE_REGION
火山引擎 Flink 版統一管理技能
這是 Flink 相關問題的統一入口，根據使用者的問題智慧路由到合適的子技能進行處理。
🎯 智慧路由規則
根據使用者的問題內容，自動選擇最合適的子技能：
🔧 工具管理類
觸發關鍵詞： - 安裝、更新、升級、login、logout、登入、登出、volc_flink - "安裝 volc_flink"、"更新 volc_flink"、"登入火山引擎"、"配置 volc_flink CLI"
路由到：flink-volc
🏗️ 專案與配置管理類
觸發關鍵詞： - 專案、列舉專案、檢視專案、專案詳情、設定預設專案、配置管理、TOS 路徑、切換賬號、多賬號、AK/SK、安全、認證 - "檢視專案"、"列舉專案"、"設定預設專案"、"配置 TOS 路徑"、"切換賬號"、"多賬號管理"
路由到：
- 認證/賬號相關 → flink-auth
- 專案相關 → flink-projects
- 配置相關 → flink-config
💾 資源管理類
觸發關鍵詞： - catalog、database、table、後設資料、資源池、resource pool、依賴、JAR、UDF - "檢視 catalog"、"列舉 table"、"檢視資源池"、"管理依賴"、"新增 JAR"
路由到：
- Catalog 後設資料 → flink-catalog
- 資源池 → flink-resource-pool
- 依賴管理 → flink-dependency
🔌 連線管理類
觸發關鍵詞： - 連線、conn、Kafka 連線、endpoint、bootstrap servers、消費訊息、抽樣資料、除錯 Kafka - "配置 Kafka endpoint"、"抽樣 Kafka 訊息"、"消費 10 條訊息"
路由到：flink-conn
🚀 任務開發類
觸發關鍵詞： - 建立 SQL、開發 SQL、部署 SQL、除錯 SQL、SQL 任務、SQL 開發、SQL 部署、校驗 SQL、語法檢查、validate、JAR 任務、CDC 任務、CDC YAML、Pipeline、MySQL CDC、整庫同步、分庫分表同步、模板、template、最佳實踐、常用場景、程式碼片段、快速建立 - "建立 SQL 任務"、"開發 SQL"、"部署任務"、"校驗 SQL"、"語法檢查"、"JAR 任務"、"建立 CDC 任務"、"生成 CDC YAML"、"MySQL 到 Paimon"、"MySQL 到 StarRocks"、"模板"、"最佳實踐"
路由到：
- SQL 開發部署 → flink-sql
- SQL 語法校驗 → flink-validate
- JAR 任務 → flink-jar
- CDC 任務 / CDC YAML / Pipeline 模板 → flink-cdc
- 模板/最佳實踐（只讀：輸出 flink-sql/assets/ + flink-sql/references/，不做建立/釋出）→ flink-sql
⚙️ 任務運維類
觸發關鍵詞： - 啟動、停止、重啟、擴容、縮容、修改配置、更新引數、SRE、運維、快照、savepoint、批處理、batch - "啟動任務"、"停止任務"、"重啟任務"、"擴容"、"縮容"、"建立快照"、"恢復快照"、"批處理任務"
路由到：
- 運維操作 → flink-sre
- 快照管理 → flink-savepoint
- 批處理任務 → flink-batch
📊 任務監控與診斷類
觸發關鍵詞： - 故障、錯誤、異常、診斷、troubleshoot、diagnose、OOM、checkpoint、效能最佳化、反壓、backpressure、監控、monitor、指標、metrics、日誌、logs - "任務報錯了"、"診斷一下"、"效能最佳化"、"檢視監控"、"檢視日誌"、"檢視指標"
路由到：
- 即時監控 → flink-monitor
- 故障診斷 → flink-diagnostic
- 效能最佳化 → flink-performance
⚠️ 路由衝突表
| 衝突場景 | 優先路由到 | 判斷規則 |
|---|---|---|
| 登入/安裝/升級 CLI vs 預設專案/TOS 路徑配置 | flink-volc / flink-config |
如果動作是安裝、升級、登入、退出、檢視 CLI 版本，走 flink-volc；如果動作是設定預設專案、檢視配置、設定 TOS 路徑，走 flink-config |
| 檢視日誌/指標/事件 vs 深入排障 | flink-monitor / flink-diagnostic |
如果動作是檢視、監控、查詢日誌/事件/指標，走 flink-monitor；如果動作是分析錯誤原因、定位根因、排查失敗/OOM/checkpoint timeout，走 flink-diagnostic |
| 效能最佳化 vs 故障診斷 | flink-performance / flink-diagnostic |
如果動作是調優並行度、記憶體、checkpoint、反壓，走 flink-performance；如果動作是解釋失敗原因或故障歸因，走 flink-diagnostic |
| 生成模板/示例 SQL vs 建立/更新真實任務 | flink-sql |
兩類都走 flink-sql：如果只是要模板/示例/最佳實踐，則只讀輸出 flink-sql/assets/ + flink-sql/references/；如果是建立/修改/釋出/除錯真實任務，則按 COMMON_MUTATION.md 執行變更流程 |
| SQL 校驗 vs SQL 開發部署 | flink-validate / flink-sql |
如果動作是校驗語法、預釋出檢查，走 flink-validate；如果動作是建立、更新、釋出、啟動任務，走 flink-sql |
| CDC YAML / CDC 草稿任務 vs SQL/JAR 任務 | flink-cdc / flink-sql / flink-jar |
如果使用者目標是 CDC pipeline YAML、--type cdc、MySQL->Paimon/StarRocks/Doris/Kafka/ByteHouse CDW 同步，走 flink-cdc；SQL/JAR 仍分別走 flink-sql / flink-jar |
| Kafka 連線配置/消費除錯 vs Kafka SQL 模板 | flink-conn / flink-sql |
如果動作是配置 Instance/Endpoint、消費訊息、抽樣資料，走 flink-conn；如果動作是生成 Kafka Source/Sink SQL 模板，走 flink-sql（只讀模板輸出） |
| 任務啟停/擴縮容/改引數 vs 快照恢復/刪除 | flink-sre / flink-savepoint |
如果動作是 stop/restart/rescale/update params，走 flink-sre；如果動作是建立、查詢、恢復、刪除快照，走 flink-savepoint |
🔀 路由決策流程
步驟 1：問題分類
根據使用者的問題，先判斷屬於哪個大類： 1. 🔧 工具管理 2. 🏗️ 專案與配置管理 3. 💾 資源管理 4. 🔌 連線管理 5. 🚀 任務開發 6. ⚙️ 任務運維 7. 📊 任務監控與診斷
步驟 2：子技能選擇
在確定的大類中，根據具體關鍵詞選擇最合適的子技能。
步驟 3：執行路由
呼叫對應的子技能處理使用者的問題。
🤝 多技能協作
有些問題可能需要多個技能協作：
示例 1：SQL 任務完整開發流程
flink-volc- 確認登入狀態flink-projects- 選擇專案flink-catalog- 檢視庫表結構flink-sql- 建立和部署 SQL 任務flink-validate- 釋出前校驗flink-monitor- 監控任務執行
示例 2：故障診斷流程
flink-monitor- 檢視任務狀態和日誌flink-diagnostic- 深入診斷問題flink-performance- 如需效能最佳化flink-sre- 如需運維操作
📋 技能清單
🔧 volc_flink 工具管理（1/1）✅
- ✅ flink-volc - 安裝、更新、登入、配置工具
🏗️ 專案與配置管理（3/3）✅
- ✅ flink-auth - 登入/登出、多賬號管理、AK/SK 安全管理
- ✅ flink-config - 配置管理、預設專案設定、TOS 路徑配置
- ✅ flink-projects - 專案列舉、專案詳情、專案切換
💾 資源管理（3/3）✅
- ✅ flink-resource-pool - 資源池列舉、詳情、建立
- ✅ flink-catalog - Catalog、Database、Table 後設資料管理
- ✅ flink-dependency - JAR 包依賴管理、UDF 庫管理
🔌 連線管理（1/1）✅
- ✅ flink-conn - Kafka 等上下游連線管理，支援接入點配置與訊息消費除錯
🚀 任務開發（4/4）✅
- ✅ flink-sql - SQL 任務建立、開發、部署、除錯
- ✅ flink-validate - SQL 語法校驗、預釋出驗證
- ✅ flink-jar - JAR 任務建立、部署、除錯
- ✅ flink-cdc - CDC YAML 任務建立、模板生成、釋出、除錯
⚙️ 任務運維（3/3）✅
- ✅ flink-sre - 啟動、停止、重啟、擴容、縮容、配置修改
- ✅ flink-savepoint - 快照建立、查詢、恢復、刪除
- ✅ flink-batch - 批處理任務管理、排程、歷史記錄
📊 任務監控與診斷（3/3）✅
- ✅ flink-monitor - 即時監控、指標查詢、事件、日誌
小蔥技能站7w4.net發現了升級外掛。
- ✅ flink-diagnostic - 故障診斷、異常分析、根因定位
- ✅ flink-performance - 效能最佳化、反壓檢測、Checkpoint 最佳化
💡 使用建議
首次使用
如果使用者是第一次使用 Flink 相關功能：
1. 先檢查是否需要安裝和登入（flink-volc）
2. 檢視可用專案（flink-projects）
3. 根據具體需求路由到對應技能
問題不明確
如果使用者的問題比較模糊，無法明確分類： 1. 詢問使用者更具體的需求 2. 或者提供一個技能列表供使用者選擇
複雜問題
如果使用者的問題涉及多個方面： 1. 分析問題的主要方面 2. 先路由到主要技能 3. 根據需要引導使用其他協作技能
📚 相關文件
詳細的技能說明請參考各子技能的 SKILL.md 檔案，以及外掛總覽文件：
skills/flink-volc/README.md
這是 Flink 技能的統一入口，智慧路由到合適的子技能處理使用者的問題！
🤖 AI 評測
這個 Skill 質量優秀，覆蓋了火山引擎 Flink 的完整功能，從安裝工具到任務診斷都能支援。路由機制智慧，能自動判斷問題型別並分發給合適的處理模組。安全規範做得好，不會洩露金鑰等敏感資訊。操作前會要求確認，降低誤操作風險。不過路由規則有點複雜，普通使用者可能不容易理解其分類邏輯。總體來說，這是一個功能全面、安全可靠、流程規範的 Skill，適合需要管理火山引擎 Flink 任務的開發者使用。
