Regroupement/identification des journaux d'acteurs pour la même "demande"

Question

Je suis à la recherche d'un moyen ou d'une meilleure/meilleure décision de conception pour un problème d'enregistrement. J'utilise des acteurs Akka dans les clusters pour mes services dorsaux et Play dans le frontal pour accepter les requêtes HTTP. Ma question est en quelque sorte étendue de l'ancienne question de l'ensemble du journal de l'application pour être identifiable aux mêmes requêtes HTTP, qui utilisent simplement le MDC qui existe dans la plupart des frameworks de journalisation actuels en générant un UUID au début et mettre dans le contexte .

Un exemple de notre flux de données pourrait ressembler à:

"Http Demande/Système A" -> "actionneur1/Cluster B" -> "Actor2/Groupe C" -> « Répondre au système A et complet demande "

Cela signifie qu'il y a au moins 3 systèmes distincts impliqués dans le processus. Tout mon journal va à Logstash. Je peux générer un UUID depuis le début de la requête depuis le Système A. Cependant, je souhaite que l'UUID puisse être reporté sur tous les sous-systèmes, qui utilisent tous la sérialisation Protobuf pour communiquer entre eux, traiter les tâches d'appartenir à la même demande http.

Je sais que je peux toujours ajouter un champ id à tous mes messages, mais c'est très moche.

Je me demande s'il existe un meilleur moyen ou un meilleur mécanisme pour transmettre l'information à tous les autres systèmes Akka d'appel sans introduire trop de bruit dans mon traitement de la logique métier?

Answer 1

Vous pouvez envelopper vos messages originaux dans un récipient avec UUID:

case class MessageWithUuid(message: Any, uuid: UUID) 

Ensuite, dans votre receive vous devez déballer et de préserver uuid pour l'enregistrement:

var uuid: Option[UUID] = 
def receive: Receive = { 
    case MessageWithUuid(message, uuid) => 
    this.uuid = Some(uuid) 
    //TODO: put UUID to MDC logging context 
    receive(message) 
    //TODO: remove UUID from MDC 
    this.uuid = None 
    case ... => 
} 

Et chaque fois que vous envoyez un message à un autre acteur, vous devez envelopper avec UUID:

def send(actor: ActorRef, message: Any) = actor ! MessageWithUuid(message, uuid.get)