citus 官方文档很不错,资料很全,同时包含一个多租户应用的文档,所以运行下,方便学习

环境准备

使用docker-compose 运行,同时集成了graphql 引擎,很方便

  • docker-compose 文件
version: '2.1'
services:
graphql-engine:
image: hasura/graphql-engine:v1.0.0-alpha26
ports:
- "8080:8080"
command: >
/bin/sh -c "
graphql-engine --database-url postgres://postgres@master/postgres serve --enable-console;
"
master:
container_name: "${COMPOSE_PROJECT_NAME:-citus}_master"
image: 'citusdata/citus:7.5.1'
ports: ["${MASTER_EXTERNAL_PORT:-5432}:5432"]
labels: ['com.citusdata.role=Master']
worker:
image: 'citusdata/citus:7.5.1'
labels: ['com.citusdata.role=Worker']
depends_on: { manager: { condition: service_healthy } }
manager:
container_name: "${COMPOSE_PROJECT_NAME:-citus}_manager"
image: 'citusdata/membership-manager:0.2.0'
volumes: ['/var/run/docker.sock:/var/run/docker.sock']
depends_on: { master: { condition: service_healthy } }
  • 数据准备
curl https://examples.citusdata.com/tutorial/companies.csv > companies.csv
curl https://examples.citusdata.com/tutorial/campaigns.csv > campaigns.csv
curl https://examples.citusdata.com/tutorial/ads.csv > ads.csv
  • 创建表
CREATE TABLE companies (
id bigint NOT NULL,
name text NOT NULL,
image_url text,
created_at timestamp without time zone NOT NULL,
updated_at timestamp without time zone NOT NULL
); CREATE TABLE campaigns (
id bigint NOT NULL,
company_id bigint NOT NULL,
name text NOT NULL,
cost_model text NOT NULL,
state text NOT NULL,
monthly_budget bigint,
blacklisted_site_urls text[],
created_at timestamp without time zone NOT NULL,
updated_at timestamp without time zone NOT NULL
); CREATE TABLE ads (
id bigint NOT NULL,
company_id bigint NOT NULL,
campaign_id bigint NOT NULL,
name text NOT NULL,
image_url text,
target_url text,
impressions_count bigint DEFAULT 0,
clicks_count bigint DEFAULT 0,
created_at timestamp without time zone NOT NULL,
updated_at timestamp without time zone NOT NULL
);
  • 添加表关系
ALTER TABLE companies ADD PRIMARY KEY (id);
ALTER TABLE campaigns ADD PRIMARY KEY (id, company_id);
ALTER TABLE ads ADD PRIMARY KEY (id, company_id);

citus 分布式处理

  • 添加数据分布式表功能

    很方便,就是select 语句,调用函数即可

SELECT create_distributed_table('companies', 'id');
SELECT create_distributed_table('campaigns', 'company_id');
SELECT create_distributed_table('ads', 'company_id');
  • 导入数据

    citus 环境起来之后就可以使用功能导入数据了

  • 效果

  • 一个json 查询
SELECT campaigns.id, campaigns.name, campaigns.monthly_budget,
sum(impressions_count) as total_impressions, sum(clicks_count) as total_clicks
FROM ads, campaigns
WHERE ads.company_id = campaigns.company_id
AND campaigns.company_id = 5
AND campaigns.state = 'running'
GROUP BY campaigns.id, campaigns.name, campaigns.monthly_budget
ORDER BY total_impressions, total_clicks;
  • 效果

数据模型说明

实际上上面的核心是创建分布式表,使用的create_distributed_table,同时定义了,多租户的数据隔离id company_id
后边的操作都是基本的sql 操作,后边会有citus 多租户应用开发的一些好的实践介绍。

参考资料

https://docs.citusdata.com/en/v7.5/get_started/tutorial_multi_tenant.html
https://docs.citusdata.com/en/v7.5/sharding/data_modeling.html#distributing-by-tenant-id
https://github.com/hasura/graphql-on-various-pg
https://github.com/rongfengliang/citus-hasuar-graphql

 
 
 
 

最新文章

  1. 【Java学习笔记】foreach语句(高级for)
  2. 查看mysql表结构和表创建语句的方法(转)
  3. 学员信息录入(StuInfoManager) 用分层实现(既MySchool后的一个案例)
  4. MSP430 flash的操作
  5. 在vim中使用zencoding/Emmet
  6. ajax请求 readyState为0 可能原因之一
  7. FastReport报表MVC显示步骤
  8. fidller判断只抓固定host
  9. 洛谷P1337 [JSOI2004]平衡点 / 吊打XXX(模拟退火)
  10. Python输出和输入
  11. IO流--与properties集合配合使用
  12. scoping作用域,anonymous function匿名函数,built-in functions内置函数
  13. Linux常用基本命令:三剑客命令之-awk格式化动作
  14. Linux 小知识翻译 - 「Linux之父 Linus」
  15. maven私服内容补充
  16. workerman-todpole 执行流程(1)
  17. CSU 1809 - Parenthesis - [前缀和+维护区间最小值][线段树/RMQ]
  18. jsp javabean开发模式
  19. [转]C# 理解lock
  20. Python学习---django下的cookie操作 180201

热门文章

  1. English trip -- MC(情景课)6 Time
  2. codeforces 1042c// Array Product// Codeforces Round #510(Div. 2)
  3. 『PyTorch』第十弹_循环神经网络
  4. 『PyTorch x TensorFlow』第八弹_基本nn.Module层函数
  5. python 小练习 11
  6. page上BeanId与ActionType中的ParameterId
  7. 41. First Missing Positive *HARD*
  8. 部署docker-registry私有仓库
  9. splunk 通过rest http导入数据
  10. JS之Callback function(回调函数)