flink CDC能不能监听Windows上的oracle日志

flink CDC能不能监听Windows上的oracle日志

展开
收起
游客6vdkhpqtie2h2 2022-09-26 20:52:41 2624 发布于浙江 分享
分享
版权
举报
4 条回答
写回答
取消 提交回答
  • 十分耕耘,一定会有一分收获!

    楼主你好,flink CDC能监听Windows上的oracle日志,具体示例如下所示: Oracle参考官网的配置 1.png

    oracle配置如下 连接oracle首先需要打开这两个服务 2.png

    提前创建对应目录然后cmd命令行运行以下命令 3.png

    -- 以 DBA 身份连接到数据库 sqlplus sys/oracleadmin AS SYSDBA

    -- 启用日志归档 alter system set db_recovery_file_dest_size = 10G; alter system set db_recovery_file_dest = 'F:\ORACLE\db_recovery_file_dest' scope=spfile; shutdown immediate; startup mount; alter database archivelog; alter database open;

    -- 检查日志归档是否开启 archive log list;

    -- 为捕获的数据库启用补充日志记录,以便数据更改捕获更改的数据库行之前的状态,下面说明了如何在数据库级别进行配置。 ALTER DATABASE ADD SUPPLEMENTAL LOG DATA;

    -- 创建表空间 CREATE TABLESPACE logminer_tbs DATAFILE 'F:\ORACLE\namespace\logminer_tbs.dbf' SIZE 25M REUSE AUTOEXTEND ON MAXSIZE UNLIMITED;

    -- 创建用户family绑定表空间LOGMINER_TBS CREATE USER family IDENTIFIED BY chickenkang DEFAULT TABLESPACE LOGMINER_TBS QUOTA UNLIMITED ON LOGMINER_TBS;

    -- 授予family用户dba的权限 grant connect,resource,dba to family;

    -- 并授予权限 GRANT CREATE SESSION TO family; GRANT SELECT ON V_$DATABASE to family; GRANT FLASHBACK ANY TABLE TO family; GRANT SELECT ANY TABLE TO family; GRANT SELECT_CATALOG_ROLE TO family; GRANT EXECUTE_CATALOG_ROLE TO family; GRANT SELECT ANY TRANSACTION TO family; GRANT EXECUTE ON SYS.DBMS_LOGMNR TO family; GRANT SELECT ON V_$LOGMNR_CONTENTS TO family; GRANT CREATE TABLE TO family; GRANT LOCK ANY TABLE TO family; GRANT ALTER ANY TABLE TO family; GRANT CREATE SEQUENCE TO family;

    GRANT EXECUTE ON DBMS_LOGMNR TO family; GRANT EXECUTE ON DBMS_LOGMNR_D TO family;

    GRANT SELECT ON V_$LOG TO family; GRANT SELECT ON V_$LOG_HISTORY TO family; GRANT SELECT ON V_$LOGMNR_LOGS TO family; GRANT SELECT ON V_$LOGMNR_CONTENTS TO family; GRANT SELECT ON V_$LOGMNR_PARAMETERS TO family; GRANT SELECT ON V_$LOGFILE TO family; GRANT SELECT ON V_$ARCHIVED_LOG TO family; GRANT SELECT ON V_$ARCHIVE_DEST_STATUS TO family;

    -- 修改user表让其支持增量日志,这句先在Oracle里创建user表再执行 ALTER TABLE FAMILY."user" ADD SUPPLEMENTAL LOG DATA (ALL) COLUMNS;

    2022-10-27 12:09:04 发布于中国台湾 举报
    赞同 1

    评论

    全部评论 (1)

    登录后可评论
    头像
    非常详细,很👍🏻!
    2022-10-31 10:15:18发布于 浙江
    赞同回复举报
  • 亚马逊云科技合作伙伴解决方案架构师,亚马逊云科技User Group Leader,多年云计算经验,csdn/阿里云等平台优质作者,亚马逊云科技社区建设者,亚马逊云科技培训与认证云领袖合作作者,专注于云计算、云原生领域。

    你好,flink CDC 可以监听Windows上的Oracle 可以参考如下两个文章的操作 阿里云实时计算Flink CDC案例:https://developer.aliyun.com/article/834483 国外:https://docs.cloudera.com/cdf-datahub/7.2.15/how-to-ssb/topics/csa-ssb-cdc-connectors.html

    2022-10-25 08:01:47 发布于重庆 举报
    赞同 评论

    评论

    全部评论 (0)

    登录后可评论
  • 一名在读研究生程序猿,欢迎大家指教,我们共同进步!

    可以监听

    具体可参考如下:

    Oracle参考官网的配置

    Flink CDC

    image.png

    2022-10-24 15:58:58 发布于吉林 举报
    赞同 评论

    评论

    全部评论 (0)

    登录后可评论
  • 今天也要加油吖~

    可以监听。

    2022-10-24 14:43:39 发布于江苏 举报
    赞同 评论

    评论

    全部评论 (0)

    登录后可评论

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

收录在圈子:
实时计算 Flink 版(Alibaba Cloud Realtime Compute for Apache Flink,Powered by Ververica)是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统,由 Apache Flink 创始团队官方出品,拥有全球统一商业化品牌,完全兼容开源 Flink API,提供丰富的企业级增值功能。
还有其他疑问?
咨询AI助理
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等