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

请问Flinkcdc中Oracle采用哪种备份库的方式,可以用CDC从备份库获取数据呀?

请问Flinkcdc中Oracle采用哪种备份库的方式,可以用CDC从备份库获取数据呀?

展开
收起
小易01 2023-07-19 18:41:21 65 0
2 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    在 Flink CDC 中,如果您想要从 Oracle 的备份库中获取数据,可以使用 Oracle GoldenGate 技术。Oracle GoldenGate 是 Oracle 公司提供的一种高性能、实时数据复制和数据集成技术,支持从 Oracle 的备份库中抽取数据并进行实时同步。
    在 Oracle GoldenGate 中,可以使用 Extract 进程从备份库中抽取数据,并使用 Pump 进程将数据传输到 Flink CDC 的数据源中。具体来说,您可以在备份库中安装和配置 GoldenGate,然后使用以下命令创建 Extract 进程和 Pump 进程:
    mipsasm
    Copy
    GGSCI> DBLOGIN USERID ggate, PASSWORD ggate
    GGSCI> ADD EXTRACT myextract, TRANLOG, BEGIN NOW
    GGSCI> ADD EXTRACT EXT1, EXTTRAIL ./dirdat/aa, MEGABYTES 100
    GGSCI> ADD RMTTRAIL ./dirdat/bb, EXTRACT EXT1
    GGSCI> ADD EXTRACT PUMP1, EXTTRAILSOURCE ./dirdat/aa, RMTTRAIL ./dirdat/bb
    GGSCI> ADD REPLICAT myrep, EXTTRAIL ./dirdat/bb
    在上述代码中,myextract 是 Extract 进程的名称,EXT1 是从 Oracle 主库中抽取数据的 Extract 进程的名称,PUMP1 是将数据传输到 Flink C

    2023-07-29 18:59:07
    赞同 展开评论 打赏
  • 存在即是合理

    在Flink CDC中,可以使用Oracle的触发器来触发备份操作,并将备份数据同步到Flink中。具体实现方式可以参考Flink官方文档或相关的开源项目。

    2023-07-24 12:57:57
    赞同 展开评论 打赏

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

相关电子书

更多
PostgresChina2018_樊文凯_ORACLE数据库和应用异构迁移最佳实践 立即下载
PostgresChina2018_王帅_从Oracle到PostgreSQL的数据迁移 立即下载
Oracle云上最佳实践 立即下载

相关镜像