数据库有问必答｜如何通过开源Flink导入数据至AnalyticDB MySQL？

Q: 如何通过开源Flink导入数据至AnalyticDB MySQL？

您可以使用如下方法将开源Flink中的数据写入AnalyticDB MySQL版集群：

• 前提条件

①.下载Flink驱动，并将其部署到Flink所有节点的${flink部署目录}/lib目录下，您可以根据Flink版本下载对应的驱动；
②.下载MySQL驱动，并将其部署到Flink所有节点的${flink部署目录}/lib目录下，MySQL驱动版本需为5.1.40或以上；
③.部署所有的JAR包后需要重启Flink集群；
④.已在目标AnalyticDB MySQL版集群中创建数据库和数据表，用于保存需要写入的数据；
⑤.如果您的AnalyticDB MySQL集群是弹性模式，您需要在集群信息页面的网络信息区域，打开启用ENI网络的开关。

• 导入流程介绍

①.数据准备：创建一个新的CSV文件并在文件中写入源数据，然后将新文件部署至Flink所有节点的/root下；
②.数据写入：通过SQL语句在Flink中创建源表和结果表，并通过源表和结果表将数据写入AnalyticDB MySQL中；
③.数据验证：登录AnalyticDB MySQL目标数据库，来查看并验证源数据是否成功导入。

注意：本文仅介绍通过Flink SQL创建表并写入数据至AnalyticDB MySQL版的方法，且仅适用于Flink1.11及以上版本。