Manage workflows - E-MapReduce - Alibaba Cloud Dokümantasyon Merkezi

Ön koşullar

Bir çalışma alanı oluşturdunuz. Daha fazla bilgi için bkz. Çalışma alanlarını yönetme.
Gerekli görevleri geliştirdiniz ve yayınladınız.

İş akışı oluşturma

Workflows sayfasına gidin.
1. E-MapReduce konsolu üzerinde oturum açın.
2. Sol gezinme bölmesinde EMR Serverless > Spark seçeneğini belirleyin.
3. Spark sayfasında hedef çalışma alanının adını tıklayın.
4. EMR Serverless Spark sayfasında sol gezinme bölmesinden Workflows seçeneğine tıklayın.
Workflows sayfasında Create Workflow düğmesini tıklayın.

Create Workflow panelinde aşağıdaki parametreleri belirtin ve Next seçeneğine tıklayın.

Parametre		Açıklama
Name		İş akışı adı, geçerli çalışma alanında benzersiz olmalıdır.
Resource Queue		İş akışının çalışacağı varsayılan kaynak kuyruğunu seçin. Not Bir düğümün kaynak kuyruğu ayarı, bu varsayılan kuyruğu geçersiz kılar.
Other Settings	Scheduling Type	Üretim ortamında iş akışının çalıştırılmasına yönelik zamanlama türü: Manual (Varsayılan): İş akışı yalnızca manuel olarak tetiklediğinizde çalışır. Scheduler: İş akışı, tanımlanan bir programa (dakika, saat veya gün bazında) göre otomatik olarak çalışır. Scheduling Type değerini Scheduler olarak ayarlarsanız Scheduler ve Scheduling Started At parametrelerini de yapılandırmanız gerekir.
	Scheduler	İş akışının otomatik olarak ne sıklıkla çalışacağını belirler. Bu parametre yalnızca Scheduling Type değerini Scheduler olarak ayarladığınızda gereklidir. Aşağıdaki zamanlama döngüleri kullanılabilir: Daily: Her gün belirli bir saatte bir kez çalışır. Hourly: Her gün belirlenen bir zaman aralığında `every N hours` gibi tanımlı bir aralıkla çalışır. Minute: Her gün belirlenen bir zaman aralığında `every N minutes` gibi tanımlı bir aralıkla çalışır.
	Scheduling Started At	Zamanlanan iş akışının başlangıç tarih ve saati. Varsayılan olarak geçerli zamandır. Yalnızca Scheduler türü için gereklidir. Önemli Scheduler türündeki bir iş akışı için zamanlamayı etkinleştirmek amacıyla Workflows sayfasındaki Scheduling Status anahtarını etkinleştirmeniz gerekir.
	Retries After Failure	Bir düğümün hata sonrası yeniden deneme sayısıdır. Varsayılan: yeniden deneme yok. Not Tek tek düğümlerin ayarları bu parametreyi geçersiz kılabilir.
	Failure Notification	Hata bildirimlerinin alınacağı e-posta adresi.
	Tags	İş akışını etiketlemek için kullanılan anahtar-değer çiftleri.

İş akışı düğümlerini düzenleyin.

Edit Workflow sayfasında alt kısımdaki Add Node düğmesine tıklayın.

Add Node panelinde düğüm parametrelerini yapılandırın.

Parametre	Açıklama
Path	Bu düğümün çalıştırdığı görevin yoludur. Görev yayınlanmış olmalıdır.
Node Type	İş akışı düğümü türüdür. Sistem, varsayılan olarak belirtilen yoldaki göreve göre türü çıkarır.
Node Name	Düğüm için özel bir addır. Otomatik olarak görev kaynağından doldurulur.
Upstream Nodes	İş akışındaki önceki düğüm. İlk düğüm için bir üst akış düğümü gerekmez.
Failure Retries	Yeniden deneme ayarlarını iş akışından devralır. Varsayılan: yeniden deneme yok.
Timeout(seconds)	Tek bir düğüm çalıştırması için zaman aşımı süresidir. Varsayılan: sınır yok.
Subscriptions	Belirli düğüm durumlarına ilişkin bildirimlere abone olmak için bir e-posta adresi belirtin.
Tags	Düğüm için etiket anahtar-değer çiftleri. Her düğüm otomatik olarak iki yerleşik etiket içerir: `workflow_name` ve `task_name`.
Resource Queue	Bu düğüm için kaynak kuyruğu. Bu ayar, iş akışının varsayılan kaynak kuyruğunu geçersiz kılar. Önemli Varsayılan daha sonra değiştirilse bile düğüme özel kaynak kuyruğu ayarı, iş akışının varsayılan ayarına göre önceliklidir.

Not

Görev kaynağı SQL geliştirme ise görev parametrelerini de yapılandırmanız gerekir. Bu parametreler varsayılan olarak görev şablonundan değerleri devralır. Varsayılan değerleri değiştirmek için görev şablonunu değiştirebilirsiniz. Parametrelerle ilgili daha fazla bilgi için bkz. Yapılandırma yönetimi.

Save düğmesine tıklayın.

