$ cat /etc/redhat-release
CentOS Linux release 7.8.2003 (Core)
$ psql -V
psql (PostgreSQL) 12.3
端口：5432
$ netstat -ntlp|grep post
tcp 0 0 0.0.0.0:5432 0.0.0.0:* LISTEN 10826/postgres
CN節點：192.168.10.71
Worker節點：192.168.10.72、192.168.10.73
安裝citus插件
tar xzf citus-10.0.2.tar.gz cd citus-10.0.2/ ./configure make make install
安裝過程：
./configure
checking for a sed that does not truncate output... /bin/sed checking for gawk... gawk checking for flex... no checking for pg_config... no configure: error: Could not find pg_config. Set PG_CONFIG or PATH.
提示需要配置環境變量：
export PGHOME=/usr/local/pgsql
export PATH=$PATH:$HOME/.local/bin:$HOME/bin:$PGHOME/bin
./configure checking for a sed that does not truncate output... /bin/sed checking for gawk... gawk checking for flex... no checking for pg_config... /usr/local/pgsql/bin/pg_config configure: building against PostgreSQL 12 checking for gcc... gcc checking whether the C compiler works... yes checking for C compiler default output file name... a.out checking for suffix of executables... checking whether we are cross compiling... no checking for suffix of object files... o checking whether we are using the GNU C compiler... yes checking whether gcc accepts -g... yes checking for gcc option to accept ISO C89... none needed checking how to run the C preprocessor... gcc -E checking for grep that handles long lines and -e... /bin/grep checking for egrep... /bin/grep -E checking for ANSI C header files... yes checking for sys/types.h... yes checking for sys/stat.h... yes checking for stdlib.h... yes checking for string.h... yes checking for memory.h... yes checking for strings.h... yes checking for inttypes.h... yes checking for stdint.h... yes checking for unistd.h... yes checking size of void *... 8 checking whether gcc supports -std=gnu99... yes checking whether gcc supports -Wall... yes checking whether gcc supports -Wextra... yes checking whether gcc supports -Wno-unused-parameter... yes checking whether gcc supports -Wno-sign-compare... yes checking whether gcc supports -Wno-missing-field-initializers... yes checking whether gcc supports -Wno-clobbered... yes checking whether gcc supports -Wno-gnu-variable-sized-type-not-at-end... no checking whether gcc supports -Wno-declaration-after-statement... yes checking whether gcc supports -Wendif-labels... yes checking whether gcc supports -Wmissing-format-attribute... yes checking whether gcc supports -Wmissing-declarations... yes checking whether gcc supports -Wmissing-prototypes... yes checking whether gcc supports -Wshadow... yes checking whether gcc supports -Werror=vla... yes checking whether gcc supports -Werror=implicit-int... yes checking whether gcc supports -Werror=implicit-function-declaration... yes checking whether gcc supports -Werror=return-type... yes checking whether gcc supports -fstack-clash-protection... yes checking for curl_global_init in -lcurl... no configure: error: libcurl not found If you have libcurl already installed, see config.log for details on the failure. It is possible the compiler isn't looking in the proper directory. Use --without-libcurl to disable anonymous statistics collection.
$ rpm -qa|grep libcurl
libcurl-7.29.0-57.el7.x86_64
libcurl已安裝，執行
./configure --without-libcurl
$ ./configure --without-libcurl checking for a sed that does not truncate output... /bin/sed checking for gawk... gawk checking for flex... no checking for pg_config... /usr/local/pgsql/bin/pg_config configure: building against PostgreSQL 12 checking for gcc... gcc checking whether the C compiler works... yes checking for C compiler default output file name... a.out checking for suffix of executables... checking whether we are cross compiling... no checking for suffix of object files... o checking whether we are using the GNU C compiler... yes checking whether gcc accepts -g... yes checking for gcc option to accept ISO C89... none needed checking how to run the C preprocessor... gcc -E checking for grep that handles long lines and -e... /bin/grep checking for egrep... /bin/grep -E checking for ANSI C header files... yes checking for sys/types.h... yes checking for sys/stat.h... yes checking for stdlib.h... yes checking for string.h... yes checking for memory.h... yes checking for strings.h... yes checking for inttypes.h... yes checking for stdint.h... yes checking for unistd.h... yes checking size of void *... 8 checking whether gcc supports -std=gnu99... yes checking whether gcc supports -Wall... yes checking whether gcc supports -Wextra... yes checking whether gcc supports -Wno-unused-parameter... yes checking whether gcc supports -Wno-sign-compare... yes checking whether gcc supports -Wno-missing-field-initializers... yes checking whether gcc supports -Wno-clobbered... yes checking whether gcc supports -Wno-gnu-variable-sized-type-not-at-end... no checking whether gcc supports -Wno-declaration-after-statement... yes checking whether gcc supports -Wendif-labels... yes checking whether gcc supports -Wmissing-format-attribute... yes checking whether gcc supports -Wmissing-declarations... yes checking whether gcc supports -Wmissing-prototypes... yes checking whether gcc supports -Wshadow... yes checking whether gcc supports -Werror=vla... yes checking whether gcc supports -Werror=implicit-int... yes checking whether gcc supports -Werror=implicit-function-declaration... yes checking whether gcc supports -Werror=return-type... yes checking whether gcc supports -fstack-clash-protection... yes checking for LZ4_compress_default in -llz4... no configure: error: lz4 library not found If you have lz4 installed, see config.log for details on the failure. It is possible the compiler isn't looking in the proper directory. Use --without-lz4 to disable zlib support.
$ rpm -qa|grep lz4
lz4-1.7.5-3.el7.x86_64
lz4已安裝,執行
./configure --without-libcurl --without-lz4
$ ./configure --without-libcurl --without-lz4 checking for a sed that does not truncate output... /bin/sed checking for gawk... gawk checking for flex... no checking for pg_config... /usr/local/pgsql/bin/pg_config configure: building against PostgreSQL 12 checking for gcc... gcc checking whether the C compiler works... yes checking for C compiler default output file name... a.out checking for suffix of executables... checking whether we are cross compiling... no checking for suffix of object files... o checking whether we are using the GNU C compiler... yes checking whether gcc accepts -g... yes checking for gcc option to accept ISO C89... none needed checking how to run the C preprocessor... gcc -E checking for grep that handles long lines and -e... /bin/grep checking for egrep... /bin/grep -E checking for ANSI C header files... yes checking for sys/types.h... yes checking for sys/stat.h... yes checking for stdlib.h... yes checking for string.h... yes checking for memory.h... yes checking for strings.h... yes checking for inttypes.h... yes checking for stdint.h... yes checking for unistd.h... yes checking size of void *... 8 checking whether gcc supports -std=gnu99... yes checking whether gcc supports -Wall... yes checking whether gcc supports -Wextra... yes checking whether gcc supports -Wno-unused-parameter... yes checking whether gcc supports -Wno-sign-compare... yes checking whether gcc supports -Wno-missing-field-initializers... yes checking whether gcc supports -Wno-clobbered... yes checking whether gcc supports -Wno-gnu-variable-sized-type-not-at-end... no checking whether gcc supports -Wno-declaration-after-statement... yes checking whether gcc supports -Wendif-labels... yes checking whether gcc supports -Wmissing-format-attribute... yes checking whether gcc supports -Wmissing-declarations... yes checking whether gcc supports -Wmissing-prototypes... yes checking whether gcc supports -Wshadow... yes checking whether gcc supports -Werror=vla... yes checking whether gcc supports -Werror=implicit-int... yes checking whether gcc supports -Werror=implicit-function-declaration... yes checking whether gcc supports -Werror=return-type... yes checking whether gcc supports -fstack-clash-protection... yes checking for ZSTD_decompress in -lzstd... no configure: error: zstd library not found If you have zstd installed, see config.log for details on the failure. It is possible the compiler isn't looking in the proper directory. Use --without-zstd to disable zlib support.
執行./configure --without-libcurl --without-lz4 --without-zstd
$ ./configure --without-libcurl --without-lz4 --without-zstd checking for a sed that does not truncate output... /bin/sed checking for gawk... gawk checking for flex... no checking for pg_config... /usr/local/pgsql/bin/pg_config configure: building against PostgreSQL 12 checking for gcc... gcc checking whether the C compiler works... yes checking for C compiler default output file name... a.out checking for suffix of executables... checking whether we are cross compiling... no checking for suffix of object files... o checking whether we are using the GNU C compiler... yes checking whether gcc accepts -g... yes checking for gcc option to accept ISO C89... none needed checking how to run the C preprocessor... gcc -E checking for grep that handles long lines and -e... /bin/grep checking for egrep... /bin/grep -E checking for ANSI C header files... yes checking for sys/types.h... yes checking for sys/stat.h... yes checking for stdlib.h... yes checking for string.h... yes checking for memory.h... yes checking for strings.h... yes checking for inttypes.h... yes checking for stdint.h... yes checking for unistd.h... yes checking size of void *... 8 checking whether gcc supports -std=gnu99... yes checking whether gcc supports -Wall... yes checking whether gcc supports -Wextra... yes checking whether gcc supports -Wno-unused-parameter... yes checking whether gcc supports -Wno-sign-compare... yes checking whether gcc supports -Wno-missing-field-initializers... yes checking whether gcc supports -Wno-clobbered... yes checking whether gcc supports -Wno-gnu-variable-sized-type-not-at-end... no checking whether gcc supports -Wno-declaration-after-statement... yes checking whether gcc supports -Wendif-labels... yes checking whether gcc supports -Wmissing-format-attribute... yes checking whether gcc supports -Wmissing-declarations... yes checking whether gcc supports -Wmissing-prototypes... yes checking whether gcc supports -Wshadow... yes checking whether gcc supports -Werror=vla... yes checking whether gcc supports -Werror=implicit-int... yes checking whether gcc supports -Werror=implicit-function-declaration... yes checking whether gcc supports -Werror=return-type... yes checking whether gcc supports -fstack-clash-protection... yes checking for git... no checking for .git... no configure: creating ./config.status config.status: creating Makefile.global config.status: creating src/include/citus_config.h config.status: creating src/include/citus_version.h
make && make install
編輯參數文件postgresql.conf，cn節點與worker節點
shared_preload_libraries = 'citus'
citus.node_conninfo='sslmode=prefer'
創建擴展
創建測試庫citusdb,如果存在多個業務庫，都需要創建擴展。例如：
citusdb=# create extension citus;
CREATE EXTENSION
worker節點編輯pg_hba.conf
# IPv4 local connections:
host all all 10.154.0.0/32 trust
在CN節點添加worker
測試與worker連通性
$ psql -h localhost -p 1921
$ psql -h 192.168.10.72 -p 1921
$ psql -h 192.168.10.73 -p 1921
psql (12.3)
Type "help" for help.
postgres=#
添加Worker節點（只有CN節點執行）
citusdb=# select master_add_node('192.168.10.72','5432');
master_add_node
-----------------
1
(1 row)
citusdb=# select master_add_node('192.168.10.73','5432');
master_add_node
-----------------
2
(1 row)
查看工作節點
citusdb=# select * from master_get_active_worker_nodes();
node_name | node_port
---------------+-----------
192.168.10.73 | 5432
192.168.10.72 | 5432
(2 rows)
創建表
citusdb=# create table city(id int PRIMARY KEY,name varchar(10));
CREATE TABLE
citusdb=# set citus.shard_count=32;
SET
表分片，分片數，副本數，分片字段數據類型均相同的表自動建立親和關系
citusdb=# select create_distributed_table('city','id');
create_distributed_table
--------------------------
(1 row)
citusdb=# insert into city values (2021,'BeiJing');
INSERT 0 1
citusdb=# insert into city values (2022,'TianJin');
INSERT 0 1
citusdb=# insert into city values (2023,'Boston');
INSERT 0 1
citusdb=# insert into city values (2024,'ShangHai');
INSERT 0 1
citusdb=# select * from city;
id | name
------+----------
2022 | TianJin
2023 | Boston
2021 | BeiJing
2024 | ShangHai
(4 rows)
citusdb=# select tablename from pg_tables where schemaname='public';
tablename
------------
city
(1 rows)
Worker節點：
子節點分片之后的數據表
citusdb=# select tablename from pg_tables where schemaname='public';
tablename
-------------------
city_102040
city_102042
city_102044
city_102046
city_102048
city_102050
city_102052
city_102054
city_102056
city_102058
city_102060
city_102062
city_102064
city_102066
city_102068
city_102070
(16 rows)