Gunakan node Pemeriksaan untuk memeriksa ketersediaan sumber data atau tugas sinkronisasi real-time - DataWorks

DataWorks menyediakan node Pemeriksaan untuk memeriksa ketersediaan objek target, seperti tabel partisi MaxCompute, file FTP, file OSS, file HDFS, file OSS_HDFS, dan tugas sinkronisasi real-time. Jika kebijakan node Pemeriksaan terpenuhi, node tersebut mengembalikan status sukses. Jika suatu task bergantung pada objek target, Anda dapat menggunakan node Pemeriksaan untuk memeriksa objek tersebut dan menetapkan task sebagai dependensi hilir. Ketika kebijakan node Pemeriksaan terpenuhi, node berjalan dengan sukses dan memicu task hilir. Topik ini menjelaskan objek yang didukung oleh node Pemeriksaan, kebijakan pemeriksaannya, serta cara mengonfigurasi node Pemeriksaan.

Objek pemeriksaan yang didukung dan kebijakan pemeriksaan

Node Pemeriksaan mendukung pemeriksaan pada sumber data dan tugas sinkronisasi real-time dengan kebijakan sebagai berikut:

Sumber data
- Tabel partisi MaxCompute dan DLF (tabel partisi Paimon)
  Catatan
  Node Pemeriksaan mendukung tabel partisi MaxCompute, tetapi tidak mendukung tabel non-partisi MaxCompute.
  Node Pemeriksaan menyediakan dua kebijakan pemeriksaan untuk menentukan ketersediaan data dalam tabel partisi MaxCompute:
  - Kebijakan 1: Periksa apakah partisi target ada
    Jika node Pemeriksaan menemukan bahwa partisi target dari tabel partisi MaxCompute tersedia, platform menganggap data telah siap.
  - Kebijakan 2: Periksa apakah partisi target telah diperbarui dalam periode tertentu
    Jika node Pemeriksaan menemukan bahwa partisi target belum diperbarui dalam periode yang ditentukan, platform menganggap penulisan data telah selesai dan tabel tersedia.
- File FTP, OSS, HDFS, atau OSS_HDFS
  Jika node Pemeriksaan menemukan bahwa file target FTP, OSS, HDFS, atau OSS_HDFS tersedia, platform menganggap file tersebut siap digunakan.
Tugas sinkronisasi real-time
Pemeriksaan menggunakan waktu mulai terjadwal dari node Pemeriksaan sebagai titik referensi. Jika tugas sinkronisasi real-time telah menyelesaikan penulisan data hingga titik tersebut, platform menganggap pemeriksaan berhasil.

Anda juga harus menentukan interval pemeriksaan dan kondisi penghentian untuk node Pemeriksaan. Interval pemeriksaan adalah durasi antar pemeriksaan, sedangkan kondisi penghentian dapat berupa jumlah maksimum pemeriksaan atau waktu akhir. Jika task tidak lulus pemeriksaan saat kondisi penghentian tercapai, node Pemeriksaan gagal dan berhenti. Untuk informasi selengkapnya tentang cara mengonfigurasi kebijakan, lihat Langkah 2: Konfigurasikan kebijakan pemeriksaan.

Catatan

Node Pemeriksaan dapat secara berkala memeriksa objek target. Anda dapat mengonfigurasi waktu terjadwal untuk node Pemeriksaan berdasarkan waktu mulai pemeriksaan yang diharapkan. Setelah kondisi penjadwalan terpenuhi, node Pemeriksaan mulai berjalan dan tetap aktif hingga kondisi pemeriksaan terpenuhi—menghasilkan status sukses—atau gagal setelah periode pemeriksaan yang berkepanjangan tanpa keberhasilan. Untuk informasi selengkapnya tentang konfigurasi penjadwalan, lihat Langkah 3: Konfigurasikan properti penjadwalan.
Node Pemeriksaan menggunakan resource penjadwalan hingga pemeriksaan selesai.

