进行实时研发前您需完成相关云资源的准备。云资源准备包括阿里云账号资源准备、Dataphin开通与AccessKey配置、Ververica Flink计算源、Quick BI开通(非必选)与配置以及数据源的准备。本文将指导您完成本教程的云资源准备工作。
步骤一:阿里云账号资源准备
主流程 | 描述 | 操作指导 |
准备阿里云账号 | 创建阿里云账号。 | |
创建RAM用户 | 创建主账号的RAM用户。 |
步骤二:Dataphin开通与AccessKey配置
主流程 | 描述 | 操作指导 |
开通Dataphin | 购买Dataphin。 | |
配置AccessKey | 授权主账号的AccessKey至Dataphin。 |
步骤三:实时计算Flink版、Quick BI开通与配置
主流程 | 描述 | 操作指导 |
开通实时计算Flink版 | 购买实时计算Flink版。 | |
开通Quick BI(非必选) | 购买Quick BI。 重要 非必选,也可以使用其他BI工具进行后续的可视化分析。 | |
创建Flink项目空间 | 创建Flink项目空间,项目名称为flink_dataphin。 重要 阿里云实时计算Flink版使用全局的项目空间,已创建的项目空间不支持再创建。建议使用flink_dataphin_001等方式创建。 |
步骤四:准备数据源
通过RDS创建MySQL8.0实例,获取RDS实例ID,并在RDS控制台添加白名单,详情请参见创建RDS MySQL实例。本教程中RDS数据源名称以flink_dataphin为例。
登录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='品类销售总数结果表';
文档内容是否对您有帮助?