Ispričaj o projektu na kojem radiš i usmeri svoje zadatke.

U mom trenutnom projektu radim na sistemu za obradu velikih količina podataka u realnom vremenu u Go jeziku. Glavni zadatak je razvoj mikroservisa koji primaju, obrađuju i agregiraju podatke iz različitih izvora, obezbeđujući visok performans i otpornost.

Moji zadaci uključuju:

• Razvoj API-ja za primanje podataka koristeći gRPC i REST.
• Optimizaciju obrade podataka korišćenjem goroutine-a i kanala za paralelizam.
• Integraciju sa sistemima redova poruka (Kafka) za asinhroni prenos podataka.
• Pisanje jedinicnih i integracionih testova za obezbeđivanje kvaliteta koda.
• Podešavanje nadzora i logovanja za brzo otkrivanje i rešavanje problema.

Primer koda za paralelnu obradu podataka korišćenjem goroutine-a:

func processData(data []int) {
    var wg sync.WaitGroup
    for _, d := range data {
        wg.Add(1)
        go func(val int) {
            defer wg.Done()
            // Obrada podataka
            fmt.Println("Obrada", val)
        }(d)
    }
    wg.Wait()
}