,cdc oracle增量读取需要的最小权限列表啊,另外可以从oracle从库读取吗,cdc 和flink推荐的版本是多少啊?
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
为了进行Oracle数据库的CDC(Change Data Capture)增量读取,您需要为oms_user用户(或相应的Oracle用户)授予以下最小权限列表:
增量同步所需权限:
SELECT
权限 on V_$ARCHIVED_LOG
, V_$DATABASE
, V_$LOG
, V_$LOGFILE
, V_$LOGMNR_CONTENTS
, V_$PARAMETER
, 以及 SYS.DBMS_LOGMNR
的 EXECUTE
权限。针对Oracle 12C及以上版本的额外需求:
CONTAINER=ALL
,除了业务表的直接SELECT权限。处理新增表的增量数据:
SELECT ANY TABLE
权限。对于是否能从Oracle从库读取增量数据,理论上只要从库开启了日志记录并且具有足够的权限支持CDC操作,Flink CDC是可以配置从Oracle从库读取增量数据的。但请注意,实际操作时要确保从库的日志与主库保持一致,并且考虑数据延迟和一致性问题。
关于Flink和Flink CDC推荐的版本,虽然具体推荐版本可能会随时间更新,但基于资料,Flink CDC 3.0被提及作为数据摄入模块,这表明至少在该文档撰写时,Flink CDC 3.0是一个兼容性和功能较为完善的版本。同时,Flink 1.15以上版本支持整库同步,意味着对于希望利用Flink进行全量及增量数据处理的用户来说,选择1.15或更高版本将更为合适。
综上所述,进行Oracle CDC增量读取时,请确保分配了上述最小权限,并根据实际情况考虑从库的使用。推荐使用Flink 1.15及以上版本配合Flink CDC 3.0进行数据同步作业的部署与实施。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。