Realtime Compute for Apache Flink:İş akışlarını yönetin

Sınırlamalar

• İş akışlarını yalnızca dağıtılmış toplu işler için oluşturabilirsiniz.

• Workflows özelliği genel önizleme aşamasındadır. Bu süre boyunca SLA'lar garanti edilmez. Daha fazla bilgi için bkz. Realtime Compute for Apache Flink Hizmet Seviyesi Sözleşmesi (SLA). Herhangi bir sorunla karşılaşırsanız destek talebi gönderin.

• Workflows özelliği yalnızca Çin (Şanghay), Çin (Hangzhou), Çin (Pekin), Çin (Shenzhen), Çin (Zhangjiakou) ve Singapur bölgelerinde kullanılabilir.

İş akışı oluşturun

1. Realtime Compute for Apache Flink konsolunda oturum açın.

2. Hedef çalışma alanının Actions sütununda Console seçeneğine tıklayın.

3. Sol gezinme bölmesinde O&M > Workflows yolunu izleyin.

4. Create workflow seçeneğine tıklayın ve aşağıdaki parametreleri yapılandırın.

   Parametre	Açıklama
   Workflow name	İş akışı adı, geçerli ad alanında benzersiz olmalıdır.
   Değişken yapılandırması	Önceden ayarlanmış değerlerle veri işlemeyi etkinleştirir. Değişken adı: ${date} gibi özel bir değişken adı. Değişken değeri: Statik bir tarih, saat biçimi veya ifade olabilir. Aşağıdaki sistem saat değişkenleri desteklenir: system.biz.date adlı değişkenin değeri ${system.biz.date}: Günlük iş akışı örneğinin planlanan zamanından önceki günü, yyyyMMdd biçiminde temsil eder. system.biz.curdate adlı değişkenin değeri ${system.biz.curdate}: Günlük iş akışı örneğinin planlanan tarihini (yıl, ay, gün), yyyyMMdd biçiminde temsil eder. system.datetime adlı değişkenin değeri ${system.datetime}: Günlük iş akışı örneğinin planlanan zamanını (yıl, ay, gün, saat, dakika, saniye), yyyyMMddHHmmss biçiminde temsil eder. Not Somutlaştırılmış tablo için bir iş akışı oluştururken bu yapılandırma gerekli değildir. Bu parametreler, iş akışındaki görevlerle ilişkili tüm dağıtımlar için geçerlidir. İş akışı düzeyindeki yapılandırmalar, dağıtım düzeyindeki yapılandırmaların üzerine yazar.
   Zamanlama türü	İki zamanlama türü desteklenir: Manually Triggered: İş akışını Execute düğmesine tıklayarak manuel olarak çalıştırın. Bu seçenek, geçici testler veya anında işleme için uygundur. Periodic scheduling: İş akışını bir zamanlama kuralına göre tetikler. Dakika, saat veya gün aralıklarıyla çalışacak şekilde zamanlayabilirsiniz. Önemli Somutlaştırılmış tablo görevleri içeren iş akışları periyodik zamanlama gerektirir.
   Zamanlama kuralı	Yalnızca Periodic scheduling seçeneği için gereklidir. Karmaşık kuralları tanımlamak için cron ifadesi kullanabilirsiniz. Örnekler: 0 0 /4 ? *: Her 4 saatte bir çalışır. 0 0 2 ? : Her gün saat 02:00'da çalışır. 0 0 5,17 ? * MON-FRI: Pazartesiden Cumaya kadar her gün saat 05:00 ve 17:00'de çalışır. Cron ifadesi sözdizimi hakkında daha fazla bilgi için bkz. Cron ifadesi sözdizimi.
   Planlanan başlangıç zamanı	Kuralın etkili olacağı zaman. Bu parametre yalnızca Periodic scheduling türü için gereklidir. Önemli Periyodik olarak zamanlanan bir iş akışı, yalnızca State durumu etkinleştirildikten sonra çalışır. Görevin zamanlama penceresini kaçırmamasını sağlamak için planlanan başlangıç zamanını gelecek bir zaman olarak ayarlayın.
   Başarısızlıkta yeniden deneme sayısı	İş akışındaki başarısız görevlerin kaç kez yeniden deneneceğini belirtir. Yeniden denemeler varsayılan olarak devre dışı bırakılır.
   Başarısızlık bildirimi	İş akışındaki bir görev başarısız olduğunda bildirim gönderilecek varsayılan e-posta adresi. Not CloudMonitor aracılığıyla DingTalk, SMS ve diğer yöntemler üzerinden uyarıları yapılandırabilirsiniz. Daha fazla bilgi için bkz. İzleme ve uyarıları yapılandırma.
   Kaynak kuyruğu	İş akışının dağıtım hedefi. Daha fazla bilgi için bkz. Kaynak kuyruklarını yönetme. Bu ayar varsayılan olarak tüm görevlere uygulanır ve görev düzeyinde yapılandırma yapmanıza gerek kalmaz. Not Bu ayar, ilgili dağıtılmış toplu işin dağıtım hedefini değiştirmez.
   Etiket	İş akışı için bir etiket oluşturmak üzere bir anahtar ve değer ekleyebilirsiniz.

