Realtime Compute for Apache Flink：Gunakan ekstensi Visual Studio Code

Prasyarat

• Sebuah workspace telah dibuat. Untuk informasi lebih lanjut, lihat Aktifkan Realtime Compute for Apache Flink.

• ID AccessKey dan Rahasia AccessKey telah diperoleh, serta izin terkait namespace yang ingin digunakan telah diberikan. Untuk informasi lebih lanjut, lihat Bagaimana cara melihat pasangan AccessKey dari sebuah akun? dan Berikan Izin pada Namespaces.

• Visual Studio Code versi 1.74.0 atau lebih baru telah diinstal. Untuk informasi lebih lanjut, kunjungi Situs Web Visual Studio Code.

Batasan

• Ekstensi tidak mendukung konfigurasi log.

• Ekstensi tidak dapat menyinkronkan penyebaran yang dibuat di konsol pengembangan Realtime Compute for Apache Flink.

Instal dan konfigurasikan ekstensi

1. Unduh dan instal ekstensi.

   • Metode 1: Buka halaman Visual Studio Code Marketplace dan klik Install.

   • Metode 2:

     1. Buka Visual Studio Code di komputer Anda. Di panel navigasi sebelah kiri, klik EXTENSIONS.

     2. Masukkan Flink Realtime Compute Studio di kotak pencarian.

     3. Temukan ekstensi yang sesuai dan klik Install.

2. Di bilah navigasi atas, pilih File > Open Folder dan pilih folder yang ingin digunakan.

3. Konfigurasikan pasangan AccessKey.

   Konfigurasikan hanya untuk folder saat ini

   1. Di panel navigasi sebelah kiri, klik . Di bagian Configure AK&SK, klik Configure in a .vvprc file. Ekstensi secara otomatis membuat file dengan akhiran .vvprc.

      

   2. Buka file yang dibuat dan tambahkan konfigurasi berikut:

      {
        "accessKey": "xxx",
        "secretKey": "xxx",
        "namespace": "xxx",
        "workspace": "xxx",
        "regionId" : "xxx"
      }

      Parameter	Deskripsi	Referensi
      accessKey	ID AccessKey dari akun Alibaba Cloud Anda.	Bagaimana cara melihat pasangan AccessKey dari sebuah akun?
      secretKey	Rahasia AccessKey dari akun Alibaba Cloud Anda.
      namespace	Nama namespace Realtime Compute for Apache Flink yang ingin digunakan.	Lihat dan hapus namespace
      workspace	ID workspace Realtime Compute for Apache Flink yang ingin digunakan.	Bagaimana cara melihat informasi tentang workspace, seperti ID workspace?
      regionId	ID wilayah tempat workspace dibuat.	Endpoints

   Konfigurasikan untuk workspace atau pengguna saat ini

   1. Di panel navigasi sebelah kiri, klik .

   2. Di bagian Configure AK&SK, klik Configure in global user settings untuk membuka editor Pengaturan di Visual Studio Code.

      

   3. Pilih tab User atau Workspace berdasarkan kebutuhan bisnis Anda.

      null

      Kami menyarankan Anda memilih tab User. Dengan cara ini, konfigurasi parameter berlaku untuk semua proyek dan workspace di Visual Studio Code.

      Parameter	Deskripsi	Referensi
      Access Key	ID AccessKey dari akun Alibaba Cloud Anda.	Bagaimana cara melihat pasangan AccessKey dari sebuah akun?
      Secret Key	Rahasia AccessKey dari akun Alibaba Cloud Anda.	Bagaimana cara melihat pasangan AccessKey dari sebuah akun?
      Namespace	Nama namespace Realtime Compute for Apache Flink yang ingin digunakan.	Lihat dan hapus namespace
      Workspace	ID workspace Realtime Compute for Apache Flink yang ingin digunakan.	Bagaimana cara melihat informasi tentang workspace, seperti ID workspace?
      Region ID	ID wilayah tempat workspace dibuat.	Endpoints

   null

   Urutan prioritas konfigurasi: Konfigurasi folder saat ini > Konfigurasi workspace > Konfigurasi pengguna.

   Setelah konfigurasi berlaku, nama namespace Realtime Compute for Apache Flink ditampilkan di bilah status di bagian bawah editor kode.

4. (Opsional) Instal ekstensi berikut untuk meningkatkan efisiensi coding:

   • Flink SQL Language Features: Mendukung sintaksis Apache Flink SQL.

   • YAML VS Code: Menyediakan saran penyelesaian kode inline untuk konfigurasi terkait Realtime Compute for Apache Flink.

Gunakan ekstensi

Langkah 1: Buat penyebaran

