注册流表

步骤一：左侧导航栏点击【开发运维】- 【实时开发】。

步骤二：点击【数仓管理】，进入流表管理页面。

步骤三：点击“创建库”，创建standard库。

步骤四：点击“新建流表”按钮，按照如下对流表进行配置。

实时任务开发

步骤一：切换到“任务管理”界面。

步骤二：点击“新建文件夹”创建standard文件夹。

步骤三：点击新建任务，做如下配置，后点击“确定”按钮。

步骤四：数据表名和字段等信息通过拖拉拽参与开发，完成以下Flink-SQL代码。

set 'order_info.connections.group.id' = 'example001';
set 'order_info.scan.startup.mode' = 'earliest-offset';
set 'order_totals.primary.keys' = 'date';

insert into `mysql5_ps`.`poc_standard`.`order_totals`
select 
order_date as `date`,
sum(amount) as total_amount
from `standard`.`order_info`
group by order_date;

步骤五：点击“语法检查”和“开始调试”，进行语法检查和调试，确保代码没有问题。

步骤六：进行运行配置，配置项保持默认即可，然后点击保存。

步骤七：点击“提交上线”按钮，填写任务描述后，点击确定。

步骤八：前往任务运维，启动任务。

步骤九：可以去FLink页面和监控页面查看任务运行情况，也可以到【自助分析】运行下方代码，查看任务的目标表写入的数据。

select * from poc_standard.order_totals;