开源软件名称：clickhouse_installer
开源软件地址：https://gitee.com/inrgihc/clickhouse_installer
开源软件介绍：
ClickHouse集群一键安装基于ansible快速安装ClickHouse相关组件 项目地址： 一、安装准备安装文件格式配置主机IP及密码等，各个组件安装的节点等，示例如下： [nodes]172.17.203.92 hostname=node1 ansible_ssh_user=root ansible_ssh_port=22 ansible_ssh_pass='123321'172.17.203.93 hostname=node2 ansible_ssh_user=root ansible_ssh_port=22 ansible_ssh_pass='123321'172.17.203.94 hostname=node3 ansible_ssh_user=root ansible_ssh_port=22 ansible_ssh_pass='123321'[zookeeper]node1node2node3[clickhouse]node1node2node3 二、一键安装1、安装git clone https://github.com/tangyibo/clickhouse_installer.gitcd clickhouse_installer/sh install.sh 2、卸载cd clickhouse_installer/sh uninstall.sh 三、分步安装1、安装使用yum安装ansible: # yum install -y epel-release# yum install -y ansible 执行如下命令所有集群服务器/etc/hosts及root免密配置: # ansible-playbook -i hosts.ini prepare.yaml 查看 vars/var_zookeeper.yml的参数配置，尤其根据版本号检查下载地址是否可用，然后执行shell命令安装zookeep集群: # ansible-playbook -i hosts.ini zookeeper.yaml 查看 vars/var_clickhouse.yml的参数配置，尤其是确认数据安装目录，然后执行shell命令安装ClickHouse集群: # ansible-playbook -i hosts.ini clickhouse.yaml 2、卸载# ansible-playbook -i hosts.ini cleanup.yaml 四、集群验证登录clickhouse集群的任意一台机器节点，执行如下命令： clickhouse-client -h 127.0.0.1 然后执行如下SQL语句查看集群节点配置信息： select * from system.clusters; 我的信息如下： [root@node1 ~]# clickhouse-client -h 127.0.0.1ClickHouse client version 21.1.2.15 (official build).Connecting to 127.0.0.1:9000 as user default.Connected to ClickHouse server version 21.1.2 revision 54443.node1 :) select * from system.clusters;SELECT *FROM system.clustersQuery id: 4cdcd3d4-855b-4774-8669-e873bd33bf73┌─cluster───────────────────────────┬─shard_num─┬─shard_weight─┬─replica_num─┬─host_name─┬─host_address──┬─port─┬─is_local─┬─user────┬─default_database─┬─errors_count─┬─estimated_recovery_time─┐│ cluster_3shards_1replicas │ 1 │ 1 │ 1 │ node1 │ 172.17.203.92 │ 9000 │ 1 │ default │ │ 0 │ 0 ││ cluster_3shards_1replicas │ 2 │ 1 │ 1 │ node2 │ 172.17.203.93 │ 9000 │ 0 │ default │ │ 0 │ 0 ││ cluster_3shards_1replicas │ 3 │ 1 │ 1 │ node3 │ 172.17.203.94 │ 9000 │ 0 │ default │ │ 0 │ 0 ││ test_cluster_two_shards │ 1 │ 1 │ 1 │ 127.0.0.1 │ 127.0.0.1 │ 9000 │ 1 │ default │ │ 0 │ 0 ││ test_cluster_two_shards │ 2 │ 1 │ 1 │ 127.0.0.2 │ 127.0.0.2 │ 9000 │ 0 │ default │ │ 0 │ 0 ││ test_cluster_two_shards_localhost │ 1 │ 1 │ 1 │ localhost │ ::1 │ 9000 │ 1 │ default │ │ 0 │ 0 ││ test_cluster_two_shards_localhost │ 2 │ 1 │ 1 │ localhost │ ::1 │ 9000 │ 1 │ default │ │ 0 │ 0 ││ test_shard_localhost │ 1 │ 1 │ 1 │ localhost │ ::1 │ 9000 │ 1 │ default │ │ 0 │ 0 ││ test_shard_localhost_secure │ 1 │ 1 │ 1 │ localhost │ ::1 │ 9440 │ 0 │ default │ │ 0 │ 0 ││ test_unavailable_shard │ 1 │ 1 │ 1 │ localhost │ ::1 │ 9000 │ 1 │ default │ │ 0 │ 0 ││ test_unavailable_shard │ 2 │ 1 │ 1 │ localhost │ ::1 │ 1 │ 0 │ default │ │ 0 │ 0 │└───────────────────────────────────┴───────────┴──────────────┴─────────────┴───────────┴───────────────┴──────┴──────────┴─────────┴──────────────────┴──────────────┴─────────────────────────┘11 rows in set. Elapsed: 0.008 sec. 五、使用教程1、创建分布式库在集群中建库，让所有节点都同步创建： create database test on cluster cluster_3shards_1replicas 2、删除分布式库drop database test on cluster cluster_3shards_1replicas 3、创建分布式表user test;CREATE TABLE IF NOT EXISTS t_user ON CLUSTER cluster_3shards_1replicas( `user_id` UInt16, `user_name` String, `user_code` String)ENGINE = ReplicatedMergeTree('/clickhouse/tables/t_user', '{replica}')PARTITION BY user_codeORDER BY user_idSETTINGS index_granularity = 8192说明： ENGINE后面跟着的参数，是提供给ZooKeeper作区分的该表的路径，对于不同分片上的表，都必须要有不同的路径，所以路径都必须唯一。第一个参数的/clickhouse/tables是官方要求的固定前缀，后面t_user是自己表名，表名前面其实还可以加分片名，总的来说可以写成：/clickhouse/tables/shard/table_name; 第二个参数{replica}指的是副本名称，{副本名}是直接引用配置文件中的你自己配置的副本名称信息;
4、插入数据/查询数据/删除数据insert into t_user values('1','tang','X10086');select * from t_user;alter table t_user delete where user_id = '1';5、批量导入CSV数据先本地创建一个csv格式的文本文件： cat > t_user.csv <<EOF2,john,10010,3,jack,10000,EOF 然后使用命令导入： cat ./t_user.csv | clickhouse-client -h 127.0.0.1 --query="insert into test.t_user format CSV" 6、查询结果数据导出clickhouse-client -h 127.0.0.1 -d 'test' -q 'select * from t_user format CSV' > ./new_t_user.csv 7、查询表记录总数select count(*) from t_user;  |
客服电话
APP下载
官方微信
请发表评论