• Metode 1: Di panel navigasi sebelah kiri, klik . Di bagian QUICK START, klik Create a new deployment. Di bilah navigasi atas, masukkan nama dan tekan tombol Enter untuk membuat file dengan akhiran .vvp. File tersebut mencakup konfigurasi penyebaran yang sudah diisi sebelumnya.

  

• Metode 2: Buat file dengan akhiran .vvp di folder saat ini. File tersebut mencakup konfigurasi penyebaran yang sudah diisi sebelumnya.

Langkah 2: Konfigurasikan penyebaran

Anda dapat mengonfigurasi penyebaran dalam tampilan formulir.

Jika Anda terbiasa dengan parameter, Anda juga dapat mengklik Raw File di pojok kiri atas untuk mengonfigurasi penyebaran dalam tampilan file mentah. Anda dapat mengklik nama bidang di formulir untuk dengan cepat menemukan parameter yang sesuai di file mentah.

• Basic: Bagian ini mencakup parameter dasar penyebaran.

  Penyebaran SQL

  Parameter	Deskripsi
  Nama Penyebaran	Masukkan nama untuk penyebaran.
  Mode Eksekusi	Pilih mode penyebaran. Nilai valid: STREAM (mode streaming) dan BATCH (mode batch).
  Versi Mesin	Pilih versi mesin Ververica Runtime (VVR). Untuk informasi lebih lanjut, lihat Versi mesin. Kami menyarankan Anda memilih versi yang dilabeli dengan RECOM.
  Target Penyebaran	Pilih antrian yang ingin digunakan untuk penyebaran. Untuk informasi lebih lanjut, lihat Kelola antrian.
  Tipe Penyebaran	Pilih tipe penyebaran. Dalam contoh ini, pilih SQL.
  Skrip SQL	Klik Open in external editor untuk membuka editor kode di mana Anda dapat menulis pernyataan DDL dan DML. null Perubahan yang Anda buat di editor kode disimpan dalam file virtual. Jika Anda keluar dan membuka kembali Visual Studio Code tanpa menutup editor, jendela editor yang sesuai menampilkan pesan kesalahan berikut: Editor tidak dapat dibuka karena file tidak ditemukan. Untuk menyelesaikan kesalahan, klik Open in external editor lagi.
  Dependensi Tambahan	Masukkan URI dependensi tambahan yang diperlukan dalam penyebaran.
  Deskripsi	Opsional. Masukkan deskripsi untuk penyebaran.

  Penyebaran JAR

  Tabel berikut menjelaskan parameter. Untuk deskripsi parameter yang lebih rinci, lihat Buat Penyebaran JAR.

  Parameter	Deskripsi
  DeploymentName	Masukkan nama untuk penyebaran.
  Mode Eksekusi	Pilih mode penyebaran. Nilai valid: STREAM (mode streaming) dan BATCH (mode batch).
  Versi Mesin	Pilih versi mesin VVR. Untuk informasi lebih lanjut, lihat Versi mesin. Kami menyarankan Anda memilih versi yang dilabeli dengan RECOM.
  Target Penyebaran	Pilih antrian yang ingin digunakan untuk penyebaran. Untuk informasi lebih lanjut, lihat Kelola antrian.
  Tipe Penyebaran	Pilih tipe penyebaran. Dalam contoh ini, pilih Jar.
  URI JAR	Masukkan jalur Object Storage Service (OSS) atau URL paket JAR yang ingin digunakan untuk penyebaran. Untuk mendapatkan jalur OSS atau URL, pastikan Anda mengunggah paket JAR di halaman Artifacts di konsol pengembangan Realtime Compute for Apache Flink atau di Bucket OSS yang terkait dengan workspace.
  Kelas Titik Masuk	Masukkan kelas titik masuk aplikasi Java. Jika Anda tidak menentukan kelas utama di paket JAR, pastikan Anda mengatur parameter ini ke nama kelas lengkap dari kelas utama.
  Argumen Utama Titik Masuk	Masukkan argumen yang ingin Anda lewatkan ke metode utama.
  Dependensi Tambahan	Masukkan jalur OSS atau URL dependensi tambahan yang diperlukan dalam penyebaran. URL harus diakhiri dengan nama file. Untuk mendapatkan jalur OSS atau URL, pastikan Anda mengunggah file dependensi di halaman Artifacts di konsol pengembangan Realtime Compute for Apache Flink atau di Bucket OSS yang terkait dengan workspace.
  Deskripsi	Opsional. Masukkan deskripsi untuk penyebaran.

  Penyebaran Python

  Tabel berikut menjelaskan parameter. Untuk deskripsi parameter yang lebih rinci, lihat Buat Penyebaran Python.

  Parameter	Deskripsi
  Nama Penyebaran	Masukkan nama untuk penyebaran.
  Mode Eksekusi	Pilih mode penyebaran. Nilai valid: STREAM (mode streaming) dan BATCH (mode batch).
  Versi Mesin	Pilih versi mesin VVR. Untuk informasi lebih lanjut, lihat Versi mesin. Kami menyarankan Anda memilih versi yang dilabeli dengan RECOM.
  Target Penyebaran	Pilih antrian yang ingin digunakan untuk penyebaran. Untuk informasi lebih lanjut, lihat Kelola antrian.
  Tipe Penyebaran	Pilih tipe penyebaran. Dalam contoh ini, pilih Python.
  URI Python	Masukkan URI file penyebaran Python yang ingin digunakan. File tersebut dapat berupa file .py atau .zip.
  Modul Entri	Masukkan kelas titik masuk aplikasi Python. Jika Anda menggunakan file .py, biarkan parameter ini kosong. Jika Anda menggunakan file .zip, Anda harus mengonfigurasi parameter ini.
  Argumen Utama Titik Masuk	Masukkan argumen yang ingin Anda lewatkan ke metode utama.
  Pustaka Python	Masukkan pustaka Python pihak ketiga yang ingin digunakan. Pustaka yang ditentukan secara otomatis dilewatkan ke variabel lingkungan PYTHONPATH dari proses pekerja yang sesuai dalam penyebaran. Dengan cara ini, Anda dapat menggunakan pustaka dalam fungsi Python yang ditentukan pengguna (UDF). Untuk informasi tentang cara menggunakan pustaka Python pihak ketiga, lihat Gunakan paket Python pihak ketiga.
  Arsip Python	Masukkan file arsip yang ingin digunakan. Untuk informasi lebih lanjut, lihat Gunakan lingkungan virtual Python kustom dan Gunakan file data.
  Dependensi Tambahan	Masukkan jalur OSS atau URL dependensi tambahan yang diperlukan dalam penyebaran. Untuk mendapatkan jalur OSS atau URL, pastikan Anda mengunggah file dependensi di halaman Artifacts di konsol pengembangan Realtime Compute for Apache Flink atau di Bucket OSS yang terkait dengan workspace.
  Deskripsi	Opsional. Masukkan deskripsi untuk penyebaran.

