我有如下3个步骤的事务:
(1)Insert User basic info(id,name).
(2)Search the User Id.
(3)If found the user,then update the record with user behavior info.
因此,我使用elasticSearch.index()API插入用户id和名称,然后elasticSearch.search()API查询它,如果找到,我将通过elasticSearch.update()API更新记录。但是ES延迟导致search()API没有得到任何结果,即使数据已经被索引。所以,有什么关于解决这个问题的想法吗?谢谢!
默认情况下,索引每秒刷新一次,但您可以使用Refresh API强制刷新并确保新索引的数据可用。
curl -XPOST 'http://localhost:9200/users/_refresh'
请注意,出于测试目的调用它是可以的,但您不应该在生产集群上这样做,因为这可能会导致性能问题。