Mesélj a projektről, amin dolgozol, és irányítsd a feladataidat.

Jelenlegi projektemben valós idejű nagy adatmennyiség feldolgozó rendszeren dolgozom Go nyelven. A fő feladatom mikroservice-ek fejlesztése, amelyek különböző forrásokból fogadnak, feldolgoznak és összegyűjtenek adatokat, magas teljesítményt és hibatűrést biztosítva.

Feladataim közé tartozik:

• API fejlesztése adatfogadásra gRPC és REST használatával.
• Az adatok feldolgozásának optimalizálása goroutine-ok és csatornák segítségével a párhuzamosság érdekében.
• Integráció üzenetsor rendszerekkel (Kafka) az aszinkron adatátvitelhez.
• Egység- és integrációs tesztek írása a kód minőségének biztosítása érdekében.
• Monitoring és naplózás beállítása a problémák gyors felismerése és megoldása érdekében.

Példa kód a goroutine-ok segítségével történő párhuzamos adatfeldolgozásra:

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