关于机器学习的三个阶段
781
2022-05-30
CS介绍
大数据计算,实时性越强,越有价值。数据随着时间增长价值迅速衰减,数据永远是临时的,而分析永远是有时效性的。实时的产品推荐,实时的产品质量反馈,在线风险分析。都可以是数据产生极大的价值。华为云实时流计算服务,打造最优秀的云上实时流计算平台,为客户创造前所未有的极致体验。
实时流计算服务,简称CS,采用全托管的服务方式,使得用户无需感知计算集群。只需聚焦于Stream SQL业务,即时执行作业,就可以完成实时流计算的数据分析。
适用场景
CS服务的使用,聚焦于互联网和物联网场景,适用于实时性要求高、吞吐量大的业务场景。主要应用在互联网行业中小企业、物联网、车联网、金融反欺诈等多种行业应用场景,如互联网汽车、日志在线分析、在线机器学习、在线图计算、在线推荐算法应用等。
实验介绍
本示例从DIS数据源读取数据,实时分析日志信息,向OBS输出源写数据。通过本示例,你会学习到:
创建并运行Flink SQL应用
完成“日志分析”示例场景
创建DIS通道
进入DIS控制台,点击右侧 购买接入通道 ,创建一个DIS通道:注意选择通道所在 区域为北京一 , 数据源类型 选择 CSV ,通道名称 填写 input-dis 。
最终完成参考如下图:
创建OBS桶
区域北京一
桶名称自定义,本示例为:outputs-obs
存储类型:标准存储
桶策略:私有
创建完毕后,打开OBS桶,新建文件夹,名称为logInfos
创建Flink SQL作业
登录实时流计算CS控制台,点击新建作业,输入自定义名称,选择模板 [云生态]DIS-CS-OBS样例模板,点击确认
确认完毕后,在编辑处,如果以上名称全部按照本文档命名,那么这里不需要做任何修改。可以直接看下一步。
如果DIS名称不一致,修改如下channel参数,为你自己设定的名称
如果OBS名称不一致,只需要修改obs_dir 参数,目录指向自己obs目录名称,本示例为"outputs-obs/logInfos", 如下图
修改完毕后,点击“语义校验”提示无错误后,点击提交按钮。
注意,右侧参数SPUs 2 并行数1保持默认即可,不需要修改。最后核对信息如下;确认无误后,点击确认按钮
发送DIS数据
使用DIS Agent向云上DIS通道发送CSV结构的数据,DIS Agent是一个本地运行的代理,监控本地文件变化,一旦文件中有新的数据追加,就会即时把新增的数据发送到DIS通道中,类似flume。
启动DIS Agent步骤:
1. 下载DIS Agent Url:https://dis-publish.obs-website.cn-north-1.myhwclouds.com/dis-agent-1.1.0.zip
2. 本地解压
3. 修改 conf/agent.yml
4. 启动 DIS Agent : Linux环境 bin/start-dis-agent.sh ; Windows环境 bin/start-dis-agent.bat
修改conf/agent.yml参数指导:
AK、SK
ak/sk:进入console控制台->右上角 我的账号 选择"我的凭证"-> "管理访问秘钥"->"新增访问秘钥"
projectId
进入console控制台->右上角 我的账号 选择"我的凭证"-> "项目列表"中选择"cn-north-1"对应的"项目ID"
DISStream DIS创建的名称
filePattern填写数据文件所在的路径,参考示例如下:D:/disagent-cw/dis-agent-1.1.0/data/*.log
注意:目录间隔符为/ ,并不是\,因为直接从windows路径中复制会成为\
剩余其他参数不需要变化。修改完毕后注意保存。
发送DIS数据
本示例下的是python程序,文件名称为send.py ,windows主机前提是安装了python程序才可以执行:
import time
for idx in range(10000):
with open("test.log", mode = "a+") as f:
f.write("api.huaweicloud.com||45.249.212.44||15421010072.675||200||651||228||POST
/x/report/heartbeat HTTP/1.1||-||Mozilla/5.0 (Windows NT 6.0; rv:34.0) Gecko/20100101
Firefox/34.0||-||200||0.033||-.918nw0fj-||0.033||140.206.227.10:80" + "\n" +
"api.huaweicloud.com||45.249.212.52||15421010072.875||200||651||228||POST /details/jobs
HTTP/1.1||-||Mozilla/5.0 (Windows NT 6.0; rv:34.0) Gecko/20100101 Firefox/34.0||-
||200||0.033||-.918nw0fj-||0.033||140.206.227.10:80" + "\n")
time.sleep(60)
启动程序
以上内容编辑完成后,需要将send.py 放到之前在agent.yml中filePattern参数指定的目录路径下执行点击send.py 启动程序;本文示例路径为D:/disagent-cw/dis-agent-1.1.0/data/
send.py启动截图(上图)
启动python程序后,再启动DIS Agent程序,DIS Agent : Linux环境 bin/start-dis-agent.sh ; Windows环境 bin/start-dis-agent.bat
DIS Agent启动截图(上图)
登录到obs控制台,查看产生的数据。并且我们可以下载下来,打开查看
打开log_out.1文件如下截图:
我们也可以在cs任务列表中进行查看任务
资源删除
如果您已经完成本示例,记得删除以下资源,以免资源继续产生费用,首先删除CS的Flink SQL作业,然后删除DIS通道,最后删除OBS桶,删除obs桶需要先删除桶内的数据,才能删除桶。
实时流计算服务 CS
版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。