Dataphin:ステップ 5: インスタンスの開始とデータの挿入

ステップ 1: リアルタイムタスクの開始

1. Dataphin ホームページで、トップメニューバーの [開発] をシングルクリックします。

2. 以下の図の操作ガイドを参照して、flink_dataphin リアルタイムタスクを開始します。

   

3. リアルタイムインスタンスを開始するためのダイアログボックスで、起動パラメーターを次のように設定します。

   パラメーター	説明
   起動モード	ステートレス起動 を選択します。
   ソーステーブルのデータ読み取りポイントを指定	現在の日時 を選択します。
   時間パラメーター設定	現在の日付 を選択します。

4. [OK] をシングルクリックして続行します。

ステップ 2: データの挿入

flink_dataphin データソースの MySQL インスタンスにアクセスし、次のコマンドを実行してデータを挿入し、リアルタイムタスクの計算結果を確認します。

// プロダクトタイプを生成する関数の作成
CREATE FUNCTION getSkuId() RETURNS VARCHAR(20)
BEGIN
    DECLARE sku_id VARCHAR(20);
    SET sku_id = CASE FLOOR(RAND() * 3)
        WHEN 0 THEN 'Green Tea'
        WHEN 1 THEN 'Black Tea'
        WHEN 2 THEN 'Herbal Tea'
        ELSE 'Data generation error'
    END;
    RETURN sku_id;
END;

// 3 秒ごとにデータ挿入を実行
DELIMITER $$
CREATE PROCEDURE executeStatement3000Times()
BEGIN
  DECLARE i INT DEFAULT 0;
  WHILE i < 1000 DO
    INSERT INTO oms_orders(id, buyer_id,sku_type,sku_quantity, gmt_create) VALUES (default,FLOOR(RAND() * 10),getSkuId(),FLOOR(RAND() * 10),current_timestamp());
    SET i = i + 1;
    SELECT SLEEP(3);
  END WHILE;
END $$
DELIMITER ;

// PROCEDURE を実行してデータを生成および挿入
CALL executeStatement3000Times();