Batasan

Batasan kelompok sumber daya: Task node Pemeriksaan hanya dapat berjalan pada kelompok sumber daya Serverless. Untuk informasi tentang cara membeli dan menggunakan kelompok sumber daya Serverless, lihat Gunakan kelompok sumber daya Serverless.
Batasan sumber data: Node Pemeriksaan tidak mendukung sumber data FTP yang protokolnya diatur ke SFTP dan autentikasi dilakukan menggunakan Key.
Batasan fitur node
- Node Pemeriksaan hanya dapat memeriksa satu objek. Jika task Anda bergantung pada beberapa objek, seperti beberapa tabel partisi MaxCompute, Anda harus membuat beberapa node Pemeriksaan untuk memeriksa setiap objek secara terpisah.
- Interval pemeriksaan untuk node Pemeriksaan harus antara 1 menit hingga 30 menit.
Batasan edisi DataWorks: Node Pemeriksaan hanya tersedia di DataWorks Edisi Profesional dan yang lebih tinggi. Untuk melakukan upgrade DataWorks, lihat Upgrade DataWorks.
Wilayah yang didukung: Anda dapat menggunakan node Pemeriksaan di ruang kerja yang berada di wilayah berikut: Tiongkok (Hangzhou), Tiongkok (Shanghai), Tiongkok (Beijing), Tiongkok (Shenzhen), Tiongkok (Chengdu), Tiongkok (Hong Kong), Jepang (Tokyo), Singapura, Malaysia (Kuala Lumpur), Indonesia (Jakarta), Jerman (Frankfurt), Inggris (London), AS (Silicon Valley), dan AS (Virginia).

Prasyarat

Sebelum menggunakan node Pemeriksaan untuk memeriksa sumber data, Anda harus membuat sumber data untuk jenis objek yang ingin diperiksa.

Periksa tipe objek	Persiapan	Referensi
Tabel partisi MaxCompute	Mesin komputasi MaxCompute telah dibuat dan di-bind ke DataStudio. Saat Anda membuat dan mengikat mesin komputasi MaxCompute di DataWorks, sumber data MaxCompute secara otomatis dibuat. Tabel partisi MaxCompute telah dibuat.	Bind mesin komputasi MaxCompute Persiapan: Bind mesin komputasi atau kluster Buat dan gunakan tabel MaxCompute
File FTP	Sumber data FTP telah dibuat. Di DataWorks, Anda harus terlebih dahulu membuat sumber data FTP untuk layanan FTP Anda. Kemudian, Anda dapat menggunakan sumber data tersebut untuk mengakses data dari layanan tersebut.	Buat sumber data FTP
File OSS	Sumber data OSS telah dibuat, dan Mode Akses-nya diatur ke Access Key. Di DataWorks, Anda harus terlebih dahulu membuat sumber data OSS untuk bucket OSS Anda. Kemudian, Anda dapat menggunakan sumber data tersebut untuk mengakses data di bucket tersebut. Catatan Saat ini, node Pemeriksaan hanya dapat mengakses sumber data OSS dalam mode Access Key. Sumber data OSS yang dikonfigurasi dengan otorisasi berbasis peran RAM tidak dapat digunakan dalam node Pemeriksaan.	Buat bucket Buat sumber data OSS
File HDFS	Sumber data HDFS telah dibuat. Di DataWorks, Anda harus terlebih dahulu membuat sumber data HDFS untuk file HDFS Anda. Kemudian, Anda dapat menggunakan sumber data tersebut untuk mengakses data file HDFS.	Buat sumber data HDFS
File OSS_HDFS	Sumber data OSS_HDFS telah dibuat. Di DataWorks, Anda harus terlebih dahulu membuat sumber data OSS_HDFS untuk layanan OSS_HDFS Anda. Kemudian, Anda dapat menggunakan sumber data tersebut untuk mengakses data dari layanan tersebut.	Sumber data OSS-HDFS