• Resources: Untuk informasi tentang parameter di bagian ini, lihat Konfigurasikan Sumber Daya untuk Penyebaran.

• Parameters: Untuk informasi tentang parameter di bagian ini, lihat Parameter.

Langkah 3: Kirim penyebaran

Klik Create di bagian bawah editor untuk mengirim penyebaran. Jika Anda memperbarui penyebaran yang ada, klik Update untuk mengirim penyebaran yang diperbarui.

Jika Anda mengirim penyebaran SQL, ekstensi memeriksa skrip SQL, rencana sumber daya, dan konfigurasi lainnya serta menghasilkan hasil pemeriksaan.

Langkah 4: Mulai penyebaran

Setelah Anda mengirim penyebaran, status terbaru penyebaran ditampilkan di pojok kanan atas. Klik Start dan pilih mode startup. Untuk informasi lebih lanjut tentang mode startup, lihat Prosedur.

Langkah 5: Kelola penyebaran

• Untuk melihat status berjalan secara detail atau melakukan operasi O&M, klik Open Online di pojok kiri atas untuk pergi ke halaman Penyebaran di konsol pengembangan Realtime Compute for Apache Flink.

• Untuk menyinkronkan penyebaran dengan cepat, klik Synchronize untuk membuka halaman pratinjau, konfirmasikan konfigurasi di halaman pratinjau, lalu klik Terima di pojok kanan atas. Ini memungkinkan ekstensi untuk menimpa konfigurasi menggunakan konfigurasi dari konsol pengembangan Realtime Compute for Apache Flink. Perhatikan bahwa halaman pratinjau tidak menampilkan pembaruan skrip SQL yang Anda lakukan di konsol.

• Untuk membatalkan penyebaran, klik Cancel di pojok kanan atas.

Referensi

• Untuk informasi tentang konektor yang didukung oleh Realtime Compute for Apache Flink, lihat Konektor yang Didukung.

• Untuk informasi tentang cara mengembangkan dan men-debug penyebaran JAR, lihat Kembangkan Draf JAR.

• Untuk informasi tentang cara mengembangkan dan men-debug penyebaran Python, lihat Kembangkan Draf API Python.

• Untuk informasi tentang cara meningkatkan performa penyebaran SQL, lihat Optimalkan Flink SQL.