从Flink SQL导入
本文介绍如何使用Flink SQL方式将Flink中的数据写入云数据库ClickHouse。
使用限制
只有Flink计算引擎VVR 3.0.2及以上版本支持使用Flink SQL写入云数据库ClickHouse。
前提条件
已在云数据库ClickHouse中创建表。更多信息,请参见创建表。
已在云数据库ClickHouse中设置白名单。更多信息,请参见设置白名单。
已开通Flink全托管。更多信息,请参见开通Flink全托管。
操作步骤
登录Flink全托管控制台,新建作业。
编写并执行代码。
创建源表、结果表,并将源表数据插入到结果表中。
--创建源表sls_test_single_local。 CREATE TEMPORARY TABLE sls_test_single_local ( id INT, name VARCHAR, age BIGINT, rate FLOAT ) WITH ( 'connector' = 'datagen', 'rows-per-second' = '50' ); --创建结果表clickhouse_output。 CREATE TEMPORARY TABLE clickhouse_output ( id INT, name VARCHAR, age BIGINT, rate FLOAT ) WITH ( 'connector' = 'clickhouse', 'url' = 'jdbc:clickhouse://demo.aliyuncs.com:8123', 'userName' = 'test', 'password' = '280226Ck', 'tableName' = 'sls_test_single_local' ); --将源表数据插入到结果表。 INSERT INTO clickhouse_output SELECT id, name, age, rate FROM sls_test_single_local;
说明创建结果表的语法说明,请参见ClickHouse结果表。
单击保存。
单击验证。
单击上线。
在弹出的上线确认窗口中单击确认,将作业发布至生产环境。
上线成功后,在弹出的上线成功,请前往运维查看详情中单击运维。
在作业运维页面,启动作业。
单击右上方启动。
在弹出的作业启动配置页面,单击确认启动。
在云数据库ClickHouse中查询表。
在页面左上角,选择目标集群所在的地域。
在集群列表页面,选择目标集群对应类型的实例列表,单击目标集群ID。
在集群信息页面,单击右上方导航栏的登录数据库。
在登录实例页面,输入数据库账号和密码,单击登录。
输入查询语句并单击执行(F8)。本文使用下面的示例语句。
select * from db01.sls_test_single_local;
查询结果如下。