MapReduce服务 MRS-ClickHouse数据批量导入:操作步骤
操作步骤
- 以客户端安装用户,登录客户端所在节点。
- 进入多线程写入工具“clickhouse_insert_tool”所在目录:
cd /opt/client/ClickHouse/clickhouse_insert_tool
- 使用文本编辑器打开clickhouse_insert_tool.sh,按照注释填写所需信息:
参数
参数描述
示例
datapath
待导入数据所在目录。
/opt/data
balancer_ip_list
ClickHouse服务Balancer实例IP地址列表,整体使用括号括起,单个IP使用双引号引起,IP之间使用空格分隔。
("192.168.1.1" "192.168.1.2")
balancer_tcp_port
ClickHouse服务Balancer实例TCP端口。
21428
local_table_name
待导入的本地库名.本地表名。
testdb1.testtb1
thread_num
并发导入线程数。
10
data_format
待导入数据的格式。
CS V
is_security_cluster
是否为安全模式集群。
- true:表示安全模式
- false:表示普通模式
true
- 保存修改后的 “clickhouse_insert_tool.sh”,并执行如下命:
cd /opt/client
source bigdata_env
安全模式(开启Kerberos认证)执行kinit命令,普通模式(关闭Kerberos认证)无需执行:
kinit clickhouseuser
- 运行脚本,导入数据。
./ClickHouse/clickhouse_insert_tool/clickhouse_insert_tool.sh
- 登录ClickHouse客户端节点,连接服务端,具体请参考ClickHouse客户端使用实践。
- 执行如下命令,查询插入数据的本地表对应的分布式表,查看结果是否符合预期:
select count(1) from testdb1.testtb1_all;
- MapReduce服务_什么是Loader_如何使用Loader
- MySQLdump导入数据库_MySQL建立数据库_MySQL数据库导出
- MapReduce服务_什么是MapReduce服务_什么是HBase
- MapReduce服务_什么是存算分离_如何配置MRS集群存算分离
- MapReduce服务_什么是Kafka_如何使用Kafka
- MapReduce服务_什么是Flume_如何使用Flume
- MapReduce工作原理_MapReduce是什么意思_MapReduce流程_MRS_华为云
- 域名转出-域名如何转出-域名转出流程-域名转出操作步骤
- MapReduce服务_什么是ClickHouse_如何使用ClickHouse
- MapReduce服务_如何使用MapReduce服务_MRS集群客户端安装与使用