AnalyticDB

AnalyticDB 简介
分析型数据库 MySQL 版(AnalyticDB for MySQL),是阿里巴巴自主研发的海量数据
实时高并发在线分析(Realtime OLAP)云计算服务,使得您可以在毫秒级针对千亿级数据
进行即时的多维分析透视和业务探索。分析型数据库 MySQL 版对海量数据的*计算和极
速响应能力,能让用户在瞬息之间进行灵活的数据探索,快速发现数据价值,并可直接嵌入
业务系统为终端客户提供分析服务。

实时计算最终结果

实时计算的最终结果要存储到 结果表中 那么就要使用到 AnalyticDB

AnalyticDB

 

AnalyticDB 购买

购买地址:
https://www.aliyun.com/product/ads?spm=5176.10695662.1157856.1.65b52025ZO0Y5g&al
y_as=d6TF_uE1

AnalyticDB

选择购买配置

AnalyticDB

确认订单

AnalyticDB

开通成功

AnalyticDB

AnalyticDB 添加集群白名单

白名单 访问

AnalyticDB

AnalyticDB

配置实时集群的 IP 地址,加入到维表 RDS 和结果表 AnalyticDB 的白名单中
进入建立集群时的位置->点击集群的实例名->复制 ENI 那列 IP 地址。
说明:阿里实时计算开发平台入口:https://stream.console.aliyun.com/zh/dark/#/profile/cluster

AnalyticDB

点击数据安全->点击添加白名单分组        注意:组内 IP 地址的间隔,只能有一个逗号,多余的空格要删除掉 

AnalyticDB

RDS 添加白名单

AnalyticDB

AnalyticDB

点击申请外网地址->复制外网地址

AnalyticDB

创建 AnalyticDB   账号

AnalyticDB

AnalyticDB

AnalyticDB

新建连接->SQL 主机地址为 AnalyticDB 的地址->用户名为 root,密码:Atguigu000000

AnalyticDB

出现 报错   : 需要配置 本机ip地址  白名单

AnalyticDB

配置  本机ip

AnalyticDB

连接成功

AnalyticDB

 

创建数据库 gmall_result    存储结果数据库   --  存储对应的结果表  

两张 结果表

AnalyticDB

 

创建地区分布统计结果表

create Table `ads_province_stat` (
 `province_id` bigint,
 `area_code` varchar,
 `province_name` varchar,
 `region_id` bigint,
 `region_name` varchar,
 `order_amount` varchar,
 `order_count` bigint,
 `dt` varchar,
 primary key (province_id,dt)
) 
DISTRIBUTE BY HASH(`province_id`) 
PARTITION BY VALUE(`DATE_FORMAT(dt, '%Y%m')`) LIFECYCLE 24 
INDEX_ALL='Y' COMMENT='省份地区销售情况统计'

创建商品统计结果表

create Table `ads_sku_stat` (
 `sku_id` bigint,
 `sku_name` varchar,
 `weight` decimal(16, 2),
 `tm_id` bigint,
 `price` decimal(16, 2),
 `spu_id` bigint,
 `c3_id` bigint,
 `c3_name` varchar,
 `c2_id` bigint,
 `c2_name` varchar,
 `c1_id` bigint,
 `c1_name` varchar,
 `order_amount` decimal(16, 2),
 `order_count` bigint,
 `sku_count` bigint,
 `dt` varchar,
 primary key (sku_id,dt)
) 
DISTRIBUTE BY HASH(`sku_id`) 
PARTITION BY VALUE(`DATE_FORMAT(dt, '%Y%m')`) LIFECYCLE 24 
INDEX_ALL='Y' COMMENT='商品销售情况统计'

其中,DISTRIBUTE BY 后面的字段,用于分 Shard,把数据分配到不同的节点上,已达到 数据及负载的均衡

PARTITION BY 后面的字段用户在节点内进行分区,用于缩小查询时的扫描范围,同时管 理数据生存周期。

两张结果表

AnalyticDB

上一篇:JavaScript:如何理解BigInt类型?


下一篇:2020年js新特性