Skip to main content

数据开发

以实时电商案例数据源表存储为例，为您介绍如何创建FlinkSQL数据开发任务，正确消费Kafka中的流数据并写入至目标结果表。

操作流程​

1.在 数据开发 页面，点击 创建任务 ，创建 FlinkSQL 任务如下：

快速开始-3.png

2.点击右侧工具栏中 源表 ，填入相应 实时采集 配置，并对Kafka中数据流进行字段映射：

-- 源表字段配置
after_event_id int
after_id varchar
after_buy_id varchar
after_goods_type varchar
after_pay_time timestamp
after_buy_amount double
after_but_way varchar

快速开始-4.png

3.点击 结果表 ，存储类型选择 MySQL ，选择相应的数据源和表，手动填写映射表名称。点击 导入全部字段 ，完成结果表的字段映射。

快速开始-5.png

4.点击 IDE区域 ，在任务编辑页面输入如下SQL代码，完成FlinkSQL开发：

INSERT       
INTO
    singal_stream_simple_target
    SELECT
        SUM (after_buy_amount) AS totalsale          
    FROM
        singal_stream_simple_source ;

5.再次浏览所有配置内容，确认无误后点击 保存 即完成数据开发任务配置。