实时数仓数据处理流程：协议转换、数据筛选和规则引擎

实时数仓支持将外部交易数据协议转换为内部数据协议，并且支持将行情数据协议转换为内部数据协议。此外，实时数仓还能够接入指定的证券数据。实时数仓通过实现风控网关消息接收接口来获取交易数据和行情数据，并根据数据的消息类型将其分配到不同的转换服务中进行处理。

在处理交易数据时，实时数仓需要先判断数据的证券是否在有效范围内。对于不在处理范围内的证券，实时数仓会直接将其写入本地文件。对于在处理范围内的证券，若数据为委托请求，则实时数仓会缓存委托数据并将其发送给下游规则计算引擎。若数据为撤单请求、订单确认或成交回报数据，则实时数仓会根据溯源插件查找原委托数据填充缺失字段。若溯源失败，则实时数仓会直接将数据写入本地文件。若溯源成功，则实时数仓会将数据发送给下游规则计算引擎。

在处理行情数据时，实时数仓需要先判断行情时间是否在配置的时间范围内。若不在，则实时数仓会直接丢弃该数据。若在，则实时数仓会进行协议解析，并判断该数据的证券是否在有效范围内。对于不在处理范围内的证券，实时数仓会直接丢弃该数据。对于在处理范围内的证券，实时数仓会将数据发送给下游规则计算引擎。