首先,我使用的方式是高級客戶端(restHighLevelClient)孝治,也就是java api的方式做了批量同步,現在貼上我的代碼:
以為貼代碼不好控制格式栅螟,所以就直接貼圖了荆秦。代碼思路是:
1.先去數據庫查詢出所有需要同步的數據
2.然后轉換成map的格式,因為elasticsearch的批量同步方法貌似只接受map格式的參數
3.然后通過request的add方法力图,把所有的參數遍歷添加到request中
4.最后在add完了之后步绸,我做了一個分批,一千條去同步一次
現在有一個疑問吃媒,一千條同步完了之后瓤介,我這里的request要怎么處理呢,直接給null的話赘那,下一次add就會報錯刑桑,request也沒有clean的方法,怎么才能解決這個問題呢募舟?