步骤一:准备工作

进行实时研发前您需完成相关云资源的准备。云资源准备包括阿里云账号资源准备、Dataphin开通与AccessKey配置、Ververica Flink计算源、Quick BI开通(非必选)与配置以及数据源的准备。本文将指导您完成本教程的云资源准备工作。

步骤一:阿里云账号资源准备

主流程

描述

操作指导

准备阿里云账号

创建阿里云账号。

准备阿里云账号

创建RAM用户

创建主账号的RAM用户。

准备RAM用户

步骤二:Dataphin开通与AccessKey配置

主流程

描述

操作指导

开通Dataphin

购买Dataphin。

开通Dataphin

配置AccessKey

授权主账号的AccessKey至Dataphin。

同步RAM用户账号至Dataphin

步骤三:实时计算Flink版、Quick BI开通与配置

主流程

描述

操作指导

开通实时计算Flink版

购买实时计算Flink版。

开通实时计算Flink版

开通Quick BI(非必选)

购买Quick BI。

重要

非必选,也可以使用其他BI工具进行后续的可视化分析。

Quick BI购买、升级、续费、欠费

创建Flink项目空间

创建Flink项目空间,项目名称为flink_dataphin

重要

阿里云实时计算Flink版使用全局的项目空间,已创建的项目空间不支持再创建。建议使用flink_dataphin_001等方式创建。

管理项目空间

步骤四:准备数据源

  1. 通过RDS创建MySQL8.0实例,获取RDS实例ID,并在RDS控制台添加白名单,详情请参见创建RDS MySQL实例。本教程中RDS数据源名称以flink_dataphin为例。

  2. 登录MySQL实例,并使用以下命令创建数据库及数据表。

    create database flink_dataphin; //创建flink_dataphin数据库
    
    use flink_dataphin; //使用flink_dataphin数据库
    
    //订单表
    CREATE TABLE `oms_orders` (
      `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '订单id',
      `buyer_id` bigint(20) DEFAULT NULL COMMENT '用户ID',
      `sku_type` char(32) DEFAULT NULL COMMENT '商品类型',
      `sku_quantity` int DEFAULT NULL COMMENT '商品数量',
      `gmt_create` datetime DEFAULT NULL COMMENT '创建时间',
      PRIMARY KEY (`id`)
    ) COMMENT='订单表';
    
    //结果表
    CREATE TABLE `ads_gross` (
      `prod_code` char(32) COMMENT '商品编号',
      `sale_num` int DEFAULT NULL COMMENT '销售数量',
       primary key (prod_code)
    ) COMMENT='品类销售总数结果表';