Jika Anda menggunakan node Pemeriksaan untuk memeriksa tugas sinkronisasi real-time, task tersebut harus merupakan task sinkronisasi Kafka-ke-MaxCompute. Sebelum menggunakan node Pemeriksaan, Anda harus membuat tugas sinkronisasi real-time tersebut. Untuk informasi selengkapnya, lihat Konfigurasikan tugas sinkronisasi real-time di DataStudio.

Langkah 1: Buat node Pemeriksaan

Buka halaman DataStudio.
Login ke Konsol DataWorks. Di bilah navigasi atas, pilih wilayah yang diinginkan. Di panel navigasi kiri, pilih Data Development and O&M > Data Development. Di halaman yang muncul, pilih ruang kerja yang diinginkan dari daftar drop-down dan klik Go to Data Development.
Klik ikon dan pilih Create Node > General > Check Node.
Di kotak dialog yang muncul, masukkan path dan nama untuk node tersebut.

Langkah 2: Konfigurasikan kebijakan pemeriksaan

Berdasarkan kebutuhan bisnis Anda, pilih untuk memeriksa sumber data atau tugas sinkronisasi real-time, lalu konfigurasikan kebijakan yang sesuai.

Sumber data

Konfigurasikan kebijakan pemeriksaan untuk tabel partisi MaxCompute

Berikut ini penjelasan parameter-parameternya.

Parameter	Description
Data Source Type	Pilih MaxCompute.
Data Source Name	Sumber data tempat tabel partisi MaxCompute yang ingin Anda periksa berada. Jika tidak tersedia sumber data, klik New data source untuk membuatnya. Untuk informasi selengkapnya tentang cara membuat sumber data MaxCompute, lihat Bind a MaxCompute compute engine.
Table Name	Tabel partisi MaxCompute yang ingin Anda periksa. Catatan Anda hanya dapat memilih tabel partisi MaxCompute yang termasuk dalam sumber data yang ditentukan.
Partition	Partisi dari tabel MaxCompute yang ingin Anda periksa. Setelah Anda mengonfigurasi parameter Table Name, Anda dapat melihat pratinjau informasi tabel untuk mengetahui nama partisi. Anda juga dapat menggunakan parameter penjadwalan untuk mendapatkan nama partisi. Untuk informasi selengkapnya tentang penggunaan parameter penjadwalan, lihat Supported formats for scheduling parameters.
Condition for passing check	Menentukan metode pemeriksaan dan kondisi kelulusan untuk tabel partisi. Anda dapat memilih salah satu dari dua metode pemeriksaan berikut: Partition exists: Memeriksa apakah partisi target ada. Exists: Pemeriksaan berhasil, dan platform menganggap tabel partisi tersedia. Does not exist: Pemeriksaan gagal, dan platform menganggap tabel partisi tidak tersedia. Check based on LastModifiedTime: Memeriksa apakah data dalam partisi target telah diperbarui dalam periode tertentu. No update: Pemeriksaan berhasil, dan platform menganggap penulisan data telah selesai serta tabel partisi tersedia. Update exists: Pemeriksaan gagal, dan platform menganggap penulisan data belum selesai serta tabel partisi tidak tersedia. Catatan Anda hanya dapat memeriksa apakah data partisi telah diperbarui dalam rentang waktu 5, 10, 15, 20, 25, atau 30 menit terakhir. Untuk informasi selengkapnya tentang LastModifiedTime, lihat Modify the modification time of a table.
Stop Policy Check	Mengonfigurasi kebijakan penghentian untuk task Check node. Anda dapat menetapkan waktu penghentian atau jumlah maksimum pemeriksaan. Anda juga dapat mengatur frekuensi pemeriksaan: Set stop time: Anda dapat menentukan seberapa sering pemeriksaan dilakukan dalam durasi target (interval pemeriksaan). Jika pemeriksaan tidak berhasil dalam durasi tersebut, task Check secara otomatis berhenti dan ditandai sebagai gagal. Catatan Interval pemeriksaan dapat berkisar antara 1 hingga `30` menit. Jika task hulu mengalami keterlambatan sehingga task Check node dimulai setelah waktu penghentian yang dikonfigurasi, task Check node tetap akan dimulai setelah task hulu selesai, namun hanya melakukan pemeriksaan satu kali. Set stop count: Anda dapat menentukan seberapa sering pemeriksaan dilakukan hingga mencapai jumlah pemeriksaan target (interval pemeriksaan). Jika pemeriksaan tidak berhasil setelah mencapai jumlah tersebut, task Check secara otomatis berhenti dan ditandai sebagai gagal. Catatan Interval pemeriksaan dapat berkisar antara 1 hingga `30` menit. Waktu proses maksimum untuk task Check node adalah 24 jam (1.440 menit). Jumlah maksimum pemeriksaan bergantung pada interval pemeriksaan. Misalnya, jika intervalnya 5 menit, jumlah maksimum pemeriksaan adalah 288. Jika intervalnya 10 menit, jumlah maksimumnya adalah 144. Nilai aktual yang ditampilkan di UI yang berlaku.

