一种基于NiFi的多模型数据处理方法、装置、设备及介质

本申请公开了一种基于NiFi的多模型数据处理方法、装置、设备及介质，涉及数据处理技术领域，包括：通过NiFi的预设控制服务配置原生多模型数据库的连接配置信息，基于连接配置信息建立NiFi与原生多模型数据库之间的连接关系；基于连接关系、预先在NiFi中配置的数据集合的集合名称和原生多模型数据库的查询语言从原生多模型数据库中读取目标数据，利用预先在NiFi中配置的增量信息对目标数据进行增量抽取；基于预设数据写入方式将得到的抽取后数据写入对应的预设数据库，在写入过程中基于开启的事务机制判断写入操作是否成功，若不成功，则触发事务回滚机制，直至写入操作成功。以降低数据管理的复杂性和成本。