Pověz mi o projektu, na kterém pracuješ, a orientuj se ve svých úkolech.

V mém současném projektu pracuji na systému zpracování velkých objemů dat v reálném čase v jazyce Go. Hlavním úkolem je vývoj mikroservis, které přijímají, zpracovávají a agregují data z různých zdrojů, zajišťující vysoký výkon a odolnost vůči chybám.

Mé úkoly zahrnují:

• Vývoj API pro příjem dat pomocí gRPC a REST.
• Optimalizaci zpracování dat pomocí gorutin a kanálů pro paralelismus.
• Integraci s systémy front zpráv (Kafka) pro asynchronní přenos dat.
• Psání jednotkových a integračních testů pro zajištění kvality kódu.
• Nastavení monitorování a logování pro rychlé odhalení a řešení problémů.

Příklad kódu pro paralelní zpracování dat pomocí gorutin:

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