1
学习教程
请认真阅读教程后再参赛去学习
2
领取免费资源
需要领取Flink/OSS免费资源去领取
3
实操上手
前往实时计算Flink控制台进行实操去实操
4
上传作品
截图分析结果,附上关键代码去上传

学习使用 Flink 对 GitHub 的实时事件流进行分析

通过 Flink 对 GitHub 的实时事件流进行分析,并通过报表直观展示,了解 GitHub 的最新热门趋势、特定仓库或者组织的活跃度。您可以通过本次活动对 Flink SQL 基础能力和 Flink 实时处理特性有直观的初步体验。
产品开通流程说明
作者信息

活动必备资源

免费领取实时计算Flink、对象存储OSS进行实操,领取并使用才可获奖。活动结束后如不需要继续使用,请及时清理测试数据和试用资源,否则计算资源耗尽后会产生扣费。
No entry or manifest in @ali/alfa-aliyundotcom-free-widget-goods-card
Error: No entry or manifest in @ali/alfa-aliyundotcom-free-widget-goods-card
    at https://g.alicdn.com/hmod/ace-developer-factory-free-product/0.0.10/??index.js,services.js:1:272373
    at h (https://g.alicdn.com/hmod/ace-developer-factory-free-product/0.0.10/??index.js,services.js:1:125719)
    at Generator.<anonymous> (https://g.alicdn.com/hmod/ace-developer-factory-free-product/0.0.10/??index.js,services.js:1:125470)
    at Generator.next (https://g.alicdn.com/hmod/ace-developer-factory-free-product/0.0.10/??index.js,services.js:1:126078)
    at f (https://g.alicdn.com/hmod/ace-developer-factory-free-product/0.0.10/??index.js,services.js:1:204053)
    at a (https://g.alicdn.com/hmod/ace-developer-factory-free-product/0.0.10/??index.js,services.js:1:204255)
    at https://g.alicdn.com/hmod/ace-developer-factory-free-product/0.0.10/??index.js,services.js:1:204314
    at new Promise (<anonymous>)
    at https://g.alicdn.com/hmod/ace-developer-factory-free-product/0.0.10/??index.js,services.js:1:204196
    at https://g.alicdn.com/hmod/ace-developer-factory-free-product/0.0.10/??index.js,services.js:1:272563
No entry or manifest in @ali/alfa-aliyundotcom-free-widget-goods-card
Error: No entry or manifest in @ali/alfa-aliyundotcom-free-widget-goods-card
    at https://g.alicdn.com/hmod/ace-developer-factory-free-product/0.0.10/??index.js,services.js:1:272373
    at h (https://g.alicdn.com/hmod/ace-developer-factory-free-product/0.0.10/??index.js,services.js:1:125719)
    at Generator.<anonymous> (https://g.alicdn.com/hmod/ace-developer-factory-free-product/0.0.10/??index.js,services.js:1:125470)
    at Generator.next (https://g.alicdn.com/hmod/ace-developer-factory-free-product/0.0.10/??index.js,services.js:1:126078)
    at f (https://g.alicdn.com/hmod/ace-developer-factory-free-product/0.0.10/??index.js,services.js:1:204053)
    at a (https://g.alicdn.com/hmod/ace-developer-factory-free-product/0.0.10/??index.js,services.js:1:204255)
    at https://g.alicdn.com/hmod/ace-developer-factory-free-product/0.0.10/??index.js,services.js:1:204314
    at new Promise (<anonymous>)
    at https://g.alicdn.com/hmod/ace-developer-factory-free-product/0.0.10/??index.js,services.js:1:204196
    at https://g.alicdn.com/hmod/ace-developer-factory-free-product/0.0.10/??index.js,services.js:1:272563
我的作品
领取资源,提交报表界面截图,如您挑战非文档设定实验,需附上关键代码
上传作品
参与作品展示
最新最热
统计当天各个仓库新增Star数Top 10排行榜。
首先我要感谢点赞的各位宝宝;图片是实时统计过去一周里Github小时级别的评论热力图,阿里云的文档比较完成,之前没有操作过,这次是根据教学文档一步步来完成的实验的,想拿1个杯子,哈哈哈
统计过去一周Github Fork数排行TOP 10
尝试了下实验提供的模板,3个任务都可以运行,按照手册,自己特意尝试了创建表,写入数据的方式,体验Flink的操作。最后还是选择这张图上传。
初学者 SELECT SUBSTRING(randstr,0,8) from datagen_source;
统计过去一周里Github小时级别的评论热力图
使用内置公开数据集快速体验实时计算Flink版,实现查看某组织近7天的开发者活跃度实时趋势
统计过去一周里Github小时级别的评论热力图
实时统计过去3天里Github小时级别的评论热力图。 SELECT DATE_FORMAT(created_at_ts, &#39;yyyy-MM-dd&#39;) as comment_date, HOUR(created_at_ts) AS comment_hour ,COUNT(*) AS comment_count FROM gh_event WHERE created_at_ts &gt;= NOW() - INTERVAL &#39;3&#39; DAY AND (type=&#39;CommitCommentEvent&#39; OR type=&#39;IssueCommentEvent&#39; or type = &#39;PullRequestReviewCommentEvent&#39;) GROUP BY DATE_FORMAT(created_at_ts, &#39;yyyy-MM-dd&#39;), HOUR(created_at_ts) ;
-- 查看google最近5天的开发者活跃度实时趋势。 SELECT NOW() as `current_ts`, COUNT(*) as pr_count FROM gh_event WHERE org_login = &#39;google&#39; and type = &#39;PullRequestEvent&#39; and created_at_ts &gt;= NOW() - INTERVAL &#39;5&#39; DAY;
统计过去一周里Github小时级别的评论热力图
查看当天当天评论数最多的10个仓库。根据教程,很快就完成了排行统计,实时出图非常的方便 代码如下: SELECT DATE_FORMAT(created_at_ts, &#39;yyyy-MM-dd&#39;) as `date`, repo_name, COUNT(*) as num FROM gh_event WHERE DATE_FORMAT(created_at_ts, &#39;yyyy-MM-dd&#39;) = DATE_FORMAT(NOW(), &#39;yyyy-MM-dd&#39;) AND (type=&#39;CommitCommentEvent&#39; OR type=&#39;IssueCommentEvent&#39; or type = &#39;PullRequestReviewCommentEvent&#39;) GROUP BY DATE_FORMAT(created_at_ts, &#39;yyyy-MM-dd&#39;), repo_name ORDER BY num DESC LIMIT 10;
查看当天Github新增star数Top 20仓库 SELECT DATE_FORMAT(created_at_ts, &#39;yyyy-MM-dd&#39;) as `date`, repo_name, COUNT(*) as num FROM gh_event WHERE type = &#39;WatchEvent&#39; AND DATE_FORMAT(created_at_ts, &#39;yyyy-MM-dd&#39;) = DATE_FORMAT(NOW(), &#39;yyyy-MM-dd&#39;) GROUP BY DATE_FORMAT(created_at_ts, &#39;yyyy-MM-dd&#39;), repo_name ORDER BY num DESC LIMIT 20;
统计当天各个仓库新增Star数Top 10排行榜。