Konfigurasikan kebijakan pemeriksaan untuk file FTP

Tabel berikut menjelaskan parameter-parameternya.

Parameter	Deskripsi
Data Source Type	Pilih FTP.
Data Source Name	Sumber data tempat file FTP yang ingin Anda periksa berada. Jika tidak ada sumber data yang tersedia, klik New data source untuk membuatnya. Untuk informasi selengkapnya tentang cara membuat sumber data FTP, lihat Sumber data FTP.
File Path	Path file FTP yang akan diperiksa, misalnya, `/var/ftp/test/`. Jika path yang dimasukkan ada, berarti file dengan nama yang sama ada di path tersebut. Anda dapat langsung memasukkan path atau menggunakan parameter penjadwalan untuk mendapatkan path. Untuk informasi selengkapnya tentang cara menggunakan parameter penjadwalan, lihat Format yang didukung untuk parameter penjadwalan.
Condition for passing check	Menentukan kondisi kelulusan untuk pemeriksaan file FTP. Jika file FTP ada, pemeriksaan lolos, dan platform menganggap file FTP tersedia. Jika file FTP tidak ada, pemeriksaan gagal, dan platform menganggap file FTP tidak tersedia.
Check Stopping Policy	Mengonfigurasi kebijakan penghentian untuk task node Pemeriksaan. Anda dapat menetapkan waktu penghentian atau jumlah maksimum pemeriksaan. Anda juga dapat mengonfigurasi frekuensi pemeriksaan: Set stop time: Anda dapat menetapkan seberapa sering memeriksa dalam durasi target (interval pemeriksaan). Jika pemeriksaan tidak lolos dalam durasi target, task Pemeriksaan secara otomatis keluar dan ditandai sebagai gagal. Catatan Interval pemeriksaan dapat berkisar dari 1 hingga `30` menit. Jika task hulu tertunda sehingga menyebabkan task node Pemeriksaan dimulai setelah waktu penghentian yang dikonfigurasi, task node Pemeriksaan tetap dimulai setelah task hulu selesai, tetapi hanya melakukan pemeriksaan sekali. Set stop count: Anda dapat menetapkan seberapa sering memeriksa dalam jumlah pemeriksaan target (interval pemeriksaan). Jika pemeriksaan tidak lolos setelah jumlah pemeriksaan target, task Pemeriksaan secara otomatis keluar dan ditandai sebagai gagal. Catatan Interval pemeriksaan dapat berkisar dari 1 hingga `30` menit. Durasi maksimum task node Pemeriksaan adalah 24 jam (1.440 menit). Jumlah maksimum pemeriksaan tergantung pada interval pemeriksaan. Misalnya, jika intervalnya 5 menit, jumlah maksimum pemeriksaan adalah 288. Jika intervalnya 10 menit, jumlah maksimumnya adalah 144. Nilai aktual pada UI yang berlaku.

