本文将指导您完成本教程的FLINK_SQL实时任务的运维,包括实时实例启动与测试数据的写入。
步骤一:启动实时任务
在Dataphin首页,单击顶部菜单栏的研发。
按照下图操作指引,启动flink_dataphin实时任务。
启动实时实例对话框,配置启动参数。
参数
描述
启动方式
选择无状态启动。
指定来源表读取数据时点
选择当前日期及此刻时间。
时间参数配置
选择当前日期。
单击确定。
步骤二:插入数据
登录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();
文档内容是否对您有帮助?