Bir veri aktarımı düğümü, DataWorks iş akışındaki önceki düğümlerin sorgu sonuçlarını DingTalk, Lark, WeCom, Teams veya e-posta aracılığıyla teslim ederek ekibinizin en güncel verilerden haberdar olmasını sağlar.
Nasıl çalışır
Veri aktarımı düğümü, DataWorks iş akışındaki SQL sorgu düğümleri ve atama düğümlerinden gelen çıkış parametrelerini almak için Input and Output Parameters bölümünü kullanır. Bu parametreleri mesaj gövdesinde yer tutucu olarak kullanarak hedefe aktarabilirsiniz.
Bir SQL sorgu düğümü çalıştırıldığında, sorgu sonuçlarını içeren bir
outputsparametresi oluşturur ve bunları sonraki düğümlere iletir. Daha fazla bilgi için bkz. Düğüm bağlamını yapılandırma.Veri aktarımı düğümünde mesaj gövdesini yapılandırırken, Markdown bileşeni içinde
${Parametre adı}biçimini kullanarak önceki bir düğümden gelen çıkış parametrelerine başvurabilir ve bunları görüntüleyebilirsiniz.Verileri tablo bileşeninde görüntülemek için, bileşenin ilişkili parametre ayarında önceki SQL sorgusundan alan adlarını seçin.
Ön koşullar
DataWorks hizmeti etkinleştirilmiş olmalıdır. Daha fazla bilgi için bkz. Satın alma kılavuzu.
Bir DataWorks çalışma alanı oluşturulmuş olmalıdır. Daha fazla bilgi için bkz. Çalışma alanı oluşturma.
DataWorks çalışma alanında bir iş akışı oluşturulmuş olmalıdır.
Bu düğüm yalnızca sunucusuz kaynak gruplarında çalışabildiği için bir sunucusuz kaynak grubu gereklidir. Sunucusuz kaynak grubu satın almak ve kullanmak için bkz. Sunucusuz kaynak gruplarını kullanma.
Kaynak grubu için genel ağ erişimi etkinleştirilmiş olmalıdır. Daha fazla bilgi için bkz. Ağ bağlantısı çözümlerine genel bakış.
Sınırlamalar
-
Farklı hedeflere veri aktarılırken aşağıdaki veri boyutu sınırlamaları geçerlidir:
DingTalk: Mesaj boyutu 20 KB'yi aşamaz.
Lark: Mesaj boyutu 20 KB'yi aşamaz ve görüntüler 10 MB'ten küçük olmalıdır.
WeCom: Her sohbet botu dakikada en fazla 20 mesaj gönderebilir.
Teams: Mesaj boyutu 28 KB'yi aşamaz.
E-posta: Her veri aktarımı görevi yalnızca tek bir e-posta gövdesini destekler. Diğer sınırlamalar için e-posta hizmet sağlayıcınızın SMTP sınırlamalarına bakın.
Veri aktarımı düğümü yalnızca aşağıdaki bölgelerdeki çalışma alanlarında kullanılabilir: China (Hangzhou), China (Shanghai), China (Beijing), China (Shenzhen), China (Chengdu), China (Hong Kong), Singapore, Malaysia (Kuala Lumpur), US (Silicon Valley), US (Virginia) ve Germany (Frankfurt).
1. Önceki bir düğüm oluşturma
Bir veri aktarımı düğümü, hedefe aktarmak üzere önceki bir düğümün bağlamından Context Parameters değerlerini alır. Bir veri aktarımı düğümü oluşturmadan önce bir SQL sorgu düğümü veya atama düğümü oluşturun.
MaxCompute verilerini aktarmak için verileri sorgulamak ve Özellikler panelinde çıkış parametreleri oluşturmak amacıyla bir atama düğümü kullanmanız gerekir. Daha fazla bilgi için bkz. MaxCompute verilerini aktarma.
Önceki düğüm farklı bir veri kaynağını sorguluyorsa, bir
outputsçıkış parametresi oluşturur. Bu parametre daha sonra veri aktarımı düğümüne iletilir. Daha fazla bilgi için bkz. En iyi uygulamalar: İş akışında veri aktarımı düğümü yapılandırma.
SQL sorgu düğümü
-
DataWorks konsolu oturumunu açın. Hedef bölgede sol gezinme bölmesinde seçeneğine tıklayın. Açılan listeden bir çalışma alanı seçin ve Go to Data Development öğesine tıklayın.
Tuvali açmak için iş akışınıza çift tıklayın. Bir SQL sorgu düğümü oluşturmak için
simgesine tıklayın.-
Düzenleyicisini açmak ve sorgunuzu yazmak için SQL sorgu düğümüne çift tıklayın.
NotBir veri aktarımı düğümü doğrudan bir ODPS SQL sorgusundan veri çekemez. Bunun yerine bir atama düğümü kullanmalı ve sorguyu bunun içinde yapılandırmalısınız. Daha fazla bilgi için bkz. Aktarım iş akışı yapılandırma.
-
Sağ bölmede düğümün zamanlama ayarlarını yapılandırmak için Scheduling seçeneğine tıklayın.
Configure Scheduling Settings adımları hakkında ayrıntılı bilgi için bkz. Temel özellikleri yapılandırma, Zaman özelliği yapılandırması, Kaynak özelliklerini yapılandırma, Aynı döngüde zamanlama bağımlılıklarını yapılandırma ve Düğüm bağlamını yapılandırma.
Scheduling panelinde yoluna gidin ve SQL sorgu sonuçlarını bir çıkış parametresi olarak ortaya çıkarmak için Add assignment parameter seçeneğine tıklayın.
Kaydet simgesine tıklayın.
Atama düğümü
-
DataWorks konsolu oturumunu açın. Hedef bölgede sol gezinme bölmesinde seçeneğine tıklayın. Açılan listeden bir çalışma alanı seçin ve Go to Data Development öğesine tıklayın.
Tuvali açmak için iş akışınıza çift tıklayın. Bir atama düğümü oluşturmak için
simgesine tıklayın.-
Düzenleyicisini açmak için atama düğümüne çift tıklayın.
Bir atama düğümü değer ataması için ODPS SQL, Shell veya Python kullanır. Daha fazla bilgi için bkz. Atama düğümü.
Düğümü yapılandırdıktan sonra
Kaydet simgesine tıklayın.
2. Veri aktarımı düğümü oluşturma
-
İş akışı tuvalinde bir veri aktarımı düğümü oluşturmak için
simgesine tıklayın.
Parametre
Açıklama
Node Type
Açılan listeden Data Push seçeneğini belirleyin.
Path
1. Adımdaki önceki düğümü içeren yolu seçin.
Name
Düğüm için bir ad girin. Yeni veri aktarımı düğümünün yapılandırma sayfasını açmak için üzerine çift tıklayın.
Sağ bölmede Properties seçeneğine tıklayın. altında Add seçeneğine tıklayarak 1. Adım da oluşturduğunuz düğümü önceki bağımlılık olarak ayarlayın.
Properties panelinde altında 28 Haziran 2024 tarihinde veya sonrasında oluşturulmuş bir sunucusuz kaynak grubu seçin. Kaynak grubunuz bu tarihten önce oluşturulduysa yükseltmek için destek talebi göndermeniz gerekir.
Properties panelinde altında bir giriş parametresi oluşturmak için Add seçeneğine tıklayın. Değer olarak 1. Adımdaki sorgu düğümünün çıkış parametresini seçin. Ardından Scheduling panelini kapatın.
-
Düğümün yapılandırma sayfasında mesajın hedefini, başlığını ve gövdesini yapılandırın.
-
Destination açılan listesinden bir hedef seçin. İstediğiniz hedef listede yoksa oluşturmak için Create Data Push Destination seçeneğine tıklayın.
Parametre
Açıklama
Type
Desteklenen türler: DingTalk, Lark, WeCom, Teams ve E-posta.
Object
Hedef için ad.
Webhook
Bir DingTalk, Lark veya WeCom sohbet botu için Webhook URL'si; Teams için gelen Webhook veya e-posta için SMTP ayrıntıları. Bu bilgileri hedef platformdan alın.
NotLark bot Webhook'unu nasıl alacağınızı öğrenmek için bkz. Lark Webhook tetikleyicisi yapılandırma.
Teams Webhook'unu nasıl alacağınızı öğrenmek için bkz. Microsoft Teams iş akışlarını kullanarak gelen bir Webhook oluşturma.
Aktarım hedeflerini yönetmek için:
DataWorks konsolu oturumunu açın. Hedef bölgede sol gezinme bölmesinde seçeneğine tıklayın. Açılan listeden bir çalışma alanı seçin ve Go to DataService Studio öğesine tıklayın.
Service Development sayfasında sol alt köşedeki
Ayarlar simgesine tıklayın ve Destination Management sekmesine gidin. Bu sekmede mevcut hedefleri yönetebilir veya yeni bir tane eklemek için Create Data Push Destination seçeneğine tıklayabilirsiniz. Daha fazla bilgi için bkz. Webhook veri aktarım hedefi oluşturma.
Name: Mesaj için bir başlık girin.
-
Body: Markdown ve Tablo bileşenleri ekleyebilirsiniz. Daha fazla bilgi için bkz. Aktarım içeriğini yapılandırma.
Not-
Önceki düğüm bir SQL sorgu düğümü ise:
Bir veri aktarımının Markdown gövdesinde, önceki çıkış parametrelerini almak için SQL sorgusundan alan adlarını
${field_name}biçiminde yer tutucu olarak kullanın.Bir veri aktarımı gövdesindeki tablolar için, verileri almak üzere önceki bir SQL sorgusundan alan adlarını Parameters olarak kullanın.
Önceki düğüm bir atama düğümü ise, mesaj gövdesinde
${Giriş parametresi adı}biçiminde bir yer tutucu kullanmanız gerekir. ${Giriş parametresi adı}, veri aktarımı düğümünde yapılandırdığınız Input Parameters değerinin adıdır.
-
-
Veri aktarımı düğümünü kaydetmek için
Kaydet simgesine tıklayın.
3. Görevi çalıştırma ve dağıtma
Veri aktarımı iş akışını yapılandırdıktan sonra doğru çalıştığını doğrulamak için test edin, ardından görevi gönderin ve dağıtın.
İş akışı tuvalinde iş akışını çalıştırmak için
Çalıştır simgesine tıklayın.Tüm düğümlerde
başarı simgesi göründükten sonra iş akışını göndermek için
Gönder simgesine tıklayın.Submission iletişim kutusunda göndermek istediğiniz düğümleri seçin ve Ignore I/O Inconsistency Alerts onay kutusunu işaretleyin.
Submission seçeneğine tıklayın.
Düğümler başarıyla gönderildikten sonra bunları dağıtın. Daha fazla bilgi için bkz. Görevleri yayımlama.
En iyi uygulamalar
Veri aktarımı düğümü basit aktarım, birleşik aktarım, betik tabanlı aktarım, koşullu aktarım ve MaxCompute aktarımı gibi çeşitli iş akışı desenlerini destekler. Daha fazla bilgi için bkz. En iyi uygulamalar: İş akışında veri aktarımı düğümü yapılandırma.
Sonraki adımlar
Dağıtımdan sonra görevi Operation Center'da yönetin. Daha fazla bilgi için bkz. Otomatik tetiklenen düğümlerde temel bakım ve onarım işlemleri gerçekleştirme.