Realtime Compute for Apache Flink:Gunakan Flink Skills untuk mengelola ruang kerja

Instal Node.js dan Python

Skill diinstal melalui CLI npx skills, yang memerlukan Node.js 18 atau versi lebih baru. Skrip internal diimplementasikan dalam Python dan memerlukan Python 3.6 atau versi lebih baru.

node --version    # Requires >= 18
python3 --version # Requires >= 3.6

Jika belum diinstal, pilih metode instalasi sesuai sistem operasi Anda:

# 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

Konfigurasikan kredensial Alibaba Cloud

Skill memperoleh kredensial AccessKey Alibaba Cloud melalui default credentials provider chain. Kami menyarankan Anda menggunakan variabel lingkungan untuk menyuntikkan kredensial guna menghindari hardcoding kredensial di command line atau skrip.

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"

Untuk lingkungan produksi, kami menyarankan penggunaan peran RAM atau kredensial sementara STS untuk mencegah kebocoran AccessKey jangka panjang.

Siapkan izin RAM

Berikan izin minimum yang diperlukan kepada Pengguna RAM yang digunakan oleh Skill. Jangan gunakan AccessKey Akun Alibaba Cloud Anda secara langsung.

Izin yang diperlukan oleh 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/*"
      ]
    }
  ]
}

Izin yang diperlukan oleh alibabacloud-flink-workspace-ops

Operasi tingkat ruang kerja seperti penerapan pekerjaan, manajemen Session Cluster, dan validasi SQL mengharuskan Anda memberikan peran developer atau administrator kepada Pengguna RAM untuk ruang kerja yang sesuai melalui manajemen anggota Konsol. Untuk informasi lebih lanjut tentang izin peran, lihat Manage workspace members.

Instal Skill

# 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

Jalur instalasi tingkat proyek: <project>/.claude/skills/. Jalur instalasi global: ~/.claude/skills/.

Jika npx skills add mengalami timeout karena masalah jaringan saat mengkloning repositori, Anda dapat mengkloning repositori secara manual dan menginstal dari jalur lokal:

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

Instal dependensi Python untuk Skill

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

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

Jika pip melaporkan error PEP 668 di macOS, gunakan virtual environment atau tambahkan parameter --break-system-packages.

Verifikasi instalasi

Mulai ulang Claude Code dan periksa daftar Skill yang tersedia untuk memastikan ketiga Flink Skills telah dikenali.

/skills

Output harus mencakup alibabacloud-flink-instance-manage, alibabacloud-flink-workspace-ops, dan alibabacloud-flink-knowledge.

Contoh penggunaan

Jelaskan maksud Anda dalam bahasa alami langsung di percakapan. Claude Code secara otomatis mencocokkan Skill yang sesuai dan menjalankan operasi tersebut.

Manajemen instans (alibabacloud-flink-instance-manage)

# Query all Flink instances in the China (Beijing) region
Kueri semua instans Flink saya di cn-beijing

# Create a Flink instance
Buat instans Flink bernama demo-vvp di cn-beijing

# Query available zones
Zona mana saja yang tersedia di cn-hangzhou?

Operasi ruang kerja (alibabacloud-flink-workspace-ops)

# Create a SQL draft
Buat draft SQL bernama hello-flink di ruang kerja my-workspace dengan konten SELECT 1

# Deploy and start a job
Terapkan draft yang baru saja saya buat dan mulai pekerjaannya

# Diagnose a job
Diagnosa pekerjaan yang baru saja gagal di ruang kerja my-workspace

# Manage Session Clusters
Buat Session Cluster bernama dev-cluster di ruang kerja my-workspace

Kueri pengetahuan (alibabacloud-flink-knowledge)

# Query product parameters
Versi engine apa saja yang didukung oleh Realtime Compute for Apache Flink?

# Generate Flink SQL
Hasilkan pernyataan SQL CDAS untuk sinkronisasi seluruh database dari MySQL CDC ke Paimon

# Checkpoint restore guidance
Bagaimana cara memulihkan pekerjaan dari titik simpan setelah peningkatan? Hal apa saja yang perlu saya perhatikan?

# Troubleshooting
Apa penyebab timeout checkpoint? Bagaimana cara melakukan troubleshooting-nya?

Untuk operasi yang memodifikasi resource—seperti pembuatan, penerapan, memulai, menghentikan, dan penghapusan—Skill secara otomatis menambahkan parameter konfirmasi keamanan --confirm. Untuk operasi yang tidak dapat dikembalikan seperti penghapusan, Anda harus secara eksplisit menyatakan maksud penghapusan dalam bahasa alami sebelum Skill menjalankan operasi tersebut.