Konfigurasikan kebijakan pemeriksaan untuk file OSS

Berikut ini penjelasan parameter-parameternya.

Parameter	Deskripsi
Data Source Type	Pilih OSS.
Data Source Name	Sumber data tempat file OSS yang ingin Anda periksa berada. Jika tidak ada sumber data yang tersedia, klik New data source untuk membuatnya. Untuk informasi selengkapnya tentang cara membuat sumber data OSS, lihat Sumber data OSS.
File Path	Path file OSS yang akan diperiksa. Anda dapat login ke Konsol OSS, buka halaman detail bucket target, lalu lihat path di halaman Files > Objects > OSS Files. Catatan Platform secara default menggunakan informasi bucket dari sumber data OSS yang Anda pilih untuk Data Source Name. Saat memasukkan path, Anda tidak perlu memasukkan awalan `oss://` atau informasi bucket. Kami juga menyarankan agar Anda tidak memulai path dengan garis miring maju (`/`). Path harus mengikuti definisi format path file OSS: Jika path file diakhiri dengan garis miring maju (/), node Pemeriksaan memeriksa apakah folder dengan nama yang sama ada di OSS. Misalnya, user/ berarti memeriksa apakah folder user ada. Jika path file tidak diakhiri dengan garis miring maju (/), node Pemeriksaan memeriksa apakah file dengan nama yang sama ada di OSS. Misalnya, user berarti memeriksa apakah file user ada. Untuk memeriksa keberadaan folder, perhatikan dua kasus berikut: Upload file langsung (misalnya, `put /a/b/1.txt`): Ini tidak membuat folder `/a` atau `/a/b`. Ini hanya membuat objek bernama `/a/b/1.txt`. Konsol menampilkan folder virtual `/a/b/`. Dalam kasus ini, pemeriksaan keberadaan folder akan gagal. Upload path langkah demi langkah (misalnya, `put /a`→`put /a/b`→`put /a/b/1.txt`): Ini membuat objek folder untuk `/a` dan `/a/b` (dengan ukuran 0 KB). Baik objek file maupun folder dibuat. Dalam kasus ini, pemeriksaan keberadaan folder akan berhasil.
Condition for passing check	Menentukan kondisi kelulusan untuk pemeriksaan file OSS. Jika file OSS ada, pemeriksaan lolos, dan platform menganggap file OSS tersedia. Jika file OSS tidak ada, pemeriksaan gagal, dan platform menganggap file OSS tidak tersedia.
Stopping Policy Check	Mengonfigurasi kebijakan penghentian untuk task node Pemeriksaan. Anda dapat menetapkan waktu penghentian atau jumlah maksimum pemeriksaan. Anda juga dapat mengonfigurasi frekuensi pemeriksaan: Set stop time: Anda dapat menetapkan seberapa sering memeriksa dalam durasi target (interval pemeriksaan). Jika pemeriksaan tidak lolos dalam durasi target, task Pemeriksaan secara otomatis keluar dan ditandai sebagai gagal. Catatan Interval pemeriksaan dapat berkisar dari 1 hingga `30` menit. Jika task hulu tertunda sehingga menyebabkan task node Pemeriksaan dimulai setelah waktu penghentian yang dikonfigurasi, task node Pemeriksaan tetap dimulai setelah task hulu selesai, tetapi hanya melakukan pemeriksaan sekali. Set stop count: Anda dapat menetapkan seberapa sering memeriksa dalam jumlah pemeriksaan target (interval pemeriksaan). Jika pemeriksaan tidak lolos setelah jumlah pemeriksaan target, task Pemeriksaan secara otomatis keluar dan ditandai sebagai gagal. Catatan Interval pemeriksaan dapat berkisar dari 1 hingga `30` menit. Durasi maksimum task node Pemeriksaan adalah 24 jam (1.440 menit). Jumlah maksimum pemeriksaan tergantung pada interval pemeriksaan. Misalnya, jika intervalnya 5 menit, jumlah maksimum pemeriksaan adalah 288. Jika intervalnya 10 menit, jumlah maksimumnya adalah 144. Nilai aktual pada UI yang berlaku.

