北京云栖大会workshop:《数据接入:海量数据存储及实时访问》篇

本文涉及的产品
对象存储 OSS,OSS 加速器 50 GB 1个月
简介: 本手册为北京云栖 Workshop《云数据·大计算:快速搭建互联网在线运营分析平台》的数据准备部分,介绍使用表格存储完成行为日志采集工作,并提供实时在线查询。

实验背景介绍

了解更多2017云栖大会·北京峰会 TechInsight & Workshop.

本手册为云栖大会Workshop《云数据·大计算:快速搭建互联网在线运营分析平台》的《数据处理:数据建模与加工》篇而准备。主要阐述在使用DataWorks/MaxCompute过程中如何直读TableStore中的日志数据并进行加工、用户画像,学员可以根据本实验手册,去学习如何创建外部表、编写SQL。

实验涉及大数据产品

实验过程

必备条件:

  • 开通表格存储服务Table Store,并在华北2区创建相应的实例
  • 记录该次实验中使用的AK信息
  • 下载此次用户数据Mock程序

获取AK

  • 前往AK控制台 获取AK,由于该AK具有该云账户完全的权限,请妥善保管。

创建实例:

  • 表格存储官网进行服务开通
  • 登录表格存储控制台

    在控制台上创建实例,在华北2创建实例(注意:实例名称为的整个区域唯一,建议为workshop-bj-随机数字),实例类型选择容量型与高性能实例均可。

_

需要记录的信息为:实例名称,域名访问地址,由于也使用的MaxCompute的华北2区域,建议使用私网地址。

数据准备

1.根据不同的电脑环境,下载相应的数据Demo包

./workshop_demo_linux -h 会列出该demo的相关命令:

* prepare: 准备测试数据,创建数据表,根据conf中的用户数量,为用户生成一周的行为日志数据
* raw ${
   userid} ${
   date} ${
   Top条数}: 查询指定用户的日志明细
* new/day_active/month_active/day_pv/month_pv:在结果表中查询上述几种类型的报表数据,(新增:new,日活:day_active,月活:month_active,日PV:day_pv,月PV:month_pv)

创建的表结构为:

原始日志数据表:user_trace_log:

列名 类型 说明
* md5 STRING ‘用户uid的md5值 前8位’,表格存储主键
* uid STRING ‘用户uid’,表格存储主键
* ts BIGINT ‘用户操作时间戳’,表格存储主键
ip STRING 'ip地址',
status BIGINT '服务器返回状态码'
bytes BIGINT '返回给客户端的字节数'
device STRING '终端型号'
system STRING '系统版本 ios xxx/android xxx'
customize_event STRING 自定义事件:登录/退出/购买/注册/点击/后台/切换用户/浏览
use_time BIGINT APP单次使用时长,当事件为退出、后台、切换用户时有该项
customize_event_content STRING 用户关注内容信息,在customize_event为浏览和评论时包含该列

分析结果表: analysis_result:

列名 类型 说明
* metric STRING 报表的类型:'new', 'day_active', 'month_active', 'day_pv', 'month_pv',表格存储主键
* ds STRING 时间yyyy-mm-dd 或者 yyyy-mm,表格存储主键
num BIGINT 对应的数据值

2.配置Demo环境

1. 解压包,并进入解压目录
2. 编辑conf/app.conf, 根据实际情况修改如下字段:
* endpoint
* instanceName
* accessKeyId
* accessKeySecret

3.启动Demo准备测试数据

./workshop_demo_linux prepare
Prepare the metric data
Prepare User data
total insert data count is: 41766

用户明细查询

执行:
./workshop_demo_linux raw 00001 "2017-12-19" 20

结果如下:

_

需要注意,由于表格存储是SchemaFree结构,表的属性列不需要预先定义,customize_event 中不同的事件对应了不同的内容,故该demo中将 事件-内容做了对齐显示,例如 browse finance 表示浏览事件,对应的内容为金融类资讯, backstage 210 则表明此次切换到后台一共运行了210秒

