@@ -169,6 +169,7 @@ func (e *Elastic) BulkSave(index string, obj []map[string]interface{}) {
//}
id := util.ObjToString(v["_id"])
delete(v, "_id")
+ util.Debug(id, v)
req = req.Add(es.NewBulkIndexRequest().Index(index).Id(id).Doc(v))
}
_, err := req.Do(context.Background())
