VS Code local job development - Realtime Compute for Apache Flink

Önkoşullar

Realtime Compute for Apache Flink hizmetini etkinleştirdiniz.
Bir AccessKey ID'niz ve AccessKey Secret'ınız vardır. AccessKey'in hedef ad alanı için gerekli izinlere sahip olması gerekir. Daha fazla bilgi için bkz. AccessKey ID ve AccessKey Secret nasıl alınır? ve Development Console'da izin verme.
VS Code v1.74.0 veya sonraki bir sürümü yüklediniz. Yüklemediyseniz resmi VS Code web sitesinden indirin.

Sınırlamalar

Günlük yapılandırması desteklenmez.
Uzantı, mevcut işleri cloud'dan çekmeyi desteklemez.

Uzantıyı yükleme ve yapılandırma

Uzantıyı indirip yükleyin.
- Yöntem 1: VS Code Marketplace'e gidin ve Install öğesine tıklayın.
- Yöntem 2:
  1. VS Code'u açın ve sol gezinme bölmesinde EXTENSIONS seçeneğine tıklayın.
  2. Arama çubuğuna Flink Realtime Compute Studio uzantısını yazarak arayın.
  3. Install seçeneğine tıklayın.
Üst menü çubuğunda File > Open Folder seçeneğine tıklayın ve yerel bir klasör seçin.

AccessKey bilgilerinizi yapılandırın.

Geçerli çalışma alanı

Sol gezinme bölmesinde simgesine tıklayın. Configure AK&SK bölümünde Configure in a .vvprc file seçeneğine tıklayın. Uzantı, .vvprc uzantılı bir dosyayı otomatik olarak oluşturur.

Dosyaya aşağıdaki yapılandırmayı ekleyin:

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

Parametre	Açıklama	Notlar
accessKey	Alibaba Cloud hesabınızın AccessKey ID'si.	Daha fazla bilgi için bkz. AccessKey ID ve AccessKey Secret nasıl alınır?
secretKey	Alibaba Cloud hesabınızın AccessKey Secret'ı.
namespace	Flink ad alanının adı.	Daha fazla bilgi için bkz. Ad alanını görüntüleme ve silme.
workspace	Flink çalışma alanının ID'si.	Daha fazla bilgi için bkz. Çalışma alanı ID'si ve diğer bilgiler nasıl görüntülenir?.
regionId	Bölge ID'si.	Bölge ID'sini Uç Noktalar içinde bulun.

Genel

Sol gezinme bölmesinde simgesine tıklayın.
Configure AK&SK bölümünde Configure in global user settings seçeneğine tıklayın. VS Code genel ayarlar sayfasını açar.

flinkStudio ifadesini aratın ve aşağıdaki alanları ayarlayın: Flink Studio: Access Key, Flink Studio: Secret Key, Flink Studio: Namespace, Flink Studio: Region ID (varsayılan: cn-hangzhou) ve Flink Studio: Workspace.

İhtiyaca göre yapılandırma için User (Kullanıcı) veya Workspace (Çalışma Alanı) seçeneğini belirleyin.

Not

Yapılandırmayı tüm projelere uygulamak için kapsamı User olarak ayarlamanızı öneririz. Workspace kapsamı yapılandırmayı yalnızca geçerli çalışma alanına uygular.

Parametre	Açıklama	Notlar
Access Key	Alibaba Cloud hesabınızın AccessKey ID'si.	Daha fazla bilgi için bkz. AccessKey ID ve AccessKey Secret nasıl alınır?
Secret Key	Alibaba Cloud hesabınızın AccessKey Secret'ı.	Daha fazla bilgi için bkz. AccessKey ID ve AccessKey Secret nasıl alınır?
Namespace	Flink ad alanının adı.	Daha fazla bilgi için bkz. Ad alanını görüntüleme ve silme.
Workspace	Flink çalışma alanının ID'si.	Daha fazla bilgi için bkz. Çalışma alanı ID'si ve diğer bilgiler nasıl görüntülenir?.
Region ID	Bölge ID'si.	Bölge ID'sini Uç Noktalar içinde bulun.

Not

Yapılandırma önceliği: Geçerli klasör > Üst klasör > Genel.

Yapılandırmayı uyguladıktan sonra ad alanı adı düzenleyicinin alt kısmındaki durum çubuğunda görünür.

(İsteğe bağlı) Daha iyi bir geliştirme deneyimi için aşağıdaki uzantıları yükleyebilirsiniz.
- Flink SQL: Flink SQL Language Features uzantısını yükleyin. Bu uzantı Flink SQL için bir dil hizmeti sağlar ve eksiksiz Flink SQL sözdizimini destekler.
- Flink yapılandırması: Flink yapılandırmaları için otomatik tamamlama sağlayan YAML VS Code uzantısını yüklemenizi öneririz.

