Ekstensi Realtime Compute for Apache Flink VS Code menyederhanakan proses pengembangan pekerjaan Flink secara lokal. Ekstensi ini memungkinkan Anda mengembangkan, menerapkan, dan mengelola pekerjaan SQL, JAR, dan Python, serta menyinkronkan konfigurasi pekerjaan dari cloud. Topik ini menjelaskan cara menggunakan ekstensi tersebut.
Prasyarat
-
Anda telah mengaktifkan Realtime Compute for Apache Flink.
-
Anda memiliki ID AccessKey dan Secret AccessKey. AccessKey tersebut harus memiliki izin yang diperlukan untuk namespace target. Untuk informasi selengkapnya, lihat Bagaimana cara memperoleh ID AccessKey dan Secret AccessKey? dan Memberikan izin di Konsol Pengembangan.
-
Anda telah menginstal VS Code v1.74.0 atau versi yang lebih baru. Jika belum, unduh dari website resmi VS Code.
Batasan
-
Konfigurasi log tidak didukung.
-
Ekstensi ini tidak mendukung penarikan pekerjaan yang sudah ada dari cloud.
Instal dan konfigurasikan ekstensi
-
Unduh dan instal ekstensi.
-
Metode 1: Buka VS Code Marketplace, lalu klik Install.
-
Metode 2:
-
Buka VS Code dan klik EXTENSIONS di panel navigasi sebelah kiri.
-
Di bilah pencarian, cari ekstensi Flink Realtime Compute Studio.
-
Klik Install.
-
-
-
Pada bilah menu atas, klik , lalu pilih folder lokal.
-
Konfigurasikan Informasi AccessKey Anda.
Ruang kerja saat ini
-
Di panel navigasi sebelah kiri, klik ikon
. Di bagian Configure AK&SK, klik Configure in a .vvprc file. Ekstensi secara otomatis membuat file dengan ekstensi .vvprc. -
Tambahkan konfigurasi berikut ke dalam file tersebut:
{ "accessKey": "xxx", "secretKey": "xxx", "namespace": "xxx", "workspace": "xxx", "regionId" : "xxx" }Parameter
Deskripsi
Catatan
accessKey
ID AccessKey akun Alibaba Cloud Anda.
Untuk informasi selengkapnya, lihat Bagaimana cara memperoleh ID AccessKey dan Secret AccessKey?
secretKey
Secret AccessKey akun Alibaba Cloud Anda.
namespace
Nama namespace Flink.
Untuk informasi selengkapnya, lihat Melihat dan menghapus namespace.
workspace
ID ruang kerja Flink.
Untuk informasi selengkapnya, lihat Bagaimana cara melihat ID ruang kerja dan informasi lainnya?.
regionId
ID wilayah.
Temukan ID wilayah di Endpoints.
Global
-
Di panel navigasi sebelah kiri, klik ikon
. -
Di bagian Configure AK&SK, klik Configure in global user settings. VS Code membuka halaman pengaturan global.
Cari
flinkStudiodan atur bidang-bidang berikut: Flink Studio: Access Key, Flink Studio: Secret Key, Flink Studio: Namespace, Flink Studio: Region ID (default: cn-hangzhou), dan Flink Studio: Workspace. -
Jika diperlukan, pilih User atau Workspace untuk konfigurasi.
CatatanKami menyarankan mengatur cakupan ke User, yang menerapkan konfigurasi ke semua proyek. Cakupan Workspace hanya menerapkan konfigurasi ke ruang kerja saat ini.
Parameter
Deskripsi
Catatan
Access Key
ID AccessKey akun Alibaba Cloud Anda.
Untuk informasi selengkapnya, lihat Bagaimana cara memperoleh ID AccessKey dan Secret AccessKey?
Secret Key
Secret AccessKey akun Alibaba Cloud Anda.
Untuk informasi selengkapnya, lihat Bagaimana cara memperoleh ID AccessKey dan Secret AccessKey?
Namespace
Nama namespace Flink.
Untuk informasi selengkapnya, lihat Melihat dan menghapus namespace.
Workspace
ID ruang kerja Flink.
Untuk informasi selengkapnya, lihat Bagaimana cara melihat ID ruang kerja dan informasi lainnya?.
Region ID
ID wilayah.
Temukan ID wilayah di Endpoints.
CatatanPrioritas konfigurasi: Folder saat ini > Folder induk > Global.
Setelah Anda menerapkan konfigurasi, nama namespace akan muncul di bilah status di bagian bawah editor.
-
-
(Opsional) Anda dapat menginstal ekstensi berikut untuk pengalaman pengembangan yang lebih baik.
-
Flink SQL: Instal ekstensi Flink SQL Language Features. Ekstensi ini menyediakan layanan bahasa untuk Flink SQL dan mendukung sintaks Flink SQL lengkap.
-
Konfigurasi Flink: Kami menyarankan menginstal ekstensi YAML VS Code, yang menyediakan pelengkapan otomatis untuk konfigurasi Flink.
-
Prosedur
Langkah 1: Buat pekerjaan
-
Metode 1: Di panel navigasi sebelah kiri, klik ikon
. Di bagian QUICK START, klik Create a new deployment. Masukkan nama di bagian atas, lalu tekan Enter untuk membuat file dengan ekstensi .vvp. Ekstensi menghasilkan pekerjaan dengan bidang default. -
Metode 2: Buat file baru dengan ekstensi
.vvplangsung di explorer file. Ekstensi mengisi file tersebut dengan konfigurasi pekerjaan default.
Langkah 2: Konfigurasikan pekerjaan
Anda dapat mengonfigurasi parameter langsung di formulir UI.
Jika Anda terbiasa dengan konfigurasi pekerjaan, klik Raw File di pojok kiri atas untuk mengonfigurasi pekerjaan di file sumber. Mengklik nama parameter di formulir UI akan membawa Anda ke definisinya di file sumber.
{
"name": "test",
"artifact": {
"kind": "SQLSCRIPT",
"sqlArtifact": {
"additionalDependencies": [],
"sqlScript": ""
}
},
"deploymentTarget": {
"mode": "PER_JOB",
"name": "default-queue"
},
...
}
-
Basic: Konfigurasikan parameter dasar.
-
Resources: Untuk informasi selengkapnya tentang parameter sumber daya pekerjaan, lihat Mengonfigurasi sumber daya pekerjaan.
-
Parameters: Untuk informasi selengkapnya tentang parameter waktu proses pekerjaan, lihat Mengonfigurasi parameter waktu proses.
Langkah 3: Terapkan pekerjaan
Setelah selesai mengembangkan atau mengonfigurasi pekerjaan, klik Create di bagian bawah untuk menerapkan pekerjaan baru, atau klik Update untuk memperbarui dan menerapkan pekerjaan lokal yang sudah ada.
Untuk pekerjaan SQL, ekstensi memvalidasi skrip SQL, paket sumber daya, dan konfigurasi lainnya, lalu mengeluarkan hasil validasi.
Langkah 4: Jalankan pekerjaan
Untuk pekerjaan yang telah diterapkan, status terbaru ditampilkan di pojok kanan atas. Anda dapat mengklik Start dan memilih mode startup. Untuk informasi selengkapnya tentang mode startup, lihat Menjalankan pekerjaan.
Langkah 5: O&M pekerjaan
Setelah pekerjaan diterapkan dan berjalan, status RUNNING berwarna hijau muncul di bilah aksi di bagian atas editor. Area Basic menampilkan informasi deployment utama dalam bentuk tabel, termasuk Deployment ID, Deployment Name, Execution Mode, Engine Version (misalnya, vvr-8.0.7-flink-1.17), Deployment Target, dan Deployment Type.
-
Open Online: Klik Open Online untuk membuka halaman O&M pekerjaan di Konsol Pengembangan, tempat Anda dapat melihat status berjalan dan melakukan operasi O&M.
-
Synchronize: Menarik konfigurasi pekerjaan dari cloud. Mengklik Synchronize membuka pratinjau konfigurasi online. Catatan: Pratinjau tidak mencakup perubahan draft yang dibuat pada pekerjaan SQL di konsol. Klik
Acceptuntuk menimpa file lokal Anda dengan konfigurasi online. -
Cancel: Menghentikan pekerjaan yang sedang berjalan.
Dokumentasi terkait
-
Untuk konektor yang didukung, lihat Konektor yang didukung.
-
Untuk informasi tentang cara mengembangkan dan men-debug pekerjaan JAR Flink, lihat Mengembangkan pekerjaan JAR.
-
Untuk informasi tentang cara mengembangkan dan men-debug pekerjaan Python Flink, lihat Mengembangkan pekerjaan Python.
-
Untuk meningkatkan performa pekerjaan Flink SQL Anda, lihat Teknik optimasi Flink SQL berperforma tinggi.