异步插入到cassandra,每个键的插入保存顺序

ffx8fchx  于 2021-08-25  发布在  Java
关注(0)|答案(0)|浏览(137)

我有一组有序的传入事件,需要将它们插入cassandra。我想利用异步插入的速度,但传入的事件可能在目标表的键上有重复项。
如果我理解正确,那么在这种情况下,异步插入不能保证数据的一致性,因为异步执行意味着异步操作的程序顺序,这意味着不能保证异步操作的顺序,但我无法用java实现一个示例,异步插入的顺序与顺序不匹配。在任何与cassandra驱动程序(datastax java驱动程序)异步插入相关的文档中,我也找不到这方面的信息。
在这种情况下,我是否必须在异步插入之前完成重复数据消除,以确保数据一致性?
如果您需要我所做工作的示例代码:

@Autowired
private ReactiveCassandraRepository repository;

...

Flux.from(eventsList)
.flatMap(value -> repository.save(value))
.subscribe()

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题