Konfigurasikan kebijakan pemeriksaan untuk file HDFS

Tabel berikut menjelaskan parameter-parameternya.

Parameter	Deskripsi
Data Source Type	Pilih HDFS.
Data Source Name	Sumber data tempat file HDFS yang ingin Anda periksa berada. Jika tidak ada sumber data yang tersedia, klik New data source untuk membuatnya. Untuk informasi selengkapnya tentang cara membuat sumber data HDFS, lihat Sumber data HDFS.
File Path	Path file HDFS yang akan diperiksa, misalnya, `/user/dw_test/dw`. Jika path yang dimasukkan ada, berarti file dengan nama yang sama ada di path tersebut. Anda dapat langsung memasukkan path atau menggunakan parameter penjadwalan untuk mendapatkan path. Untuk informasi selengkapnya tentang cara menggunakan parameter penjadwalan, lihat Format yang didukung untuk parameter penjadwalan.
Condition for passing check	Menentukan kondisi kelulusan untuk pemeriksaan file HDFS. Jika file HDFS ada, pemeriksaan lolos, dan platform menganggap file HDFS tersedia. Jika file HDFS tidak ada, pemeriksaan gagal, dan platform menganggap file HDFS tidak tersedia.
Stop Policy	Mengonfigurasi kebijakan penghentian untuk task node Pemeriksaan. Anda dapat menetapkan waktu penghentian atau jumlah maksimum pemeriksaan. Anda juga dapat mengonfigurasi frekuensi pemeriksaan: Set stop time: Anda dapat menetapkan seberapa sering memeriksa dalam durasi target (interval pemeriksaan). Jika pemeriksaan tidak lolos dalam durasi target, task Pemeriksaan secara otomatis keluar dan ditandai sebagai gagal. Catatan Interval pemeriksaan dapat berkisar dari 1 hingga `30` menit. Jika task hulu tertunda sehingga menyebabkan task node Pemeriksaan dimulai setelah waktu penghentian yang dikonfigurasi, task node Pemeriksaan tetap dimulai setelah task hulu selesai, tetapi hanya melakukan pemeriksaan sekali. Set stop count: Anda dapat menetapkan seberapa sering memeriksa dalam jumlah pemeriksaan target (interval pemeriksaan). Jika pemeriksaan tidak lolos setelah jumlah pemeriksaan target, task Pemeriksaan secara otomatis keluar dan ditandai sebagai gagal. Catatan Interval pemeriksaan dapat berkisar dari 1 hingga `30` menit. Durasi maksimum task node Pemeriksaan adalah 24 jam (1.440 menit). Jumlah maksimum pemeriksaan tergantung pada interval pemeriksaan. Misalnya, jika intervalnya 5 menit, jumlah maksimum pemeriksaan adalah 288. Jika intervalnya 10 menit, jumlah maksimumnya adalah 144. Nilai aktual pada UI yang berlaku.

Konfigurasikan kebijakan pemeriksaan untuk file OSS_HDFS

Tabel berikut menjelaskan parameter-parameternya.

