本文通过安全监控作业案例,帮助您了解实时计算Flink版作业开发流程。

实时安全监控案例介绍

实时监控报警作为保障数据安全的重要环节,受到越来越多的关注。为了保证同时满足数据的正确性和实效性,实时计算Flink版将流式数据源表和存放白名单的维度表进行实时JOIN,识别源表中数据对应的地址是否存在于白名单中,采取过滤等措施。
说明 本案例适用于实时计算Flink版共享模式(已停购)和独享模式。

安全监控业务架构图

Architecture
  • DataHub源表结构
    字段名 类型 注释
    name varchar 名称
    place varchar 地址
  • RDS维表结构
    字段名 类型 注释
    place varchar 白名单地址
  • RDS结果表结构
    字段名 类型 注释
    name varchar 过滤后的名称
    place varchar 地址

作业操作流程