Skip to main content

Citus Version

versiondate
Citus v112022-06-15
Citus v102021-02-16

Citus v12

set citus.enable_schema_based_sharding to on;

Citus v11

  • 开源所有企业版功能
    • Citus v10 开源了分片平衡
    • Citus v11 开源了所有剩下的企业版功能
  • 使用逻辑复制的 Rebalance - 不阻塞写
  • 更完善的元数据同步 - 多用户、RLS - 集群角色、授权
    • 因此可以直接连任意节点,不再需要连 coordinator
      • 默认隐藏分片表 - 避免看起来很乱
        • 可针对关闭 SET citus.show_shards_for_app_name_prefixes TO 'psql';
        • 全部关闭 SET citus.override_table_visibility TO off;
  • 租户隔离
    • 针对租户的 citus_stat_statements
  • 细粒度控制节点间授权
    • pg_dist_authinfo
    • citus.node_conninfo 支持 sslkey,sslcert
  • 内部链接走内部链接池路由
    • pg_dist_poolinfo
  • COPY 避免校验 JSON/JSONB - 提高数据加载性能 - 之前会导致两次校验
    • 可关闭 SET citus.skip_jsonb_validation_in_copy TO off;
  • 集群信息
    • citus_check_cluster_node_health()
    • citus_backend_gpid() - gpid -> global_pid - 全局识别每个会话
    • citus_stat_activity
    • citus_dist_stat_activity
    • citus_lock_waits
    • pg_cancel_backend() 和 pg_terminate_backend() 支持 gpid
  • 新增 helper
    • run_command_on_coordinator
    • run_command_on_all_nodes
    • citus_is_coordinator
  • Preview
    • Triggers on distributed tables
      • SET citus.enable_unsafe_triggers TO on;
-- 升级
ALTER EXTENSION citus
UPDATE
;

CALL citus_finish_citus_upgrade();

-- 多用户
-- =======
-- ALTER|CREATE|DROP ROLE 会 同步/广播 到其他节点
-- GRANT/REVOKE 也会 同步 到其他节点
-- 配置 citus.enable_alter_database_owner 同步修改 db owner - ALTER DATABASE … OWNER TO
CREATE ROLE create_role_test CREATEDB CREATEROLE LOGIN REPLICATION CONNECTION
LIMIT
105 PASSWORD 'type_your_passwd' VALID UNTIL '2045-05-05 00:00:00.00+00';

-- 因为用户和权限都同步了,所以 RLS 也能生效
CREATE POLICY user_mod ON events FOR
SELECT
TO rls_tenant_1 USING (current_user = 'rls_tenant_' | | tenant_id:: text);

-- 重新平衡
-- =======
SELECT
rebalance_table_shards();

-- 单个表
SELECT
rebalance_table_shards('users');

-- 没有 pk 或 replica identity,
-- 适用于没有更新和删除的表 - 迁移完成后恢复
SELECT
rebalance_table_shards(
'test_table',
shard_transfer_mode = > 'force_logical'
);

-- 租户隔离
-- =======
SELECT
isolate_tenant_to_new_shard('table_name', tenant_id);

SELECT
isolate_tenant_to_new_shard('orders', 135);

-- CASCADE 同时限定 co-located 表
SELECT
isolate_tenant_to_new_shard('orders', 135, 'CASCADE');

-- 集群信息
-- =======
select
key,
citus_backend_gpid()
FROM
distributed_table;

SELECT
global_pid,
query,
state
FROM
citus_stat_activity
WHERE
query ilike 'INSER%'
and global_pid != citus_backend_gpid();

-- 类似 citus_stat_activity,但不包含内部后端
SELECT
global_pid,
query,
state
FROM
citus_dist_stat_activity
WHERE
query ilike 'INSER%'
and global_pid != citus_backend_gpid();

SELECT
*
FROM
citus_lock_waits;
  • ⚠️ 废弃
    • Shard placement invalidation
    • Append-distributed tables - 推荐使用 hash-distributed tables
    • 分布式 cstore_fdw 表 - v10 内置列存储
  • 参考

Citus v10

  • Shard rebalance - 会阻塞读
  • 内置列存储 - columner