Realtime Compute for Apache Flink：使用 Flink Skills 管理工作空間

安裝 Node.js 與 Python 運行環境

Skill 通過 npx skills CLI 安裝，運行依賴 Node.js 18 及以上版本；Skill 內部指令碼基於 Python 實現，需 Python 3.6 及以上版本。

node --version    # 需要 ≥ 18
python3 --version # 需要 ≥ 3.6

未安裝時按系統選擇安裝方式：

# macOS
brew install node python@3.9

# Ubuntu/Debian
sudo apt-get install nodejs npm python3 python3-pip

# CentOS/RHEL
sudo yum install nodejs python3 python3-pip

配置阿里雲訪問憑據

Skill 通過預設憑據鏈擷取阿里雲 AccessKey，推薦使用環境變數方式注入，避免憑據明文寫入命令列或指令碼。

export ALIBABA_CLOUD_ACCESS_KEY_ID="your-access-key-id"
export ALIBABA_CLOUD_ACCESS_KEY_SECRET="your-access-key-secret"
export ALIBABA_CLOUD_REGION_ID="cn-beijing"

生產環境推薦使用 RAM 角色或 STS 臨時憑據，避免長期 AccessKey 外泄。

準備 RAM 許可權

為 Skill 使用的 RAM 使用者授予對應的最小權限原則，避免直接使用阿里雲帳號 AccessKey。

alibabacloud-flink-instance-manage 要求的權限

{
  "Version": "1",
  "Statement": [
    {
      "Effect": "Allow",
      "Action": [
        "stream:CreateVvpInstance",
        "stream:DescribeVvpInstances",
        "stream:CreateVvpNamespace",
        "stream:DescribeVvpNamespaces",
        "stream:QueryTagVvpResources"
      ],
      "Resource": [
        "acs:stream:*:*:vvpinstance/*",
        "acs:stream:*:*:vvpinstance/*/vvpnamespace/*"
      ]
    }
  ]
}

alibabacloud-flink-workspace-ops 要求的權限

涉及作業部署、Session Cluster、SQL 校正等專案空間級操作，需通過控制台的成員管理為 RAM 使用者授予對應專案空間的開發人員或管理員角色。具體角色許可權參見開發控制台授權。

安裝 Skill

# 安裝到當前專案（推薦用於專案級共用）
npx skills add aliyun/alibabacloud-aiops-skills --skill alibabacloud-flink-instance-manage --agent claude-code -y --full-depth
npx skills add aliyun/alibabacloud-aiops-skills --skill alibabacloud-flink-workspace-ops --agent claude-code -y --full-depth
npx skills add aliyun/alibabacloud-aiops-skills --skill alibabacloud-flink-knowledge --agent claude-code -y --full-depth

# 或安裝到全域（追加 -g 參數，所有專案可用）
npx skills add aliyun/alibabacloud-aiops-skills --skill alibabacloud-flink-instance-manage --agent claude-code -y --full-depth -g

專案級安裝路徑為 <project>/.claude/skills/，全域安裝路徑為 ~/.claude/skills/。

若 npx skills add 因網路原因複製倉庫逾時，可先手動複製倉庫，再用本地路徑安裝：

git clone https://github.com/aliyun/alibabacloud-aiops-skills.git ~/.agents/alibabacloud-aiops-skills
npx skills add ~/.agents/alibabacloud-aiops-skills/skills/analyticscomputing/sc/alibabacloud-flink-instance-manage --agent claude-code -y
npx skills add ~/.agents/alibabacloud-aiops-skills/skills/analyticscomputing/sc/alibabacloud-flink-workspace-ops --agent claude-code -y
npx skills add ~/.agents/alibabacloud-aiops-skills/skills/analyticscomputing/sc/alibabacloud-flink-knowledge --agent claude-code -y

安裝 Skill 的 Python 依賴

cd .claude/skills/alibabacloud-flink-instance-manage
pip3 install -r assets/requirements.txt

cd ../alibabacloud-flink-workspace-ops
pip3 install -r assets/requirements.txt

macOS 上若 pip 報 PEP 668 錯誤，可使用虛擬環境或追加 --break-system-packages 參數。

驗證安裝

重啟 Claude Code 後查看可用 Skill 列表，確認三款 Flink Skill 已被識別。

/skills

輸出中應包含 alibabacloud-flink-instance-manage、alibabacloud-flink-workspace-ops 與 alibabacloud-flink-knowledge。

使用樣本

直接在對話中以自然語言描述意圖，Claude Code 自動匹配對應 Skill 並執行操作。

執行個體管理情境（alibabacloud-flink-instance-manage）

# 查詢華北 2 地區下的所有 Flink 執行個體
查詢 cn-beijing 的 Flink 執行個體

# 建立 Flink 執行個體
在 cn-beijing 建立一個 Flink 執行個體，名稱為 demo-vvp

# 查詢可用性區域
查詢 cn-hangzhou 地區支援哪些可用性區域

工作空間營運情境（alibabacloud-flink-workspace-ops）

# 建立 SQL 草稿
在工作空間 my-workspace 中建立一個名為 hello-flink 的 SQL 草稿，內容是 SELECT 1

# 部署並啟動作業
把剛才建立的草稿部署上線並啟動作業

# 診斷作業
幫我診斷一下工作空間 my-workspace 裡最近失敗的作業

# 管理 Session Cluster
在工作空間 my-workspace 中建立一個名為 dev-cluster 的 Session Cluster

知識問答情境（alibabacloud-flink-knowledge）

# 查詢產品參數
Realtime Compute Flink 版支援哪些引擎版本？

# 產生 Flink SQL
幫我產生一個 MySQL CDC 整庫同步到 Paimon 的 CDAS SQL

# Checkpoint 恢複指導
作業升級後如何從 Savepoint 恢複？需要注意什嗎？

# 故障排查
Checkpoint 逾時可能是什麼原因？如何排查？

涉及建立、部署、啟停、刪除等可變更操作時，Skill 自動追加 --confirm 安全確認參數；刪除等無法復原操作需要在自然語言中明確表達刪除意圖，Skill 才會執行。