5. Create seçeneğine tıklayın.

   İş akışı oluşturucu sayfasına yönlendirilirsiniz.

6. İş akışının ilk görevini yapılandırın.

   Oluşturucu sayfasında varsayılan bir ilk görev bulunur. İlk göreve tıklayın, parametrelerini Edit task panelinde yapılandırın ve ardından Save seçeneğine tıklayın.

   Job

   Parametre	Açıklama
   Dağıtım	Yalnızca geçerli ad alanındaki dağıtılmış bir toplu işi seçebilirsiniz. Bulanık arama desteklenir.
   Görev adı	Geçerli iş akışı içindeki görevin adı.
   Üst akış görevleri	Geçerli görevin üst akış bağımlılıkları. Yalnızca geçerli iş akışı içindeki diğer görevleri seçebilirsiniz. Not İlk görevin üst akış bağımlılığı yoktur, bu nedenle bunun için bir üst akış görevi seçemezsiniz.
   Başarısızlıkta yeniden deneme sayısı	Başarısız bir görev için yeniden deneme sayısı. Varsayılan olarak bu değer, iş akışının yeniden deneme sayısından miras alınır. Belirtilirse görev düzeyindeki ayar öncelik kazanır.
   Abonelik	Durum abonelik ilkesini ve bildirim e-postasını yapılandırın. Start ve Fail durumlarına abone olabilirsiniz.
   Zaman aşımı	Görev için maksimum yürütme süresi. Görev bu süreyi aşarsa başarısız olur.
   Kaynak kuyruğu	Görevin dağıtım hedefi. Daha fazla bilgi için bkz. Kaynak kuyruklarını yönetme. Belirtilmezse, iş akışı için yapılandırılan kaynak kuyruğu kullanılır. Not Bu ayar, ilgili dağıtılmış toplu işin dağıtım hedefini değiştirmez.
   Etiket	İş akışı görevi için bir etiket oluşturmak üzere bir anahtar ve değer ekleyebilirsiniz.

   Materialized table

   Parametre	Açıklama
   Somutlaştırılmış tablo	Yalnızca VVR 11.0 veya sonraki sürümlerle oluşturulan ve akış yenileme modunu kullanan bölümlenmiş somutlaştırılmış tabloları seçebilirsiniz.
   Görev adı	Geçerli iş akışı içindeki görevin adı.
   Zaman bölümü	Bölüm alanı: Somutlaştırılmış tablonun zaman bölümü alanı. Bölüm biçimi: Örneğin, yyyyMMdd.
   Kaynak yapılandırması	Zamanlamalı geri doldurmalar için kullanılan kaynak miktarını özelleştirebilirsiniz. Paralellik için sistemin uygun bir değer belirlemesine izin vermek amacıyla Automatically allocate seçeneğini belirleyin.
   Üst akış görevleri	Geçerli görevin üst akış bağımlılıkları. Yalnızca geçerli iş akışı içindeki diğer görevleri seçebilirsiniz. Not İlk görevin üst akış bağımlılığı yoktur, bu nedenle bunun için bir üst akış görevi seçemezsiniz. Bir somutlaştırılmış tablo görevi oluşturduktan sonra, alt akış görevleri veri soyuna göre otomatik olarak çıkarılır.
   Başarısızlıkta yeniden deneme sayısı	Başarısız bir görev için yeniden deneme sayısı. Varsayılan olarak bu değer, iş akışının yeniden deneme sayısından miras alınır. Belirtilirse görev düzeyindeki ayar öncelik kazanır.
   Abonelik	Durum abonelik ilkesini ve bildirim e-postasını yapılandırın. Start ve Fail durumlarına abone olabilirsiniz.
   Zaman aşımı	Görev için maksimum yürütme süresi. Görev bu süreyi aşarsa başarısız olur.
   Kaynak kuyruğu	Görevin dağıtım hedefi. Daha fazla bilgi için bkz. Kaynak kuyruklarını yönetme. Belirtilmezse, iş akışı için yapılandırılan kaynak kuyruğu kullanılır. Not Bu ayar, ilgili dağıtılmış somutlaştırılmış tablonun dağıtım hedefini değiştirmez.
   Etiket	İş akışı görevi için bir etiket oluşturmak üzere bir anahtar ve değer ekleyebilirsiniz.

   Not

   • Bir somutlaştırılmış tablo görevi oluşturduktan sonra, bir iletişim kutusu tablonun soyuna göre alt akış görevlerini önerir. Kurulumu tamamlamak için istediğiniz görevleri seçmeniz yeterlidir.

   • Alt akış görevleri de aynı sınırlamalara uymalıdır. Yalnızca VVR 11.0 veya sonraki sürümlerle oluşturulan, akış yenileme modunu kullanan ve tazelik süresi 30 dakikadan az olan bölümlenmiş somutlaştırılmış tabloları seçebilirsiniz.

