代码拉取完成，页面将自动刷新
基于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]
node1
node2
node3
[clickhouse]
node1
node2
node3
git clone https://github.com/tangyibo/clickhouse_installer.git
cd clickhouse_installer/
sh install.sh
cd clickhouse_installer/
sh uninstall.sh
使用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
# 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.1
ClickHouse 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.clusters
Query 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.
在集群中建库，让所有节点都同步创建：
create database test on cluster cluster_3shards_1replicas
drop database test on cluster cluster_3shards_1replicas
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_code
ORDER BY user_id
SETTINGS index_granularity = 8192
说明：
ENGINE后面跟着的参数，是提供给ZooKeeper作区分的该表的路径，对于不同分片上的表，都必须要有不同的路径，所以路径都必须唯一。第一个参数的/clickhouse/tables是官方要求的固定前缀，后面t_user是自己表名，表名前面其实还可以加分片名，总的来说可以写成：/clickhouse/tables/shard/table_name;
第二个参数{replica}指的是副本名称，{副本名}是直接引用配置文件中的你自己配置的副本名称信息;
insert into t_user values('1','tang','X10086');
select * from t_user;
alter table t_user delete where user_id = '1';
先本地创建一个csv格式的文本文件：
cat > t_user.csv <<EOF
2,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"
clickhouse-client -h 127.0.0.1 -d 'test' -q 'select * from t_user format CSV' > ./new_t_user.csv
select count(*) from t_user;
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。