Realtime Compute for Apache Flink:Gérer les espaces de travail avec Flink Skills

Présentation des Skills

Realtime Compute for Apache Flink met à disposition trois Agent Skills sur Alibaba Cloud Skill Hub. Ces Skills couvrent trois catégories de scénarios à haute fréquence : la gestion du cycle de vie des instances, les opérations sur les espaces de travail et l'expertise Flink. Une fois intégrés, ils vous permettent de créer, interroger, déployer, opérer et déboguer les ressources Flink via le langage naturel dans les clients prenant en charge le protocole Agent Skills, tels que Claude Code, OpenClaw, Qoder, Cursor et Gemini CLI. Aucun appel manuel aux API ou opération via la console n'est requis.

Ces trois Skills appellent directement l'API Flink via le SDK Python officiel d'Alibaba Cloud. Par défaut, les identifiants sont chargés grâce à la chaîne de fournisseurs d'identifiants par défaut. Les identifiants ne sont jamais transmis en tant qu'arguments de ligne de commande.

Prérequis

node --version    # Requires >= 18
python3 --version # Requires >= 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

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"

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

Installer et utiliser les Skills dans Claude Code

# Install to the current project (recommended for project-level sharing)
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

# Or install globally (append -g for all projects)
npx skills add aliyun/alibabacloud-aiops-skills --skill alibabacloud-flink-instance-manage --agent claude-code -y --full-depth -g

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

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

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

/skills

# Query all Flink instances in the China (Beijing) region
Query my Flink instances in cn-beijing

# Create a Flink instance
Create a Flink instance named demo-vvp in cn-beijing

# Query available zones
Which zones are available in cn-hangzhou?

# Create a SQL draft
Create a SQL draft named hello-flink in workspace my-workspace with the content SELECT 1

# Deploy and start a job
Deploy the draft I just created and start the job

# Diagnose a job
Diagnose the recently failed job in workspace my-workspace

# Manage Session Clusters
Create a Session Cluster named dev-cluster in workspace my-workspace

# Query product parameters
What engine versions does Realtime Compute for Apache Flink support?

# Generate Flink SQL
Generate a CDAS SQL statement for full-database sync from MySQL CDC to Paimon

# Checkpoint restore guidance
How do I restore a job from a savepoint after an upgrade? What should I be aware of?

# Troubleshooting
What could cause a checkpoint timeout? How do I troubleshoot it?

FAQ

Q1 : Le Skill ne prend pas effet après l'installation

Vérifiez que le répertoire du Skill a bien été créé (le fichier .claude/skills/alibabacloud-flink-instance-manage/SKILL.md existe) et que le client a été redémarré pour charger les Skills.

Q2 : Erreur ModuleNotFoundError lors de l'exécution d'une commande

Les dépendances Python ne sont pas installées. Accédez au répertoire du Skill et exécutez pip3 install -r assets/requirements.txt.

Q3 : Erreur NoPermission ou Forbidden lors de l'exécution d'une commande

Vérifiez si l'utilisateur RAM dispose de la stratégie de permissions minimale indiquée dans les prérequis, et si la chaîne de fournisseurs d'identifiants par défaut charge bien l'AccessKey correct pour cet utilisateur RAM.

Q4 : Le statut de l'instance ne passe pas à RUNNING après la création

Le Skill interroge le statut par intervalles de 30 secondes, avec un temps d'attente maximal de 10 minutes. En cas de dépassement du délai, vérifiez manuellement le statut de l'instance dans la console. Si les ressources sont insuffisantes, augmentez-les dans la console avant de réessayer.

Q5 : Puis-je soumettre des jobs JAR Flink via les Skills ?

Non. Les Skills couvrent actuellement uniquement le cycle de vie complet des jobs SQL au sein des espaces de travail. La soumission et le déploiement des jobs JAR doivent être effectués via la console ou en utilisant l'API.

Q6 : Les informations de paramètres renvoyées par Knowledge Skill sont-elles toujours exactes et à jour ?

Knowledge Skill récupère les dernières informations de paramètres depuis la documentation en ligne chaque fois que possible. Si la récupération de la documentation échoue, le Skill renvoie un avis de sécurité et vous oriente vers la console pour vérification. Pour les paramètres critiques tels que la facturation et les versions du moteur, l'affichage réel dans la console fait foi.

Q7 : Quels types de Flink SQL Knowledge Skill peut-il générer ?

Le Skill prend en charge la génération d'instructions DDL, d'instructions de synchronisation CDC de base de données complète (syntaxe CDAS) et de SQL de surveillance pour le contrôle des risques. Le SQL généré inclut des annotations -- TODO: pour indiquer les informations de connexion que vous devez remplacer par des valeurs réelles.