Parameter	Deskripsi
Data Source Type	Pilih OSS_HDFS.
Data Source Name	Sumber data tempat file OSS_HDFS yang ingin Anda periksa berada. Jika tidak ada sumber data yang tersedia, klik New data source untuk membuatnya. Untuk informasi selengkapnya tentang cara membuat sumber data OSS_HDFS, lihat Sumber data OSS-HDFS.
File Path	Path file OSS_HDFS yang akan diperiksa. Anda dapat login ke Konsol OSS, buka halaman detail bucket target, lalu lihat path di halaman Files > Objects > HDFS Files. Path harus mengikuti definisi format path file OSS_HDFS: Jika path file diakhiri dengan `/`, node Pemeriksaan memeriksa apakah folder dengan nama yang sama ada di OSS_HDFS. Misalnya, `user/` berarti memeriksa apakah folder user ada. Jika path file tidak diakhiri dengan `/`, node Pemeriksaan memeriksa apakah file dengan nama yang sama ada di OSS_HDFS. Misalnya, `user` berarti memeriksa apakah file user ada.
Condition for passing check	Menentukan kondisi kelulusan untuk pemeriksaan file OSS_HDFS. Jika file OSS_HDFS ada, pemeriksaan lolos, dan platform menganggap file OSS_HDFS tersedia. Jika file OSS_HDFS tidak ada, pemeriksaan gagal, dan platform menganggap file OSS_HDFS tidak tersedia.
Stop Policy Check	Mengonfigurasi kebijakan penghentian untuk task node Pemeriksaan. Anda dapat menetapkan waktu penghentian atau jumlah maksimum pemeriksaan. Anda juga dapat mengonfigurasi frekuensi pemeriksaan: Set stop time: Anda dapat menetapkan seberapa sering memeriksa dalam durasi target (interval pemeriksaan). Jika pemeriksaan tidak lolos dalam durasi target, task Pemeriksaan secara otomatis keluar dan ditandai sebagai gagal. Catatan Interval pemeriksaan dapat berkisar dari 1 hingga `30` menit. Jika task hulu tertunda sehingga menyebabkan task node Pemeriksaan dimulai setelah waktu penghentian yang dikonfigurasi, task node Pemeriksaan tetap dimulai setelah task hulu selesai, tetapi hanya melakukan pemeriksaan sekali. Set stop count: Anda dapat menetapkan seberapa sering memeriksa dalam jumlah pemeriksaan target (interval pemeriksaan). Jika pemeriksaan tidak lolos setelah jumlah pemeriksaan target, task Pemeriksaan secara otomatis keluar dan ditandai sebagai gagal. Catatan Interval pemeriksaan dapat berkisar dari 1 hingga `30` menit. Durasi maksimum task node Pemeriksaan adalah 24 jam (1.440 menit). Jumlah maksimum pemeriksaan tergantung pada interval pemeriksaan. Misalnya, jika intervalnya 5 menit, jumlah maksimum pemeriksaan adalah 288. Jika intervalnya 10 menit, jumlah maksimumnya adalah 144. Nilai aktual pada UI yang berlaku.

Tugas sinkronisasi real-time

Berikut ini penjelasan parameter-parameternya.

Parameter	Deskripsi
Check Object	Pilih Real-time Synchronization Task.
Real-time Synchronization Task	Tugas sinkronisasi real-time yang akan diperiksa. Catatan Hanya tugas sinkronisasi real-time Kafka-ke-MaxCompute yang didukung. Jika Anda memiliki tugas sinkronisasi real-time tetapi tidak dapat memilihnya, periksa apakah task tersebut telah dipublikasikan ke lingkungan produksi.
Stop Policy Check	Mengonfigurasi kebijakan penghentian untuk task node Pemeriksaan. Anda dapat menetapkan waktu penghentian atau jumlah maksimum pemeriksaan. Anda juga dapat mengonfigurasi frekuensi pemeriksaan: Set stop time: Anda dapat menetapkan seberapa sering memeriksa dalam durasi target (interval pemeriksaan). Jika pemeriksaan tidak lolos dalam durasi target, task Pemeriksaan secara otomatis keluar dan ditandai sebagai gagal. Catatan Interval pemeriksaan dapat berkisar dari 1 hingga `30` menit. Jika task hulu tertunda sehingga menyebabkan task node Pemeriksaan dimulai setelah waktu penghentian yang dikonfigurasi, task node Pemeriksaan tetap dimulai setelah task hulu selesai, tetapi hanya melakukan pemeriksaan sekali. Set stop count: Anda dapat menetapkan seberapa sering memeriksa dalam jumlah pemeriksaan target (interval pemeriksaan). Jika pemeriksaan tidak lolos setelah jumlah pemeriksaan target, task Pemeriksaan secara otomatis keluar dan ditandai sebagai gagal. Catatan Interval pemeriksaan dapat berkisar dari 1 hingga `30` menit. Durasi maksimum task node Pemeriksaan adalah 24 jam (1.440 menit). Jumlah maksimum pemeriksaan tergantung pada interval pemeriksaan. Misalnya, jika intervalnya 5 menit, jumlah maksimum pemeriksaan adalah 288. Jika intervalnya 10 menit, jumlah maksimumnya adalah 144. Nilai aktual pada UI yang berlaku.