Yordam

1. Adım: İş oluşturma

Yöntem 1: Sol gezinme bölmesinde simgesine tıklayın. QUICK START bölümünde Create a new deployment seçeneğine tıklayın. Üst kısımda bir ad girin ve Enter tuşuna basarak .vvp uzantılı bir dosya oluşturun. Uzantı, varsayılan alanlara sahip bir iş oluşturur.
Yöntem 2: Dosya gezgininde doğrudan .vvp uzantılı yeni bir dosya oluşturun. Uzantı, dosyayı varsayılan bir iş yapılandırmasıyla doldurur.

2. Adım: İş yapılandırma

Parametreleri doğrudan UI formunda yapılandırabilirsiniz.

İş yapılandırmasına aşinaysanız sol üst köşede bulunan Raw File seçeneğine tıklayarak kaynağı dosyasında işi yapılandırın. UI formundaki bir parametre adına tıklamak, kaynak dosyadaki tanımına gider.

{
  "name": "test",
  "artifact": {
    "kind": "SQLSCRIPT",
    "sqlArtifact": {
      "additionalDependencies": [],
      "sqlScript": ""
    }
  },
  "deploymentTarget": {
    "mode": "PER_JOB",
    "name": "default-queue"
  },
  ...
}

Basic: Temel parametreleri yapılandırın.

SQL işi

Parametre	Açıklama
Dağıtım Adı	Dağıtımın adı.
Çalıştırma Modu	Dağıtım modu. Akış modu için STREAM veya toplu iş modu için BATCH kullanın.
Motor Sürümü	Motor sürümleri hakkında daha fazla bilgi için bkz. Motor sürümleri. En son önerilen sürümü kullanmanızı öneririz.
Dağıtım Hedefi	Dağıtım için kaynak kuyruğu. Daha fazla bilgi için bkz. Kaynak kuyruğunu yönetme.
Dağıtım Türü	SQL seçin.
SQL Betiği	Yerel düzenleyiciyi açmak için Open in external editor seçeneğine tıklayın. DDL ve DML kodlarınızı yazın. Not Düzenleyicide açılan dosya, gerçek dosya sisteminde depolanmayan sanal bir dosyadır. Bu nedenle, VS Code'u yeniden açarsanız kapatılmamış bir sanal dosyanın düzenleyici sekmesi `The editor could not be opened because the file was not found` hata mesajını gösterir. Dosyayı açmak için tekrar Open in external editor seçeneğine tıklayın.
Ek Bağımlılıklar	İş için gereken ek bağımlılıklar. Hedef bağımlılık dosyasının URI'sini girin.
Açıklama	İsteğe bağlı. İş için bir açıklama girin.

JAR işi

Parametre yapılandırmaları hakkında daha fazla bilgi için bkz. JAR işi dağıtma.

Parametre	Açıklama
Dağıtım Adı	Dağıtımın adı.
Çalıştırma Modu	Dağıtım modu. Akış modu için STREAM veya toplu iş modu için BATCH kullanın.
Motor Sürümü	Motor sürümü. Daha fazla bilgi için bkz. Motor sürümleri. En son önerilen sürümü kullanmanızı öneririz.
Dağıtım Hedefi	Dağıtım için kaynak kuyruğu. Daha fazla bilgi için bkz. Kaynak kuyruğunu yönetme.
Dağıtım Türü	Dağıtılacak iş türü. JAR seçin.
JAR URI	JAR paketinin OSS yolu veya URL'si. İlgili bağımlılık dosyalarını Development Console'daki Artifacts bölümüne veya bağlı bir OSS paketine yüklediğinizden ve ilgili yolu aldığınızdan emin olun.
Giriş Noktası Sınıfı	Çalıştırılacak ana sınıf. JAR manifest dosyası bir ana sınıf belirtmiyorsa gereklidir.
Giriş Noktası Ana Bağımsız Değişkenleri	Ana yönteme geçirilecek giriş bağımsız değişkenlerini girin.
Ek Bağımlılıklar	Ek bağımlılık dosyalarının OSS yolunu veya URL'sini girin. Şu anda yalnızca bir dosya adıyla biten URL'ler desteklenir. İlgili bağımlılık dosyalarını Development Console'daki Artifacts bölümüne veya bağlı bir OSS paketine yüklediğinizden ve ilgili yolu aldığınızdan emin olun.
Açıklama	İsteğe bağlı. İş için bir açıklama girin.

Python işi

Parametre yapılandırmaları hakkında daha fazla bilgi için bkz. Python işi dağıtma.

