Tüm Ürünler
Search
Belge Merkezi

DataWorks:Düğüm Türleri

Son Güncelleme:Oct 05, 2026

DataWorks Veri Geliştirme (DataStudio), veri işleme gereksinimleriniz için çeşitli düğümler sunar. Bu düğümler arasında veri entegrasyonu düğümleri; ODPS SQL, Hologres SQL ve EMR Hive gibi hesaplama kaynağı düğümleri ile sanal düğümler ve Check düğümleri gibi genel amaçlı düğümler yer alır.

Önemli

Veri Geliştirme ortamında ODPS SQL, Hologres SQL veya EMR Hive gibi bir hesaplama kaynağı düğümü oluşturamıyorsanız sol gezinme bölmesinde Computing Resource seçeneğine tıklayın ve ilgili hesaplama kaynağının bağlı olup olmadığını kontrol edin. Kaynak bağlı olmasına rağmen düğümü hala oluşturamıyorsanız önbelleğe alınan verileri güncellemek için geçerli sayfayı yenileyin. Ayrıca tarayıcınızda gizli modu etkinleştirmeyi deneyebilirsiniz.

Veri senkronizasyon düğümleri


Veri entegrasyon düğümü


Kullanım


Düğüm kodu


TaskType


Çevrimdışı senkronizasyon düğümü


Periyodik çevrimdışı (toplu iş) veri senkronizasyonu için kullanılır. Karmaşık senaryolarda birbirinden farklı çeşitli veri kaynakları arasında veri senkronizasyonunu destekler. Çevrimdışı senkronizasyonun desteklediği veri kaynakları hakkında daha fazla bilgi için bkz. Desteklenen veri kaynakları ve senkronizasyon çözümleri.


23


DI


Gerçek zamanlı senkronizasyon düğümü


Artımlı verilerin gerçek zamanlı senkronizasyonu için kullanılır. Gerçek zamanlı senkronizasyon; gerçek zamanlı okuma, dönüştürme ve yazma olmak üzere üç temel eklenti içerir. Bu eklentiler tanımlanmış bir ara veri formatı aracılığıyla etkileşime girer. Gerçek zamanlı senkronizasyonun desteklediği veri kaynakları hakkında daha fazla bilgi için bkz. Desteklenen veri kaynakları ve senkronizasyon çözümleri.


900


RI

Not

Veri Geliştirme (DataStudio) arayüzünde oluşturduğunuz düğümlere ek olarak Data Integration ana sitesi çeşitli senkronizasyon çözümleri destekler. Örnekler arasında tam ve artımlı verilerin gerçek zamanlı senkronizasyonu ile tüm veritabanlarının çevrimdışı senkronizasyonu yer alır. Daha fazla bilgi için bkz. Data Integration'daki senkronizasyon görevi yetenekleri. Data Integration ana sitesindeki görevlerin kodu genellikle 24 şeklindedir.

Motor hesaplama düğümleri

Bir iş akışında belirli bir motora karşılık gelen bir düğüm oluşturabilirsiniz. Ardından bu düğümü veri geliştirmek için kullanabilir ve kodu yürütülmesi amacıyla ilgili hesaplama motoruna gönderebilirsiniz.

DataWorks ile entegre motor

DataWorks'ün motor yeteneklerini sarmalama şekli

Düğüm kodu

TaskType

MaxCompute

ODPS SQL düğümü

10

ODPS_SQL

ODPS Spark düğümü

225

ODPS_SPARK

PyODPS 2 düğümü

221

PY_ODPS

PyODPS 3 düğümü

1221

PYODPS3

ODPS Script düğümü

24

ODPS_SQL_SCRIPT

ODPS MR düğümü

11

ODPS_MR

SQL script şablonu düğümü

1010

COMPONENT_SQL

E-MapReduce

EMR Hive düğümü

227

EMR_HIVE

EMR MR düğümü

230

EMR_MR

EMR Spark SQL düğümü

229

EMR_SPARK_SQL

EMR Spark düğümü

228

EMR_SPARK

EMR Shell düğümü

257

EMR_SHELL

EMR Presto düğümü

259

EMR_PRESTO

EMR Impala düğümü

260

EMR_IMPALA

EMR Spark Streaming düğümü

264

EMR_SPARK_STREAMING

EMR Kyuubi düğümü

268

EMR_KYUUBI

EMR Trino düğümü

267

EMR_TRINO

EMR JAR

231

EMR_JAR

EMR File

232

EMR_FILE

CDH

CDH Hive düğümü

270

CDH_HIVE

CDH Spark düğümü

271

CDH_SPARK

CDH MR düğümü

273

CDH_MR

CDH Presto düğümü

278

CDH_PRESTO

CDH Impala düğümü

279

CDH_IMPALA

CDH Spark SQL düğümü

272

CDH_SPARK_SQL

AnalyticDB for PostgreSQL

AnalyticDB for PostgreSQL düğümü

-

-

AnalyticDB for MySQL

AnalyticDB for MySQL düğümü

1000126

-

Hologres

Hologres SQL düğümü

1093

HOLOGRES_SQL

Tek tıkla MaxCompute tablo şeması senkronizasyon düğümü

1094

HOLOGRES_SYNC_DDL

Tek tıkla MaxCompute veri senkronizasyon düğümü

1095

HOLOGRES_SYNC_DATA

ClickHouse

ClickHouse SQL

1301

CLICK_SQL

Algoritma (makine öğrenimi)

PAI Designer düğümü

1117

PAI_STUDIO

PAI DLC düğümü

1119

PAI_DLC

Veritabanı

MySQL düğümü

1000125

-

SQL Server düğümü

10001

-

Oracle düğümü

10002

-

