А если попробовать так? dataSlice:=make([]models.Data,0,10000) for i:=range dataCh{

Question

А если попробовать так? dataSlice:=make([]models.Data,0,10000) for i:=range dataCh{

dataSlice = append(dataSlice, i)
if len(dataSlice)==cap(dataSlice){
_ = DBElastic.BulkSendPost(dataSlice)
//Вот здесь почистить слайс данных после пуша в эластик

}
}

#backend #go #programming #russian

0

30.12.2020

2 ответов

14 просмотров

Jbcui Автор вопроса

lrrr_lrrr
не кажется ли вам немножко странным код где вы сра...

dataCh это канал в который я складываю данные уже обработанные другой функцией, не связанной с кафкой

0

30.12.2020

lrrr_lrrr · Accepted Answer

не кажется ли вам немножко странным код где вы сравниваете длинну и капасити, при том что выше у вас magic number в коде? почему бы не вынести в переменную конфига/константу/вотэвер число 10000 и не использовать его при сравнениях тоже? получится вроде читаймо const chunkSize = 10000 dataSlice:=make([]models.Data,0,chunkSize) if len(dataSlice)>=chunkSize {...} dataCh это канал? это ваш канал или кафка туда пушит? в любом случае нужна возможность выйти из цикла мне кажется, так что нужно что-то такое for { select { case <- done: // выйти из цикла, что-то идет не так case msg := <-dataCh: // append to buffer } }

170 похожих чатов

А если попробовать так? dataSlice:=make([]models.Data,0,10000) for i:=range dataCh{

2 ответов

Похожие вопросы