温馨提示:文本由机器自动转译,部分词句存在误差,以视频为准
00:00
大家好,欢迎收看patchlink实战系列教程,本章结为入门系列6CONNECTOR使用。Post s数据写入到click house z、腾讯云流计算OCEANIST10大数据产品生态体系的实时化分析利器,兼容opache flink作业。下面将教大家学习如何利用busless涩口作业,将post per s数据写入到click house z。Post per s的CDC原表及post per s的流失源表,用于依次读取post per s数据库全量快照数据和变更数据。基于flink exactly once语仪,即使发生故障时也能保证不多读也不少读一条数据。click house不支持标准的更新和删除操作。若您的任务有更新和删除操作,可以通过collapse merge tree来实现。首先进入PG数据库准备数据。这里我提前在数据库里创建了表test,并手动插入了三条数据。
01:01
接下来我们通过一台CVM连接上CK集群,这里我已经提前创建好了表,接下来进入lot控制台。点击左上角新建按钮,创建色口作业。点击开发调试进入作业编辑页面。首先创建source,点击插入模板,选择postpers数据源表数据实时同步CDC,点击添加,然后创建sin,点击插入模板,选择clickhouse数据目的表,点击添加。
02:16
进入PG控制台获取实例相关信息。
03:29
进入CK控制台获取集群相关信息。注意需要使用HTTP方式的集群访问地址。
04:05
接下来编写业务逻辑,这里我们对原始数据进行字符串转换操作后写入CI。点击保存语法检查、发布草稿、运行测口作业。
05:18
我们可以看到,作业已经处于运行中状态。接下来进入CVM,登录CK集群,并查看写入的数据。
我来说两句