今日指数项目之板块任务开发

Posted 2022-05-03 Maynor学长

板块

板块描述：板块分为概念板块、行业板块和地域板块，行情业务是按照行业划分的板块，比如：电子、房地产、银行等。每一个板块下又细分为很多的个股，所以板块实时行情能够反映行业下的个股行情概况。本节板块开发内容是针对沪市个股数据开发的沪市板块个股行情数据。
板块行情业务处理内容包含：
1.秒级行情(5s)
2.分时行情（60s）
3.分时行情备份
4.板块K线(日、周、月)
这里我们先处理前3个业务点。

初始化执行环境

开发步骤：
1.创建SectorStream主类，添加main方法
2.获取流处理执行环境
3.设置事件时间
4.设置检查点机制
5.设置重启机制
6.整合Kafka
7.数据过滤（时间和null字段）
8.数据转换
9.过滤个股数据
10.设置水位线
11.触发执行

 /**

 * 板块行情数据处理

     * 1.秒级行情(5s)
    
 * 2.分时行情（60s）
    
     * 3.分时行情备份
    
     * 4.板块K线(日、周、月)
       */
       //1.创建SectorStream单例对象