步骤五:启动实例并插入数据

本文将指导您完成本教程的FLINK_SQL实时任务的运维,包括实时实例启动与测试数据的写入。

步骤一:启动实时任务

  1. 在Dataphin首页,单击顶部菜单栏的研发

  2. 按照下图操作指引,启动flink_dataphin实时任务。

    image.png

  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();