参加《21天晋级大数据实战营》——DAY9 1天精通实时流计算实验小结

举报
richblue88 发表于 2018/12/07 21:28:51 2018/12/07
【摘要】 1、创建Flink SQL作业准备2、通道建立数据接入服务创建2个通道，csinput、csoutput3、SMN主题https://console.huaweicloud.com/smn/?region=cn-north-1#/smn/manager/dashboard 添加订阅获取URNurn:smn:cn-north-1:b5080652e5a1415182ad3855c0d9224e...

1、创建Flink SQL作业准备

图片.png

图片.png


图片.png

图片.png


图片.png

图片.png

图片.png

图片.png


2、通道建立

数据接入服务

图片.png

图片.png



图片.png


创建2个通道，csinput、csoutput

图片.png

图片.png

图片.png

图片.png

3、SMN主题

https://console.huaweicloud.com/smn/?region=cn-north-1#/smn/manager/dashboard

图片.png


图片.png


图片.png

图片.png

添加订阅

图片.png

图片.png

获取URN

图片.png

urn:smn:cn-north-1:b5080652e5a1415182ad3855c0d9224e:cs-test

图片.png

图片.png



4、Flink SQL作业

图片.png

图片.png

图片.png

图片.png

5、发送DIS数据，测试结果

下载dis-agent-1.1.0.zip

解压

修改conf/agent.yml

图片.png

图片.png

切换目录

D:\dis-agent-1.1.0\bin

start-dis-agent.bat启动

图片.png


发送DIS数据

图片.png

使用Maven下载guava-22.0.jar

图片.png

图片.png


图片.png



图片.png



图片.png


跑一次作业没数据没邮件

作业停止后，尝试调试作业，就有数据和邮件了：

图片.png



图片.png

图片.png


图片.png


图片.png





【版权声明】本文为华为云社区用户原创内容，转载时必须标注文章的来源（华为云社区）、文章链接、文章作者等基本信息， 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容，欢迎发送邮件进行举报，并提供相关证据，一经查实，本社区将立刻删除涉嫌侵权内容，举报邮箱： cloudbbs@huaweicloud.com
实时流计算服务 CS 大数据 云学院
  • 点赞
  • 收藏
  • 关注作者

评论（0）

0/1000
抱歉，系统识别当前为高风险访问，暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称，即可参与社区互动！

*长度不超过10个汉字或20个英文字符，设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符，设置后3个月内不可修改。

确认 取消

加入云驻计划，成为创作者

  • 华为云周边好礼
  • 免费体验产品
  • 特殊身份标识
  • 线下官方门票
  • 内部专家零距离
  • 与10000+优质创作者共同成长
立即加入