报表结果查询

执行:
./workshop_demo_linux day_active"

结果如下:
_

下一步

到目前为止,原始数据收集完成,请进行《数据处理:数据建模与加工》篇,对数据进行分析。

完整课程信息:云数据·大计算:快速搭建互联网在线运营分析平台

相关实践学习
阿里云表格存储使用教程
表格存储(Table Store)是构建在阿里云飞天分布式系统之上的分布式NoSQL数据存储服务,根据99.99%的高可用以及11个9的数据可靠性的标准设计。表格存储通过数据分片和负载均衡技术,实现数据规模与访问并发上的无缝扩展,提供海量结构化数据的存储和实时访问。 产品详情:https://www.aliyun.com/product/ots
相关文章
|
5月前
|
JavaScript 前端开发 UED
告别卡顿:用虚拟滚动征服超长列表
告别卡顿:用虚拟滚动征服超长列表
333 112
|
数据中心 iOS开发 MacOS
玩转阿里云 Terraform(三):Terraform 的安装和加速
本文以Mac OS为例,详细介绍如何在本地安装Terraform,并在文章最后介绍一种可以加速Terraform安装的方法。
15998 0
|
3月前
|
SQL 人工智能 安全
手把手教你调出“懂你”的AI:大模型微调实战与资源管理
本文深入浅出讲解大模型微调核心知识:用生活化比喻解析学习率、训练轮数、批量大小、截断长度和LoRA秩五大关键参数;提供适配不同显存的实操配置表;分享Liger Kernel、DeepSpeed等省显存技巧;并强调定量、定性与效率三维评估。零基础也能快速上手定制专属AI。
336 11
手把手教你调出“懂你”的AI:大模型微调实战与资源管理
|
存储 消息中间件 监控
Fluss在阿里双11万亿规模场景下的落地实践
阿里采集分析平台负责人吴宝国在Flink Forward Asia 2025深圳站分享Fluss大规模落地实践:以列式流存储替代传统消息队列,解决成本高、湖流割裂痛点;支撑双11 4PB/天、1亿TPS;实现多级分区、过滤下推、湖流一体,助力淘天、饿了么等业务降本增效。
318 0
Fluss在阿里双11万亿规模场景下的落地实践
|
2月前
|
人工智能 安全 搜索推荐
智能体来了:从0到1教你三步构建属于你的 AI 数字分身
本文带你从零构建专属AI智能体:解析其自主性本质,详解“骨架—性格—应用”三步搭建法,涵盖决策中枢、记忆系统与行动接口,并强调隐私保护与伦理边界。门槛降低,人人可启程。
1121 1
|
7月前
|
人工智能 JSON 前端开发
Agentic AI崛起:九大核心技术定义未来人机交互模式​
本文系统梳理AI智能体架构设计的九大核心技术,涵盖智能体基础、多智能体协作、知识增强、模型优化、工具调用、协议标准化及人机交互等关键领域,助力构建高效、智能、协同的AI应用体系。建议点赞收藏,持续关注AI架构前沿技术。
1726 1
|
4月前
|
人工智能 缓存 运维
从“救火”到“预见”:汽车行业操作系统智能运维解决方案
操作系统控制台作为面向汽车行业的综合运维平台,致力于打通“应用—操作系统—硬件”全栈链路运维能力。
|
5月前
|
人工智能 达摩院 Anolis
龙蜥操作系统装机量突破1000万,市占率近50%,首发支持RISC-V RVA23预览版!
报告调研显示,在国产操作系统迁移意愿方面,龙蜥操作系统的吸引力最高,用户意愿迁移至龙蜥生态社区版和商业版的比例为 54.25%,占比第一。
|
缓存 负载均衡 算法
slb支持多种负载均衡算法
slb支持多种负载均衡算法
505 6