版本要求

PostgreSQL: 9.6, 10, 11, 12 +

连接器：flink-cdc-connectors

操作步骤

更改wal日志方式为logical

wal_level = logical # minimal, replica, or logical

阿里云中修改参数设置会实例重启，谨慎操作

修改域信息，保证本机可以连接

新建用户

CREATE USER user WITH PASSWORD 'pwd';

给用户复制流权限

ALTER ROLE user replication;

给用户数据库权限

grant CONNECT,CREATE ON DATABASE test to user;

把当前库public下所有表查询权限赋给用户（可选部分表）

GRANT SELECT ON cgm_device TO user;

发布表

CREATE PUBLICATION dbz_publication FOR TABLE cgm_device,cgm_user_info,cgm_user_action,cgm_user_patient;

查询哪些表已经发布

select * from pg_publication_tables;

其他命令

-- 赋予权限 GRANT privilege_list | ALL ON table_name TO role_name;

GRANT SELECT ON cgm_device TO dev_user;

-- 权限回收

REVOKE ALL ON ALL TABLES IN SCHEMA public FROM dev_user;

-- 查看某用户的系统权限

SELECT * FROM pg_roles WHERE rolname='dev_user';

-- 查询当前用户所有表权限

SELECT * FROM information_schema.table_privileges WHERE grantee = 'dev_user'

-- 查看户在某表的列上的权限

select * from information_schema.column_privileges where grantee='dev_user';

-- 查看usage权限表

SELECT * FROM information_schema.usage_privileges WHERE grantee = 'dev_user'

-- 查看当前用户能够访问的数据类型

select * from information_schema.data_type_privileges;

flink-cdc 同步 Postgre SQL 基本配置【1】相关推荐

Flink CDC 实时同步mysql
前言在实际开发中,需要做数据同步的场景是非常多的,比如不同的应用之间不想直接通过RPC的方式进行数据交互,或者说下游应用需要检测来自上游应用的某些业务指标数据的变化时,这些都可以考虑使用数据同步的方 ...
StarRocks X Flink CDC，打造端到端实时链路
实时数仓建设背景实时数仓需求随着互联网行业的飞速发展,企业业务种类变得越来越多,数据量也变得越来越大.以 Apache Hadoop 生态为核心的数据看板业务一般只能实现离线的业务.在部分领域,数 ...
Flink CDC 2.0原理详解和生产实践
点击上方蓝色字体,选择"设为星标" 回复"面试"获取更多惊喜八股文交给我,你们专心刷题和面试 Hi,我是王知无,一个大数据领域的原创作者. 放心关注我,获取更 ...
4.3.2 Flink-流处理框架-Flink CDC数据实时数据同步-何为Flink CDC？
目录 1.写在前面 2.Flink CDC出现的动机 3.基于传统的CDC的ETL分析 4.基于Flink CDC的ETL分析 5.支持的版本和连接器 1.写在前面 CDC是一种可以捕获数据库变更的技 ...
Flink CDC 系列（3）—— Flink CDC MySQL Connector 与 Flink SQL 的结合使用案例Demo
Flink CDC 系列文章: <Flink CDC 系列(1)-- 什么是 Flink CDC> <Flink CDC 系列(2)-- Flink CDC 源码编译> < ...
Flink CDC mongoDB 使用及Flink sql解析monggo中复杂嵌套JSON数据实现
需要实时采集MongoDB中的数据,所以考虑使用flink cdc mongodb,在flink cdc2.1版本后也支持了MongoDB的数据采集,是通过oplog. MongoDB中的存储数据的文 ...
flink cdc MySQL2Doris 案例分享解决分库多表同步
案例简单说明使用flink cdc,完成mysql 多库多表同时同步到doris中版本信息 flink 1.14.4 doris 1.1.0 依赖 <properties><m ...
Flink原理解析50篇（四）-基于 Flink CDC 打通数据实时入湖
在构建实时数仓的过程中,如何快速.正确的同步业务数据是最先面临的问题,本文主要讨论一下如何使用实时处理引擎Flink和数据湖Apache Iceberg两种技术,来解决业务数据实时入湖相关的问题. 0 ...
基于Flink CDC打通数据实时入湖
作者 | 数据社责编 | 欧阳姝黎在构建实时数仓的过程中,如何快速.正确的同步业务数据是最先面临的问题,本文主要讨论一下如何使用实时处理引擎 Flink 和数据湖 Apache Ice ...

flink-cdc 同步 Postgre SQL 基本配置【1】

版本要求

连接器：flink-cdc-connectors

操作步骤

其他命令

flink-cdc 同步 Postgre SQL 基本配置【1】相关推荐

最新文章

热门文章