Parametre	Açıklama
Dağıtım Adı	Dağıtımın adı.
Çalıştırma Modu	Dağıtım modu. Akış modu için STREAM veya toplu iş modu için BATCH kullanın.
Motor Sürümü	Motor sürümü. Daha fazla bilgi için bkz. Motor sürümleri. En son önerilen sürümü kullanmanızı öneririz.
Dağıtım Hedefi	Dağıtım için kaynak kuyruğu. Daha fazla bilgi için bkz. Kaynak kuyruğunu yönetme.
Dağıtım Türü	Dağıtılacak iş türü. Python seçin.
Python URI	.py veya .zip dosyası olabilen Python iş dosyasının URI'si.
Giriş Modülü	Çalıştırılacak giriş modülü. .py dosyaları için gerekli değildir. .zip dosyaları için gereklidir.
Giriş Noktası Ana Bağımsız Değişkenleri	Ana yönteme geçirilecek giriş bağımsız değişkenlerini girin.
Python Kitaplıkları	Üçüncü taraf Python paketleri. Bu paketler Python çalışan işlemcinin PYTHONPATH yoluna eklenir ve böylece Python kullanıcı tanımlı işlevlerinde doğrudan erişilebilir hale gelirler. Üçüncü taraf Python paketlerinin nasıl kullanılacağı hakkında bilgi için bkz. Üçüncü taraf Python paketlerini kullanma.
Python Arşivleri	Arşiv dosyaları. Daha fazla bilgi için bkz. Özel Python sanal ortamı kullanma ve Veri dosyalarını kullanma.
Ek Bağımlılıklar	Ek bağımlılık dosyalarının OSS yolunu veya URL'sini girin. İlgili bağımlılık dosyalarını Development Console'daki Artifacts bölümüne veya bağlı bir OSS paketine yüklediğinizden ve ilgili yolu aldığınızdan emin olun.
Açıklama	İsteğe bağlı. İş için bir açıklama girin.

Resources: İş kaynak parametreleri hakkında daha fazla bilgi için bkz. İş kaynaklarını yapılandırma.
Parameters: İş çalıştırma parametreleri hakkında daha fazla bilgi için bkz. Çalışma zamanı parametrelerini yapılandırma.

3. Adım: İşi dağıtma

İşi geliştirmeyi veya yapılandırmayı tamamladıktan sonra yeni bir iş dağıtmak için alt kısımdaki Create seçeneğine tıklayın veya mevcut yerel bir işi güncellemek ve dağıtmak için Update seçeneğine tıklayın.

SQL işleri için uzantı SQL betiğini, kaynak planını ve diğer yapılandırmaları doğrular ve ardından doğrulama sonuçlarını çıktılar.

4. Adım: İşi başlatma

Dağıtılmış bir iş için en son durum sağ üst köşede görüntülenir. Start seçeneğine tıklayabilir ve bir başlatma modu seçebilirsiniz. Başlatma modları hakkında daha fazla bilgi için bkz. İş başlatma.

5. Adım: İş İşletimi ve Bakımı

İş dağıtılıp çalıştırıldıktan sonra düzenleyicinin üst kısmındaki eylem çubuğunda yeşil renkli RUNNING durumu görünür. Basic alanında Dağıtım ID'si, Dağıtım Adı, Çalıştırma Modu, Motor Sürümü (örneğin, vvr-8.0.7-flink-1.17), Dağıtım Hedefi ve Dağıtım Türü gibi temel dağıtım bilgileri bir tabloda gösterilir.

Open Online: Development Console'da iş işletim ve bakım sayfasını açmak için Open Online seçeneğine tıklayın. Burada çalıştırma durumunu görüntüleyebilir ve işletim/bakım işlemlerini gerçekleştirebilirsiniz.
Synchronize: İş yapılandırmasını cloud'dan çeker. Synchronize seçeneğine tıklamak çevrimiçi yapılandırmanın önizlemesini açar. Not: Önizleme, konsoldaki SQL işlerinde yapılan taslak değişikliklerini içermez. Çevrimiçi yapılandırma ile yerel dosyanızı üzerine yazmak için Accept seçeneğine tıklayın.
Cancel: Çalışan işi durdurur.

İlgili belgeler

Desteklenen bağlayıcılar için bkz. Desteklenen bağlayıcılar.
Flink JAR işlerini geliştirme ve hata ayıklama hakkında bilgi için bkz. JAR işi geliştirme.
Flink Python işlerini geliştirme ve hata ayıklama hakkında bilgi için bkz. Python işi geliştirme.
Flink SQL işlerinizin performansını artırmak için bkz. Yüksek performanslı Flink SQL optimizasyon teknikleri.