wishpal_ironfan
/
service
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

by Robin at 20240524

This commit is contained in:
Leufolium 2024-05-24 23:27:51 +08:00
parent e141dc412c
commit 39d95f6ba8
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app/mix/dao/elasticsearch.go
View File

@ -53,9 +53,7 @@ func (es *ElasticSearch) CreateStreamerAcct(ctx *gin.Context, streameraccts []*d
for _, streameracct := range streameraccts {
bulk.Add(elastic.NewBulkCreateRequest().Id(fmt.Sprint(streameracct.Mid)).Doc(streameracct))
}
logger.Info("bulk: %v", bulk)
rsp, err := bulk.Do(ctx)
logger.Info("rsp: %v", rsp)
_, err := bulk.Do(ctx)
return err
}