FLink如何编写实时安全检测的示例代码？

本文共计2718个文字，预计阅读时间需要11分钟。

目录+研发背景+场景描述+组件版本+日志结构+技术方案+关键代码+主入口类+mapper算子+filter算子+keyBy算子+窗口函数（核心代码）+最后一次map算子+ElasticSearch工具类+事件实体类+消息实体类

目录

• 研发背景
• 场景描述
• 组件版本
• 日志结构
• 技术方案
• 关键代码
• 主入口类
• mapper算子
• filter算子
• keyBy算子
• 窗口函数（核心代码）
• 最后一次map算子
• ElasticSearch工具类
• 事件实体类
• 消息实体类

研发背景

公司安全部目前针对内部系统的网络访问日志的安全审计，大部分都是T+1时效，每日当天，启动Python编写的定时任务，完成昨日的日志审计和检测，定时任务运行完成后，统一进行企业微信告警推送。