Dataphin：步驟五：啟動執行個體並插入資料

步驟一：啟動即時任務

1. 在Dataphin首頁，單擊頂部功能表列的研發。

2. 按照下圖操作指引，啟動flink_dataphin即時任務。

   

3. 啟動即時執行個體對話方塊，配置啟動參數。

   參數	描述
   啟動方式	選擇無狀態啟動。
   指定來源表讀取資料時點	選擇當前日期及此刻時間。
   時間參數配置	選擇當前日期。

4. 單擊確定。

步驟二：插入資料

登入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 '綠茶'
        WHEN 1 THEN '紅茶'
        WHEN 2 THEN '花茶'
        ELSE '資料建置錯誤'
    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();