PostgreSQL düğümü

10003

-

StarRocks

10004

-

DRDS düğümü

10005

-

PolarDB MySQL düğümü

10006

-

PolarDB PostgreSQL düğümü

10007

-

Doris düğümü

10008

-

MariaDB düğümü

10009

-

SelectDB düğümü

10010

-

Redshift düğümü

10011

-

SAP HANA düğümü

10012

-

Vertica düğümü

10013

-

DM (Dameng) düğümü

10014

-

KingbaseES (Renmin Jincang) düğümü

10015

-

OceanBase düğümü

10016

-

DB2 düğümü

10017

-

GBase 8a düğümü

10018

-

Diğer

Data Lake Analytics düğümü

1000023

-

Genel amaçlı düğümler

Motor düğümleri, karmaşık mantığı işlemek için genel amaçlı düğümlerle birlikte kullanılabilir. Bir iş akışında gerekli düğümleri genel amaçlı düğüm grubunda oluşturabilir ve bunları motor düğümleriyle birleştirerek karmaşık mantığı uygulayabilirsiniz.

İş senaryosu

Düğüm türü

Kullanım notları

Düğüm kodu

TaskType

İş yönetimi

Sanal düğüm

Sanal düğüm bir kontrol düzlemi düğümüdür. Herhangi bir veri üretmeyen kuru çalıştırma düğümüdür. Genellikle düğümleri ve iş akışlarını yönetmenize yardımcı olmak amacıyla bir iş akışının kök düğümü olarak kullanılır.

99

VIRTUAL

Olay tetikleyici

HTTP tetikleyici düğümü

Bu düğümü kullanarak başka bir zamanlama sistemindeki bir görev tamamlandıktan sonra DataWorks'te bir görevi tetikleyebilirsiniz.

Not

DataWorks artık çapraz kiracı iş birliği düğümlerinin oluşturulmasını desteklememektedir. Çapraz kiracı iş birliği düğümleri kullanıyorsanız bunları HTTP tetikleyici düğümleriyle değiştirin. HTTP tetikleyici düğümleri aynı özellikleri sağlar.

1114

SCHEDULER_TRIGGER

OSS Nesne Denetimi düğümü

OSS nesnelerinin oluşturulmasını izleyerek alt düğümlerin yürütülmesini tetikler.

239

OSS_INSPECT

FTP Denetimi düğümü

FTP dosyalarının oluşturulmasını izleyerek alt düğümlerin yürütülmesini tetikler.

Not

DataWorks resmi olarak FTP Denetimi düğümü yerine bir Check düğümü kullanmanızı önerir.

1320

FTP_CHECK

Check düğümü

Bir hedef nesnenin aktif olup olmadığını denetlemek için kullanılır. Check düğümü denetim ilkesini karşıladığında başarılı bir çalışma durumu döndürür. Aşağı akış bağımlılıkları varsa alt görevler tetiklenir. Aşağıdaki hedef nesneler denetlenebilir:

  • MaxCompute bölümlendirilmiş tablosu

  • FTP dosyası

  • OSS dosyası

  • HDFS

  • OSS-HDFS

241

CHECK_NODE

Veri Kalitesi

Veri Karşılaştırma düğümü

Veri Karşılaştırma düğümü bir iş akışındaki farklı tabloların verilerini birden çok şekilde karşılaştırmanıza olanak tanır.

1331

DATA_SYNCHRONIZATION_QUALITY_CHECK

Parametre atama ve aktarma

Atama düğümü

Parametre aktarmak için kullanılır. Atama düğümünün yerleşik çıkışı son sorgunun veya çıktının sonucunu düğüm bağlamı özelliği aracılığıyla alt düğümlere iletir. Bu sayede düğümler arası parametre aktarımı gerçekleştirilir.

1100

CONTROLLER_ASSIGNMENT

Parametre düğümü

Üst düğümlerden gelen parametreleri toplamak ve bunları alt düğümlere dağıtmak için kullanılır.

1115

PARAM_HUB

Kontrol

for-each düğümü

Bir atama düğümü tarafından aktarılan sonuç kümesini yinelemek için kullanılır.

1106

CONTROLLER_TRAVERSE

do-while düğümü

Belirli bir düğüm mantığının yürütülmesini döngüye almak için kullanılır. Ayrıca bir atama düğümüyle birlikte kullanarak atama düğümü tarafından aktarılan sonuç çıktısını döngüye alabilirsiniz.

1103

CONTROLLER_CYCLE

Dal düğümü

Bir üst düğümün sonucunu değerlendirmek ve farklı sonuçlar için hangi dal mantığının izleneceğini belirlemek için kullanılır. Bir atama düğümüyle birlikte kullanılabilir.

1101

CONTROLLER_BRANCH

Birleştirme düğümü

Üst düğümlerin çalışma durumlarını birleştirmek için kullanılır. Bu sayede dal düğümünün alt düğümleri için bağımlılık ekleme ve yürütme tetikleme sorunları çözülür.

1102

CONTROLLER_JOIN

Diğer

Shell düğümü

Shell düğümü standart Shell sözdizimini destekler ancak etkileşimli sözdizimini desteklemez.

6

DIDE_SHELL

Function Compute düğümü

Olay işlevlerini periyodik olarak zamanlamak ve işlemek ile diğer düğüm türleriyle entegre ederek ortak zamanlama yapmak için kullanılır.

1330

FUNCTION_COMPUTE

Veri İtme düğümü

Bir iş akışındaki sorgu verilerini DingTalk gruplarına, Lark gruplarına, WeCom gruplarına ve Teams'e itmek için kullanılır. Bu sayede ekip üyeleri en son verileri anında alıp takip edebilir.

1332

DATA_PUSH