实时计算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）

# 查询产品参数
实时计算 Flink 版支持哪些引擎版本？

# 生成 Flink SQL
帮我生成一个 MySQL CDC 整库同步到 Paimon 的 CDAS SQL

# Checkpoint 恢复指导
作业升级后如何从 Savepoint 恢复？需要注意什么？

# 故障排查
Checkpoint 超时可能是什么原因？如何排查？

涉及创建、部署、启停、删除等可变更操作时，Skill 自动追加 --confirm 安全确认参数；删除等不可逆操作需要在自然语言中明确表达删除意图，Skill 才会执行。