Kā tiek īstenots Saga modelis, lai pārvaldītu izplatītās transakcijas mikroservisu arhitektūrā?

Sagas paraugs tiek ir izmanto, lai pārvaldītu izplatītas transakcijas mikroservisu arhitektūrā, kur tradicionālās ACID transakcijas nav iespējamas datu un pakalpojumu izplatīšanas dēļ.

Ideja ir tāda, ka liela biznesa operācija tiek sadalīta sērijā vietējo transakciju dažādos pakalpojumos. Katru vietējo transakciju pavada kompensācijas operācija, kas atceļ tās efektu jebkurā solī, ja notiek kļūda.

Go realizācija parasti ir būvēta ap orķestratoru vai koreogrāfiju:

• Orķestrators: centralizēts pakalpojums, kas pārvalda soļu secību un izsauc vietējās transakcijas, apstrādā kļūdas un uzsāk kompensācijas transakcijas.
• Koreogrāfija: katrs pakalpojums publicē notikumus par soļa izpildi, citi pakalpojumi uz tiem reaģē, veicot savus soļus vai kompensācijas darbības.

Vienkāršots orķestrācijas piemērs Go:

func RunSaga() error {
    if err := ServiceA.DoStep(); err != nil {
        return err
    }
    if err := ServiceB.DoStep(); err != nil {
        ServiceA.Compensate() // pirmā soļa atcelšana
        return err
    }
    if err := ServiceC.DoStep(); err != nil {
        ServiceB.Compensate()
        ServiceA.Compensate()
        return err
    }
    return nil
}

Reālās sistēmās tiek izmantotas ziņojumu rindas (Kafka, RabbitMQ) notikumu pārsūtīšanai un sagas stāvokļa pārvaldībai, kā arī sagas stāvokļa glabāšana datu bāzē kļūdu izturībai.