Flink 实践教程-进阶（4）：TOP-N原创

大家好，欢迎收看winnk实战系列教程，本章节为进阶系列四窗口TOP10G。腾讯云六计算OIST10大数据产品生态体系的实时化分析利器，兼容opa linknk作业，下面将教大家学习如何利用oless色口作业实时获取seekov稿数据，经过滚动窗口统计，每分钟内购买种类前三名，最后存储在post per s轴。CFT连接器既可以支持用作数据源表，也可以作为追加流的数据目的表。JDBC连接器提供了对MYSQLPG等常见的数据库读写支持。其支持用作数据源表为表和数据目的表。首先，我们进入c Co g实例，新建一个topic，用作色口作业的数据源端。

我们可以选择一台同VPC下的CVM进入，使用提前写好的Python脚本向topic实时写入数据，每秒钟一条。注意，这里需要提前安装Python环境和cof Co拈更多读写方式可以参考c Co Co官方文档。接下来进入cof控制台，查看下topic里面的数据。这个数据是正常写入了。紧接着进入PG实例数据库，创建数据目的表，用来接收数据，这里我们提前创建好了表。进入ocean控制台，创建色口作业。

点击开发调试，进入作业开发页面。首先创建source，单击插入模板，选择cof数据源表和数据目的表，点击添加修改数据源表的相关信息。这里为了方便字段我就复制过来了。接下来创建S，单击插入模板，选择JDBC数据目的表，点击添加修改目的表相关信息。

同样的，这里我也复制过来。最后编写业务逻辑。这里我们先创建一个视图，对原始数据进行过滤，窗口聚合操作，统计每分钟内各个种类的购买数量。

接下来取前面的视图数据，根据窗口开始时间进行排序，取出每分钟内购买量前三的种类数据之后写入sink端。

点击保存语法检查、发布草稿、运行作业。我们可以看到，作业已经处于运行中状态。稍等几分钟过后，我们进入PEG数据库，查看下写入的数据，我们可以看到数据已经正常写入成功。到此为止，我们进阶系列四的演示就结束了，欢迎大家一元购体验流计算lus。