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

Flink CDC中oracle dataguard模式下,有没有cdc备库的方案?

Flink CDC中oracle dataguard模式下,有没有cdc备库的方案?

展开
收起
真的很搞笑 2023-11-16 08:07:48 66 0
3 条回答
写回答
取消 提交回答
  • Flink CDC现在支持从 Oracle 数据库的物理备份中恢复数据,同时也支持从Oracle的 Data Guard 中读取数据。以下是一个基本的 Flink CDC Oracle Data Guard 实现方式:

    1. 将 Oracle Data Guard 设置为 read-only 模式。
    2. 安装 Flink CDC connector for Oracle 并启动 job。
    3. 在 job 中指定 Data Guard 的地址,使用 Oracle CDC Connector 从 Data Guard 中读取数据。
    2023-11-16 16:57:15
    赞同 1 展开评论 打赏
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    Oracle Data Guard 是 Oracle 提供的一种高可用解决方案,它可以备份主数据库并在出现故障时接管主数据库的工作负载。
    对于 Flink CDC 而言,在 oracle dataguard 环境下可以使用以下方式进行增量数据捕捉:

    • 在主库上运行 Flink CDC 监听器,将更改事件推送到 Kafka 或其它中间件
    • 在备库上运行 Flink CDC 监听器,并订阅 Kafka 或中间件,消费相同的数据
    • 在备库上运行 Flink SQL 查询并处理这些数据

    请注意,由于主库与备库之间可能存在延迟,因此在备库上捕捉的数据可能存在延时。另外,你需要使用合适的技术手段保证数据一致性。一般来说,在实时应用场景中,可以直接在主库上进行读取,而不必将数据传递至备库进行捕捉,以此减少延迟和确保数据的一致性。如果确实需要在备库中处理数据,可以通过主备同步来确保数据一致。

    2023-11-16 13:10:58
    赞同 展开评论 打赏
  • 是的,Flink CDC确实支持在Oracle Data Guard模式下进行实时数据同步。Oracle Data Guard是一种高可用解决方案,可以在主数据库发生故障时,自动切换到备数据库,以保证业务的连续性。

    在Flink CDC中,你可以通过配置Flink SQL语句来连接到Oracle Data Guard的主数据库和备数据库,然后实时捕获主数据库的变更事件,并将这些事件同步到备数据库。这样,即使主数据库发生故障,也可以通过备数据库继续提供服务。

    2023-11-16 10:04:38
    赞同 展开评论 打赏

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

相关产品

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

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

    相关镜像