Flink 实践教程：入门（2）：写入 Elasticsearch原创

大家好，欢迎收看patche linknk实战系列教程，本章节为入门系列二，Connector使用生成数据写入到elastic search搜索引擎。腾讯云六计算OCEANIST10大数据产品生态体系的实时化分析利器，兼容opali作业。下面将教大家学习如何利用u list色口作业将随机数写入到依赖四中。data general连接器是一种内置连接器，不需要额外的依赖项，利用内存的数据生成来创建表。默认情况下将创建无界流数据，每列都有一个随机值，此外也可以指定总行数，从而生成有界表。ES连接器只支持写入，可以作为踏破数据流的目的表，也可以作为abser数据流的目的表。进入ocean控制台，点击左上角新建按钮，创建色口作业。

点击开发调试进入作业编辑页面。接下来创建source，点击插入模板，选择data general虚拟数据源表，点击插入。然后创建点击插入模板，选择elastic search目的表写入，点击插入。接下来根据实际业务情况对SPI进行修改。

进入ES控制台，查看并配置ES相关参数。接下来编写业务逻辑。Ocean平台可以自动匹配需要的ES connector，也可以点击作业参数，在引用程序包处选择自己开发的ES connector。

点击语法检查发布草稿运行口作业。我们可以看到作业已经处于运行中状态，接下来我们查看下ES中写入的数据。进入ES控制台，点击右上角keyboard按钮，进入keyboard。点击左侧第一位tools查询写入数据。我们可以看到数据已经正常写入，这样一个简单的测口作业就完成了。