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

Flink CDC监听商品表数据 ,然后清理redis 商品缓存?

Flink CDC监听商品表数据 ,然后清理redis 商品缓存?

展开
收起
真的很搞笑 2023-12-01 08:33:55 70 0
3 条回答
写回答
取消 提交回答
  • 首先,你需要在 Flink 中配置 CDC 数据源,使其能够连接到你的数据库系统并捕获商品表的变化数据。然后,你可以将捕获的数据流通过 Flink Table API 转换为流表,然后使用表 API 的 sink () 函数将数据流发送到 Redis,这样就可以清空或更新Redis中的商品缓存。在这个过程中,如果遇到Flink CDC作业未能正常消费删除事件的问题,可能由于网络问题或其他错误,Flink CDC没有正确消费对应的删除事件(delete change log event),所以结果表没有受到影响,数据未被删除。因此,检查和调试Flink CDC作业的配置是非常重要的。

    2023-12-02 17:12:00
    赞同 展开评论 打赏
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    你的需求可以通过以下步骤实现:

    1. 使用Flink CDC(Change Data Capture)监听商品表的数据变化。Flink CDC可以从数据库的binlog中读取数据变更,并将这些变更实时地传输到Flink流处理引擎。

    2. 在Flink中,你可以定义一个处理函数来处理接收到的商品表数据变更。在这个处理函数中,你可以根据需要清理Redis中的商品缓存。

    2023-12-01 14:57:44
    赞同 展开评论 打赏
  • 日志搜下 :from savepoint
    redis和mysql没有关系呀,此回答整理自钉群“Flink CDC 社区”

    2023-12-01 12:13:01
    赞同 展开评论 打赏

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

相关产品

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

    更多
    基于英特尔 SSD 的虚拟机缓存解决SSD 立即下载
    用户态高速块缓存方案 立即下载
    高性能Web架构之缓存体系 立即下载