数据仓库服务 GAUSSDB(DWS)-通过DLI Flink作业将Kafka数据实时写入GaussDB(DWS):步骤五:准备DWS对接Flink工具dws-connector-flink

时间:2024-09-14 17:38:49

步骤五:准备DWS对接Flink工具dws-connector-flink

dws-connector-flink是一款基于DWS JDBC接口实现对接Flink的一个工具。在配置 DLI 作业阶段,将该工具及依赖放入Flink类加载目录,提升Flink作业入库DWS的能力。

  1. 浏览器访问https://mvnrepository.com/artifact/com.huaweicloud.dws
  2. 在软件列表中选择最新版本的DWS Connectors Flink,本实践选择DWS Connector Flink 2 12 1 12

  3. 单击“1.0.4”分支,实际请以官网发布的新分支为准。

  4. 单击“View ALL”。

  5. 单击dws-connector-flink_2.12_1.12-1.0.4-jar-with-dependencies.jar,下载到本地。

  6. 创建OBS桶,本实践桶名设置为obs-flink-dws,并将此文件上传到OBS桶下,注意桶也保持与DLI在一个区域下,本实践为“ 华北-北京四”。

    图13 上传jar包到OBS桶

support.huaweicloud.com/bestpractice-dws/dws_05_0110.html