7. (İsteğe bağlı) Daha fazla görev eklemek için sayfanın alt kısmındaki Add task seçeneğine tıklayın.

8. İş akışı yapılandırmasını kaydedin.

   1. Görev düzenleyici sayfasının sağ üst köşesinde Save seçeneğine tıklayın.

   2. Görüntülenen iletişim kutusunda OK seçeneğine tıklayın.

İş akışı çalıştırın

Her iş akışı yürütmesi, iş akışı ayrıntıları sayfasının Overview sekmesinde görünen bir iş akışı örneği oluşturur.

• Manuel tetikleme: İş akışını hemen bir kez çalıştırır. Test veya isteğe bağlı işleme için kullanışlıdır.

  Hedef iş akışının Actions sütununda Execute seçeneğine tıklayın. Görüntülenen iletişim kutusunda Manual trigger seçeneğini belirleyin ve ardından OK seçeneğine tıklayın. Her işlem, iş akışının bir kez yürütülmesini tetikler.

• Periyodik zamanlama: Etkinleştirildiğinde, iş akışı planlanan zamanda otomatik olarak çalışır.

  Hedef iş akışının planlanan zamanda çalışması için State durumunu etkinleştirmeniz gerekir.

Veri geri doldurma

Veri geri doldurma, belirli bir zaman aralığındaki verileri tamamlar veya günceller. Yaygın kullanım senaryoları arasında üst akış kaynaklarından gelen geçmiş verilerin yeniden işlenmesi, boyut tablolarının düzeltilmesi veya yeni entegrasyonlar için verilerin geri yüklenmesi yer alır.

İş akışı durumu

Status sütunu, belirli bir iş akışının tüm örneklerinin durumlarını özetler. Örneğin, bir iş akışı beş gün boyunca günlük olarak çalıştırılıyorsa Status sütunu, beş örneğin kaç tanesinin her bir durumda (Başarılı veya Başarısız gibi) olduğunu gösterir.

İş akışını düzenleyin

1. Realtime Compute for Apache Flink konsolunda oturum açın.

2. Hedef çalışma alanının Actions sütununda Console seçeneğine tıklayın.

3. Sol gezinme bölmesinde Workflows seçeneğine tıklayın.

4. Hedef iş akışının Actions sütununda Edit workflow seçeneğine tıklayın.

   Parametre açıklamaları için bkz. İş akışı oluşturun.

   Not

   Bir iş akışını düzenlemek için State durumu Off konumunda olmalıdır.

İlgili konular

• Flink SQL toplu işlerini DataWorks'te zamanlamak için bkz. Flink SQL Batch düğümü ve Düğüm zamanlama yapılandırması.

• Workflows temel kavramları hakkında daha fazla bilgi için bkz. İş Akışları (genel önizleme).

• İş akışı örneklerini, görev günlüklerini ve daha fazlasını görüntülemek için bkz. İş akışı örneklerini ve görev örneklerini yönetme.

• Kaynakları izole etmek ve yönetmek için kaynak kuyrukları ekleyebilirsiniz. Daha fazla bilgi için bkz. Kaynak kuyruklarını yönetme.

• Toplu işleri (SQL, JAR ve Python) dağıtmak için bkz. İşi dağıtma.