:İş akışı oluşturma

Ön koşullar

Başlamadan önce çalışma alanınızda bank_data iş verisi tablosunu ve result_table hedef tablosunu oluşturun. İş verisi tablosunda veri bulunmalıdır. Daha fazla bilgi için bkz. Tablo oluşturma ve veri yükleme.

Arka plan

DataWorks'te bir iş akışı içindeki düğümler arasındaki bağımlılıkları görsel olarak yapılandırabilirsiniz. İş akışları, verileri işlemeyi ve bağımlılıklarını tanımlamanızı sağlar. Tek bir çalışma alanı içinde birden fazla iş akışı oluşturabilirsiniz. Daha fazla bilgi için bkz. İş akışı oluşturma.

İş akışı oluşturma

1. DataWorks konsolu oturum açın. Hedef bölgede sol gezinme bölmesinden Data Development and O&M > Data Development seçeneğine tıklayın. Açılan listeden bir çalışma alanı seçin ve Go to > Data Development öğesine tıklayın.

2. Data Studio sayfasında imleci simgesinin üzerine getirin ve Create Workflow seçeneğine tıklayın.

3. Create Workflow iletişim kutusunda Business Name ve Description alanlarını doldurun.

4. Create düğmesine tıklayın.

Düğüm oluşturma ve bağımlılıkları yapılandırma

İş akışınızın kök düğümü olarak hizmet vermesi için bir zero load node oluşturmanızı öneririz. Bu düğüm, tüm iş akışının yürütülmesini kontrol edebilir. İş akışını tasarlamak için şu adımları izleyin:

1. İş akışı adına çift tıklayarak geliştirme panelini açın. General > > > Zero Load Node yolunu izleyin.

   Zero Load Node öğesini sağ taraftaki geliştirme paneline de sürükleyebilirsiniz.

2. Create Node iletişim kutusunda bir Path seçin, Node Name alanına start yazın ve OK düğmesine tıklayın.

3. Önceki adımları tekrarlayarak insert_data adlı bir ODPS SQL düğümü oluşturun.

4. start düğümünden insert_data düğümüne bir çizgi sürükleyerek start düğümünü insert_data düğümünün üst düğümü olarak ayarlayın.

Zero-load node'un üst akış bağımlılığını yapılandırma

Zero load node genellikle tüm iş akışını kontrol eder ve diğer tüm düğümler için nihai üst düğüm olarak görev yapar.

Genellikle zero load node için Parent Nodes olarak Add Root Node seçeneğini ayarlayın:

1. Zero load node adına çift tıklayarak düzenleyicisini açın.

2. Sağ taraftaki bölmede Scheduling sekmesine tıklayın.

3. Scheduling Dependencies bölümünde, çalışma alanı kök düğümünü zero load node'un üst düğümü olarak ayarlamak için Add Root Node düğmesine tıklayın.

4. Düğümü kaydedin ve gönderin.

   Önemli

   Düğümü göndermeden önce Rerun attribute ve Parent Nodes özelliklerini yapılandırmanız gerekir.

   1. Araç çubuğunda düğümü kaydetmek için simgesine tıklayın.

   2. Araç çubuğunda simgesine tıklayın.

   3. Submit iletişim kutusunda bir Change Description girin.

   4. OK düğmesine tıklayın.

ODPS SQL düğümünü düzenleme ve çalıştırma

Bu bölümde, insert_data ODPS SQL düğümündeki SQL kodunu kullanarak ev kredisi olan bekârların sayısını eğitim düzeyine göre gruplandırarak sorgulama ve sonuçları alt akış düğümleri tarafından daha ileri analiz veya sunum için kaydetme işlemi açıklanmaktadır.

1. ODPS SQL düğümünün düzenleyicisini açın ve aşağıdaki kodu girin.

   Sözdizimi hakkında daha fazla bilgi için bkz. SQL genel bakış.

   INSERT OVERWRITE TABLE result_table  --Insert data into the result_table table.
   SELECT education
       , COUNT(marital) AS num
   FROM bank_data
   WHERE housing = 'yes'
       AND marital = 'single'
   GROUP BY education;

2. Kod içindeki bank_data üzerine sağ tıklayın ve Delete Input seçeneğini belirleyin.

   Tablo oluşturma ve veri yükleme bölümünde oluşturulan bank_data tablosu zamanlanmış bir düğüm tarafından oluşturulmamıştır. Bir düğüm böyle bir tablodan veri okuyorsa, kod düzenleyicide tablo adına sağ tıklayarak otomatik olarak ayrıştırılan bağımlılığı kaldırabilirsiniz. Alternatif olarak, bağımlılığın oluşturulmasını önlemek için kodun başına özel bir yorum ekleyebilirsiniz.

   Not

   DataWorks'teki zamanlama bağımlılıkları, alt akış düğümlerinin düzenli aralıklarla güncellenen üst akış düğümlerindeki verilere güvenilir bir şekilde erişmesini sağlar. Platform, DataWorks içinde zamanlanmış düğümler tarafından güncellenmeyen tabloları izleyemez. Zamanlanmış bir görev tarafından oluşturulmayan bir tablodan veri seçen bir düğüm için, DataWorks'ün otomatik olarak oluşturduğu bağımlılığı manuel olarak silmeniz gerekir.

3. Kodunuzu kaydetmek için araç çubuğundaki simgesine tıklayın.

4. Kodu çalıştırmak için simgesine tıklayın.

   Çalıştırma tamamlandıktan sonra sayfanın alt kısmındaki çalışma günlüğünü ve sonuçları görüntüleyebilirsiniz.

İş akışını gönderme

1. insert_data ODPS SQL düğümünü çalıştırıp hata ayıkladıktan sonra iş akışı tuvaline dönün.

2. Araç çubuğundaki simgesine tıklayın.

3. Submit iletişim kutusunda göndermek istediğiniz düğümleri seçin, bir Change Description girin ve Ignore I/O Inconsistency Alerts seçeneğini belirleyin.

4. OK düğmesine tıklayın.

   İş akışını gönderdikten sonra, Workflow altındaki düğüm listesinde her düğümün gönderim durumunu kontrol edebilirsiniz. Bir düğüm adının solundaki simgesi, düğümde gönderilmemiş değişiklikler olduğunu gösterir. Böyle bir simge yoksa düğümde gönderilmemiş değişiklik yoktur.

Sonraki adımlar

Artık bir iş akışı oluşturup gönderdiğinize göre, verileri farklı türdeki veri kaynaklarına geri yazmak için bir senkronizasyon görevi nasıl oluşturulacağını öğrenmek üzere sonraki eğitime geçin. Daha fazla bilgi için bkz. Senkronizasyon görevi oluşturma.