Flink 实践教程-入门（7）：消费 Kafka 数据写入 PG原创

大家好，欢迎收看patchlink实战系列教程，本章节为入门系列7CONNECTOR使用。C kafka数据写入到postsper s色腾讯云六计算LIST10大数据产品生态体系的实时化分析利器，兼容opacheli作业。下面将教大家学习如何利用oless色口作业将s kafka数据写入到PG中。kafka连接器既可以支持用作数据源表，也可以作为aend方式的数据目的表。Upsar kafka连接器可以支持以UPS二D的方式将数据写入kafka topic。JDBC连接器提供了对MYSQLPG等常见的数据库读写支持，其支持用作数据源表、维表和数据目的表。首先选择一台同VPC的CVM进入，使用Python脚本模拟生成数据并写入到soka中。

接下来返回kafka实例，查看topic数据写入情况。我们可以看到，数据已经正常写入到topic中。进入ocean控制台，创建色口作业。点击作业调试，进入作业开发页面，首先创建source，点击插入模板，选择C数据源表和数据目的表，点击添加。修改kafka连接器的相关参数信息和source表的字段信息。

然后创建，点击插入模板，选择JDBC数据目的表，点击添加，修改PG的相关连接参数和sain表的字段信息。

接下来编写业务逻辑，这里我们对原始数据进行算术函数转换操作后写入PG中。Mode函数用于返回榆树。Trunky函数用于设置数据的精度。点击保存语法检查、发布草稿、运行测口作业。我们可以看到作业已经处于运行中状态，接下来进入PG数据库，可以看到数据已经正常写入PG数据库。

注意，这里需要提前在PG数据库创建表。我们进入到ochs官方文档，这里提供了许多算术函数供用户参考使用。