同じ「要求」のアクターログをグループ化/識別する

Question

私は、ロギングの問題のために、最良の、またはより良い設計上の決定を探しています。 私はバックエンドサービスのためにクラスタでAkkaアクターを使用しており、HTTPリクエストを受け入れるにはフロントエンドでPlayしています。 私の質問は、最初のUUIDを生成してコンテキストに入れることによって、アプリケーションログ全体を同じHTTPリクエストに識別させるという古い質問から拡張されました。

我々のデータの流れの一例は次のようになります。

"HTTPリクエスト/システムA" - > "Actor1 /クラスタB" - > "ACTOR2 /クラスタC" - >「システムAと完全に返信します要求」

これは、プロセスに少なくとも3つの別々のシステムが含まれていることを意味します。 私のすべてのログはLogstashに送られます。 システムAからの要求の開始からUUIDを生成することができます。 しかし、すべてのサブシステムにUUIDを/ piggy-backedで渡すことができます。これらはすべて、Protobufシリアル化を使用して通信し、ジョブを処理します同じhttp要求に属しています。

私はすべてのメッセージにidフィールドを追加することができますが、これは非常に醜いです。

ビジネスロジックの処理にあまりノイズをかけることなく、他のすべての呼び出し元のAkkaシステムに情報を伝達するためのよりよい方法があるかどうかは疑問です。

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

その後、中にあなたのreceiveあなたがそれをアンラップし、ロギング用uuid維持する必要があります：

Answer 1

あなたはUUIDを容器にあなたの元のメッセージをラップすることができます

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 ... => 
} 

をそして、あなたが送ったときにメッセージを別のアクタに送信するには、UUIDでラップする必要があります。

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