开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

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

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

展开
收起
游客6vdkhpqtie2h2 2022-09-26 20:52:41 2574 0
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
    赞同 展开评论 打赏
  • 亚马逊云科技合作伙伴解决方案架构师,亚马逊云科技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
    赞同 展开评论 打赏
  • 一名在读研究生程序猿,欢迎大家指教,我们共同进步!

    可以监听

    具体可参考如下:

    Oracle参考官网的配置

    Flink CDC

    image.png

    2022-10-24 15:58:58
    赞同 展开评论 打赏
  • 今天也要加油吖~

    可以监听。

    2022-10-24 14:43:39
    赞同 展开评论 打赏

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

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载

    相关镜像