|
@@ -166,7 +166,7 @@ func (e *Elastic) BulkSave(index string, obj *[]map[string]interface{}, isDelBef
|
|
|
if isDelBefore {
|
|
if isDelBefore {
|
|
|
req = req.Add(es.NewBulkDeleteRequest().Index(index).Id(fmt.Sprintf("%v", v["_id"])))
|
|
req = req.Add(es.NewBulkDeleteRequest().Index(index).Id(fmt.Sprintf("%v", v["_id"])))
|
|
|
}
|
|
}
|
|
|
- req = req.Add(es.NewBulkIndexRequest().Index(index).Id(fmt.Sprintf("%v", v["_id"])).Doc(v))
|
|
|
|
|
|
|
+ req = req.Add(es.NewBulkIndexRequest().Index(index).Doc(v))
|
|
|
}
|
|
}
|
|
|
_, err := req.Do(context.Background())
|
|
_, err := req.Do(context.Background())
|
|
|
if err != nil {
|
|
if err != nil {
|
