Golang

8247

Какво кеширахте? Някакви директории?

/* Ние трябва да прехвърлим данни от източник към потребител. Източникът предоставя данните на малки пакети (~десет записа), докато потребителят работи по-ефективно с по-големи пакети. Реален пример е прехвърлянето на данни от Kafka тип опашки към базата данни Clickhouse. Източник: - Почти безкраен. - Източникът никога не връща повече от MaxItems записи в едно извикване на Next. - В рамките на една "сесия" (едно извикване на функцията Pipe), източникът връща нови данни при всяко Next. - След рестарт, източникът ще започне от предишната "потвърдена" позиция, указана с cookie. Затова, всяка стойност на cookie, която Next връща, след като данните са запазени в приемника, трябва да бъде потвърдена с извикване на Commit, в същия ред, в който са били върнати от Next. Приемник: - Не може да обработи повече от MaxItems наведнъж. Основно ниво: Трябва да се реализира функцията func Pipe(p Producer, c Consumer) error, която чете данни от източника, ги групира в буфер с размер не повече от MaxItems и ги запазва в приемника, след което потвърждава напредъка в източника. */ const MaxItems = 9999 type Producer interface { // Next връща: // - пакет от елементи за обработка // - cookie за потвърждение след приключване на обработката // - грешка Next() (items []any, cookie int, err error) // Commit се използва за маркиране на данните като обработени Commit(cookie int) error } type Consumer interface { Process(items []any) error } func Pipe(p Producer, c Consumer) error { var buf []any var cookies []int for { items, cookie, err := p.Next() if err != nil { return err } buf = append(buf, items...) cookies = append(cookies, cookie) if len(buf) >= MaxItems { if err := c.Process(buf); err != nil { return err } for _, c := range cookies { if err := p.Commit(c); err != nil { return err } } buf = buf[:0] cookies = nil } } if len(buf) > 0 { if err := c.Process(buf); err != nil { return err } for _, c := range cookies { if err := p.Commit(c); err != nil { return err } } } return nil }

Middle

Яндекс

166

Можете ли да изброите компаниите или доставчиците, с които сте имали контакт?

Junior — Middle

166

Разкажи за последното си работно място: с какво се занимаваше, какъв стек използваше, какви бяха трудните задачи?

Middle