Langkah 3: Konfigurasikan properti penjadwalan

Untuk memeriksa data partisi secara berkala, klik Scheduling di panel kanan halaman editor node. Konfigurasikan properti penjadwalan untuk node sesuai kebutuhan. Untuk informasi selengkapnya, lihat Ikhtisar properti penjadwalan task.

Seperti node penjadwalan biasa, node Pemeriksaan memerlukan dependensi penjadwalan dan waktu terjadwal. Setiap node di DataWorks harus memiliki dependensi hulu. Jika node Pemeriksaan tidak memiliki dependensi hulu yang sebenarnya, Anda dapat menetapkan dependensinya ke node beban nol atau node root ruang kerja, tergantung pada kompleksitas bisnis Anda. Untuk informasi selengkapnya, lihat Node beban nol.

Catatan

Anda harus menetapkan properti Rerun dan Parent Nodes untuk node sebelum dapat melakukan commit.

Langkah 4: Commit dan publikasikan task

Setelah mengonfigurasi node, lakukan commit dan publikasikan. Setelah node dipublikasikan, node tersebut berjalan secara berkala berdasarkan konfigurasi penjadwalannya.

Klik ikon di bilah alat untuk menyimpan node.
Klik ikon di bilah alat untuk melakukan commit node.
Di kotak dialog Commit, masukkan Change description. Jika diperlukan, pilih apakah akan melakukan tinjauan kode dan pengujian asap setelah node di-commit.
Catatan
- Anda harus menetapkan properti Rerun dan Parent Nodes untuk node sebelum dapat melakukan commit.
- Tinjauan kode membantu mengontrol kualitas kode task. Ini mencegah kesalahan task yang dapat terjadi jika kode yang salah dipublikasikan ke lingkungan produksi tanpa ditinjau. Jika Anda menggunakan tinjauan kode, kode node yang di-commit harus disetujui oleh reviewer sebelum dapat dipublikasikan. Untuk informasi selengkapnya, lihat Tinjauan kode.
- Untuk memastikan node penjadwalan berjalan sesuai harapan, kami menyarankan Anda melakukan pengujian asap pada node sebelum mempublikasikannya. Untuk informasi selengkapnya, lihat Pengujian asap.

Jika Anda menggunakan ruang kerja dalam mode standar, Anda juga harus mengklik Publish di pojok kanan atas halaman editor node setelah melakukan commit. Ini akan mempublikasikan node ke lingkungan produksi. Untuk informasi selengkapnya, lihat Publikasikan task.

Langkah selanjutnya

Setelah node Pemeriksaan di-commit dan dipublikasikan, node tersebut berjalan secara berkala di Pusat Operasi berdasarkan konfigurasinya. Anda dapat melihat hasil pemeriksaan dan melakukan operasi O&M terkait di Pusat Operasi DataWorks. Untuk informasi selengkapnya, lihat Operasi O&M dasar untuk Tugas yang dipicu otomatis.