İlk düğümü yapılandırdıktan sonra daha fazla düğüm eklemek için sayfanın alt kısmındaki Add Node düğmesine tıklayabilirsiniz.

İş akışını yayınlayın.
1. Sağ üst köşede Publish Workflow düğmesine tıklayın.
2. Publish iletişim kutusunda sürüm için bir açıklama girebilir ve ardından OK düğmesine tıklayabilirsiniz.

İş akışı çalıştırma

Her iş akışı çalıştırması, iş akışı ayrıntıları sayfasındaki Workflow Runs sekmesinde bir kayıt oluşturur.

Hata ayıklama

Düzenleme sırasında bir iş akışının en son sürümünde hata ayıklama yapabilirsiniz.

Edit Workflow sayfasında Debugging seçeneğine tıklayın.
Debugging iletişim kutusunda geliştirme ortamından bir kaynak kuyruğu seçin ve ardından Run düğmesine tıklayın.

Zamanlanmış çalıştırma

İş akışını oluştururken Scheduling Type değerini Scheduler olarak ayarlarsanız oluşturma işleminden sonra Scheduling Status anahtarını etkinleştirebilirsiniz. İş akışı daha sonra belirtilen zamanda tetiklenir.

Manuel çalıştırma

Workflows sayfasında hedef iş akışının adına tıklayın. Sağ üst köşede Run düğmesine tıklayın ve iş akışını çalıştırmak için bir yöntem seçin.

Manually Run (Varsayılan): İş akışını programından bağımsız olarak hemen çalıştırır.

Backfill: Başarısız veya eksik kalan çalıştırmalardaki verileri düzeltmek için iş akışını geçmiş bir dönem için yeniden çalıştırır. Aşağıdaki parametreleri yapılandırın:

Parametre	Açıklama
Cycle	Sistem, seçtiğiniz zaman aralığı için iş akışı çalıştırmaları oluşturur. Geçerli zaman seçilen döngünün başlangıcını geçtiğinde sistem geriye dönük doldurma çalıştırmalarını otomatik olarak oluşturur ve yürütür. İş akışının planlanan çalıştırma zamanı seçilen döngü içindeyse geriye dönük doldurma iş akışı çalıştırması oluşturulur ve çalıştırılır. İş akışı zaman değişkenleri (örneğin `${ds}`) içeriyorsa sistem bunları otomatik olarak seçilen döngünün zamanıyla değiştirir.
Parallelism	Sistemin eşzamanlı olarak zamanladığı geriye dönük doldurma iş akışı çalıştırma sayısıdır. Varsayılan değer: 1. Sistem, çalıştırmaları iş döngüsüne göre artan sırada zamanlar ve önceki çalıştırmalar tamamlandıkça sonraki çalıştırmaları başlatır. 1 değeri geriye dönük doldurma işlemini seri olarak çalıştırır. 1'den büyük bir değer, geriye dönük doldurma işlemini iş döngüsüne göre artan sırada eşzamanlı olarak çalıştırır. Not Çalıştırmalar iş döngüsüne göre artan sırada zamanlanır ancak tamamlanma sırası, her iş akışının çalışma süresine bağlıdır ve zamanlama sırasına uygun olması garanti edilmez.
Resource Queue	İş akışının varsayılan kaynak kuyruğunu kullanır. Üretim ortamındaki başka bir kullanılabilir kuyruğu seçebilirsiniz.
Remarks	Gelecekteki yönetim ve sorun gidermeye yardımcı olması için geriye dönük doldurma çalıştırmasına ilişkin bir açıklama.
More	Failure Notification: Geriye dönük doldurma iş akışı çalıştırması başarısız olduğunda uyarı almak için bir e-posta adresi belirtin. Node resource queue priority: Varsayılan olarak devre dışıdır. Etkinleştirildiğinde iş akışındaki her düğüm, o düğüm için yapılandırılan Driver ve Executor kaynak kuyruklarında çalışır ve kuyruk yapılandırılmamış düğümler yukarıda belirtilen kaynak kuyruğunu kullanır. Devre dışı bırakıldığında tüm düğümler yukarıda belirtilen kaynak kuyruğunu kullanır. İş akışı CPU ve GPU kuyruklarının karışımını kullanıyorsa bu seçeneği etkinleştirmenizi öneririz.

Çalıştırma durumunu görüntüleme

Hedef iş akışı için Workflow Runs Status ve Workflow Job Runs Status sütunlarında tüm iş akışı ve düğüm çalıştırmalarının durumunu görüntüleyebilirsiniz.

İş akışı çalıştırma durumu

Durum	Açıklama
Mavi	Çalışıyor
Yeşil	Başarılı
Kırmızı	Başarısız
Mor	Bekliyor

İş akışı düğümü çalıştırma durumu

Durum	Açıklama
Mavi	Çalışıyor
Yeşil	Başarılı
Kırmızı	Başarısız
Sarı	Yeniden deneniyor
Mor	Bekliyor

İlgili konular

Temel iş akışı kavramları hakkında daha fazla bilgi için bkz. Temel kavramlar.
İş akışı ve düğüm çalıştırmalarını görüntüleme hakkında bilgi için bkz. İş akışı ve düğüm çalıştırmalarını yönetme.