Data Management:Orkestrasi task untuk promosi e-commerce

Masuk ke DMS 5.0.

Arahkan pointer ke ikon di pojok kiri atas Konsol DMS, lalu pilih All Features > SQL Console > SQL Console.

Pada kotak dialog Please select the database first, masukkan kata kunci untuk mencari database, pilih instans database dari hasil pencarian, lalu klik Confirm.

Buat tabel konfigurasi, tabel bisnis, dan tabel penerbitan kupon.

1. Buat tabel konfigurasi bernama activity_setting. Tempel pernyataan SQL berikut ke editor SQL, lalu klik Execute.

   Pernyataan SQL:

   CREATE TABLE `activity_setting` (
       `has_promotion` tinyint(1) NOT NULL COMMENT 'Indicates whether a promotion is active',
       `consumption_limit` int(11) NOT NULL COMMENT 'Consumption threshold',
       `quota` int(11) NOT NULL COMMENT 'Coupon amount',
       PRIMARY KEY (`has_promotion`)
   ) ENGINE=InnoDB
   DEFAULT CHARACTER SET=utf8 COLLATE=utf8_general_ci
   ROW_FORMAT=COMPACT
   AVG_ROW_LENGTH=16384;

2. Buat tabel bisnis bernama consumption_records. Tempel pernyataan SQL berikut ke editor SQL, lalu klik Execute.

   Pernyataan SQL:

   CREATE TABLE `consumption_records` (
       `id` bigint(20) UNSIGNED NOT NULL AUTO_INCREMENT COMMENT 'Record ID',
       `time` datetime NOT NULL COMMENT 'Consumption time',
       `count` int(11) NOT NULL COMMENT 'Consumption amount',
       `user_id` bigint(20) NOT NULL COMMENT 'User ID',
       PRIMARY KEY (`id`)
   ) ENGINE=InnoDB
   DEFAULT CHARACTER SET=utf8mb4 COLLATE=utf8mb4_general_ci
   COMMENT='Consumption records table'
   AUTO_INCREMENT=8001
   ROW_FORMAT=COMPACT
   AVG_ROW_LENGTH=54;

3. Buat tabel penerbitan kupon bernama voucher_send_list. Tempel pernyataan SQL berikut ke editor SQL, lalu klik Execute.

   Pernyataan SQL:

   CREATE TABLE `voucher_send_list` (
       `Id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'Record ID',
       `user_id` int(11) NULL COMMENT 'User ID',
       `consumption_sum` int(11) NULL COMMENT 'Total consumption',
       `quota` int(11) NULL COMMENT 'Coupon amount',
       PRIMARY KEY (`Id`)
   ) ENGINE=InnoDB
   DEFAULT CHARACTER SET=utf8 COLLATE=utf8_general_ci
   AUTO_INCREMENT=1
   ROW_FORMAT=COMPACT
   AVG_ROW_LENGTH=0;

Masukkan data ke tabel konfigurasi. Tempel pernyataan SQL berikut ke editor SQL, lalu klik Execute.

INSERT INTO activity_setting( has_promotion, consumption_limit, quota)
VALUES('1','100','30');

Masukkan data ke tabel bisnis. Gunakan fitur pembuatan data uji untuk menghasilkan data. Untuk informasi selengkapnya, lihat Test data generation.

Buat dan isi tabel konfigurasi, tabel bisnis, serta tabel penerbitan kupon. Untuk informasi selengkapnya, lihat Persiapkan lingkungan.

Buat alur task.

1. Masuk ke Data Management (DMS) 5.0.

2. Arahkan pointer ke ikon di pojok kiri atas, lalu pilih All Features > Data+AI > Data Development > Task Orchestration.

   Catatan

   Jika Anda menggunakan Konsol DMS dalam mode normal, pilih Data+AI > Data Development > Task Orchestration di bilah navigasi atas.

3. Klik Create Task Flow.

4. Pada kotak dialog New Task Flow, masukkan Task Flow Name dan Description, lalu klik OK.

Orkestrasikan node-node task.

1. Dari daftar Task Type di sebelah kiri, seret node SQL Assignment for Single Instance, node Conditional Branch, dan node Single Instance SQL ke Kanvas.

2. Hubungkan node-node tersebut untuk membentuk alur task.

   Arahkan kursor ke node Single Instance SQL Assignment, klik lingkaran berongga yang muncul di sisi kanan node Single Instance SQL Assignment, lalu seret garis koneksi ke node Conditional Branch.

   Arahkan pointer ke node Conditional Branch, klik lingkaran berongga yang muncul di sisi kanan node Conditional Branch, lalu seret garis koneksi ke node Single Instance SQL.

Konfigurasikan node-node task.

1. Pilih node SQL Assignment for Single Instance untuk dikonfigurasi. Untuk informasi selengkapnya, lihat Configure an SQL Assignment for Single Instance node.

   1. Pilih database target.

   2. Pada editor SQL, masukkan pernyataan SQL berikut:

      select * from activity_setting limit 1

   3. Pada bagian Variable Setting di sebelah kanan, tambahkan tiga variabel output: Quota (Coupon amount), HasPromotion (Indicates whether a promotion is active), dan ConsumptionLimit (Consumption threshold).

      Pada editor SQL di sebelah kiri, masukkan select * from activity_setting limit 1. Pada bagian pemetaan variabel output di sebelah kanan, petakan variabel ke hasil kueri sebagai berikut: Quota ke Baris 0 dan Kolom 2, HasPromotion ke Baris 0 dan Kolom 0, serta ConsumptionLimit ke Baris 0 dan Kolom 1.

2. Pilih dan konfigurasikan node Conditional Branch. Untuk informasi selengkapnya, lihat Configure a Conditional Branch node.

   Konfigurasikan ekspresi kondisional sebagai berikut: atur Condition Field menjadi HasPromotion, Operator menjadi ==, dan Value menjadi 1.

3. Pilih node Single Instance SQL untuk dikonfigurasi.

   Masukkan pernyataan SQL berikut:

   INSERT INTO `voucher_send_list`(`user_id`,`consumption_sum`,`quota`)
   SELECT * FROM
   (SELECT `user_id`, sum(count) AS consumption_sum,${Quota} FROM `consumption_records`
    WHERE `time` > '${bizdate}'  GROUP BY `user_id`) `consumption_records`
   where `consumption_sum`>${ConsumptionLimit}

Di pojok kiri atas Kanvas, klik Try Run untuk menguji alur task.

Opsional: Konfigurasikan penjadwalan periodik.

1. Pada halaman pengeditan alur task, klik tab Task Flow Information di bagian bawah halaman.

2. Pada bagian Scheduling Settings, aktifkan sakelar Enable Scheduling dan konfigurasikan jadwalnya. Untuk informasi tentang parameter, lihat Scheduling cycle configuration.

Publikasikan alur task. Alur tersebut kemudian akan berjalan secara otomatis sesuai jadwal yang dikonfigurasi.

1. Di pojok kiri atas Kanvas, klik Publish.

2. Pada kotak dialog Publish, masukkan komentar di bidang Remarks, lalu klik Publish.