基于Flink的实时计算方法、装置、计算机设备及存储介质

摘要

本发明公开了一种基于Flink的实时计算方法、装置、计算机设备及存储介质，该方法包括：获取实时数据，根据实时数据以及预设规则生成待处理的目标数据，实时数据包括实时数据的生成时间，对从预设数据库获取到的计算参数进行封装处理，生成预设数据格式的目标计算参数，根据待处理的目标数据以及目标计算参数生成待计算数据，按照预设计算规则对待计算数据进行计算处理，并将得到的计算结果发送至目标节点，本发明通过在实时计算过程中，支持计算参数的动态更新，且不需要调整任务或重启任务，增加了实时计算过程的灵活性，保证了服务的持续性和稳定性，使得计算依赖的实时数据支持容灾，不丢失，在保证数据正确性的同时，保证了数据的完整性。