Flink 实践教程：入门（3）：读取 MySQL 数据原创

大家好，欢迎收看patche flink实战系列教程，本章结为入门系列三，Connector使用my seql数据写入到log。腾讯云六计算OIST10大数据产品生态体系的实时化分析利器，兼容opachlink作业。下面将教大家学习如何利用oceanist sequel作业，将MYSQL数据写入到LA s chome。My seql的CDC源表支持对MYSQL数据库的全量和增量读取，并保证exactly want语仪。MYSQLCDC底层使用了代B证母来做CDC logger sink是腾讯云oceanist提供的一个自定义loger视力，它可以将最终的结果输据写入task manager的日志文件中，后续可以通过fli POI或者控制台的日志面板查看这些日志的输出。首先进入MY控制台，进入MY数据库。

在test DB库中创建一张student表，并手动插入两条数据。接下来进入lotness控制台。点击左上角新建按钮，创建C作业。点击开发调试，进入作业编辑页面，首先创建source，点击插入模板，选择MYSQLCD模板。点击添加。进入MYSQL控制台，获取source connector所需的实例信息。然后创建sink。这里我们使用第三方的connector logger sink。需要在帮助文档中找到这个sink，点击oist控制台右上角的帮助文档，在新窗口查看。在SQL开发指南上下游开发指南章节中找到logger sink。

下载lager thinkc the jar Bo，然后回到oceanist控制台，保存作业后，再到依赖管理菜单中上传自己的LA jar Bo。并在作业中引用该logger sink。这里我们先把引用的S表修改好。

在作业参数中选择刚刚上传的logger jar包。接下来编写业务逻辑。点击保存语法检查、发布草稿、运行测口作业。我们可以看到作业已经处于运行中状态，接下来查看下日志。我们可以看到，数据已经从MYQL读出，写入了wa thinkink。

在MY中新增一条数据来验证CDC的特性。通过task manager的日志，我们可以看到新增的数据。这样一个简单的侧口作业就完成了。