draft-ietf-netconf-distributed-notif: Distributed YANG Pushにおけるメッセージブローカー統合規格

Tech

本記事はGeminiの出力をプロンプト工学で整理した業務ドラフト（未検証）です。

draft-ietf-netconf-distributed-notif: Distributed YANG Pushにおけるメッセージブローカー統合規格

【背景と設計目標】

大規模ネットワークでNETCONFセッションへの負荷を抑え、メッセージブローカー経由で高スケールなテレメトリ収集を実現する。（60文字）

既存の「RFC 8639 (Subscription to YANG Notifications)」および「RFC 8640 (Dynamic Subscription to YANG Push)」は、ルータ（Publisher）とコレクタ（Receiver）間のポイントツーポイント接続を前提としていました。本ドラフト（draft-ietf-netconf-distributed-notif）は、ルータ内部の分散プロセスやKafka/AMQPといった外部メッセージブローカーと直接連携可能にする上位互換の補完拡張規格です。

【通信シーケンスと動作】

制御プレーン（NETCONF/RESTCONFによる購読設定）とデータプレーン（テレメトリ通知ストリーム）を物理的・論理的に分離し、中間メッセージブローカーを介して非同期配信を行います。

sequenceDiagram
    autonumber
    participant "Controller as NETCONF Controller"
    participant "Router as Router (Control Process)"
    participant "LineCard as Line Card (Data Publisher)"
    participant "Broker as Message Broker (Kafka/AMQP)"
    participant "Collector as Telemetry Receiver"

    Controller ->> Router: establish-subscription (Target: Distributed)
    Router ->> LineCard: Configure Internal Stream
    Router -->> Controller: Subscription OK (ID: 402)

    LineCard ->> Broker: Connect & Authenticate (TLS)
    Broker -->> LineCard: Connected

    loop Stream Telemetry Data
        LineCard ->> Broker: Publish (Distributed Notification)
        Broker ->> Collector: Forward Message (Topic: net-telemetry)
    end

  1. コントローラはコントロールプロセスへNETCONF経由で購読要求（establish-subscription）を発行します。

  2. コントロールプロセスはラインカードや分散型パブリッシャにストリーム生成を指示します。

  3. データプレーン（ラインカード等）はコントロールプロセスを経由せず、直接メッセージブローカーへ暗号化セッションを貼ります。

  4. ブローカーは受信した通知をトピック（例: net-telemetry）に基づいて多重化・フィルタリングし、最終的なレシーバへ配信します。

【データ構造 / パケットフォーマット】

分散通知メッセージ（Distributed Notification Message）は、トランスポート非依存（UDP/Kafka/HTTP2等）で転送できるように、軽量な共通ヘッダ構造を持ちます（CBOR/JSON/GPB等にマッピング可能）。

 0                   1                   2                   3
 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Version (4b)  | Msg Type (4b) |          Reserved (8b)        |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|                        Subscription ID (32b)                  |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|                                                               |
+                     Observation Timestamp (64b)               +
|                                                               |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|                     Publisher Identifier (32b)                |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|                     Message Sequence Number (32b)             |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
/                                                               /
/                   YANG Push Payload (Variable)                /
/                                                               /
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+

  • Version (4 bits): プロトコルバージョン（例: 0x1）。

  • Msg Type (4 bits): メッセージ種別（0x1: Telemetry Data, 0x2: Heartbeat/Status）。

  • Subscription ID (32 bits): 制御プレーンで確立されたサブスクリプションのユニーク識別子。

  • Observation Timestamp (64 bits): データが計測された絶対時間（POSIX time (ms)）。

  • Publisher Identifier (32 bits): マルチラインカード構成における各パブリッシャ（例: LineCard Slot ID）を特定する識別子。

  • Message Sequence Number (32 bits): パケット欠落検出用の単調増加シーケンス番号。

【技術的な特徴と比較】

既存標準との機能比較

項目 RFC 8639 / RFC 8640 (Point-to-Point) draft-ietf-netconf-distributed-notif
トランスポート構成 端末間直接（NETCONF/RESTCONF） 分散型（Broker / Multi-transport）
ルータCPU負荷 高（コントロールプロセスが集約） 極めて低（ラインカードから直接送出）
スケーラビリティ 数十〜数千メトリクス/秒 数百万メトリクス/秒（Kafka連携時）
エンコーディング XML / JSON CBOR / Protobuf / JSON
障害の影響範囲 セッション切断でストリーム全停止 ブローカーバッファにより一時障害を吸収

主要な技術的キーワード解説

  • HOL Blocking (ヘッドオブラインブロッキング) の排除 従来のTCP/NETCONFベースのYANG Pushでは、特定の大きな通知データが詰まると後続のリアルタイム通知が遅延する問題がありました。本規格ではトランスポートにUDP（RFC 9289）やKafka等のマルチトピックモデルを適用可能な設計にすることで、HOL Blockingを完全回避します。

  • 0-RTT ストリーミングとデータ多重化 制御プレーンで購読が一度完了すれば、データプレーンはコネクション確立のオーバーヘッドを抑えて0-RTTでストリーミングを開始します。メッセージブローカー側でトピック単位の多重化（Multiplexing）を行うため、ルータ側での複雑なファンアウト処理が不要になります。

  • Path MTU とパケット分断処理 ラインカードからの直接送信時にPMTUを超える場合、トランスポート層（UDP/IP）でのフラグメンテーションを避けるため、CBORメッセージ境界でのアプリケーションレベル分断メカニズムをサポートします。

【セキュリティ考慮事項】

  1. エンドツーエンドのペイロード保護（End-to-End Payload Security） 中間層にメッセージブローカーが入るため、ルータとブローカー間のTLS保護（Hop-by-Hop）だけでは、ブローカー悪用時のデータ改ざんを防げません。本ドラフトではペイロード自体にデジタル署名（COSE/JOSE規格）を付与するエンドツーエンド保護が推奨されます。

  2. リプレイ攻撃（Replay Attack）耐性 高精度な Observation Timestamp（64-bit）と Message Sequence Number をヘッダに含むため、収集側で古いパケットの再注入や順序逆転を検知・排除できます。

  3. アクセス制御（NACM）の分散化問題 NETCONF Access Control Model (RFC 8341) はコントロールプロセスで適用されます。本ドラフトでは、ラインカードがデータを出力する段階であらかじめ認可されたデータノードのみをフィルタリングして送出する「事前計算型NACM」の適用が求められます。

【まとめと実装への影響】

  1. コントロールプレーンとデータプレーンの分離 ネットワークエンジニアは、設定変更（NETCONF）とデータ収集（Kafka/UDP）で利用するネットワークパスおよびキャパシティ設計を明確に分ける必要があります。

  2. エンコーディング設計の最適化 大規模環境ではXML/JSONではなく、CBORやProtobufを用いたバイナリエンコーディングが事実上の標準となるため、コレクタ側のデコードパイプラインの刷新が必要です。

  3. メッセージブローカー運用の内包 ネットワーク運用チームは、ルータやスイッチの知識だけでなく、KafkaやAMQPなどのブローカーインフラの可用性・セキュリティ・トピック設計に関するスキルを習得することが不可欠となります。

ライセンス：本記事のテキスト/コードは特記なき限り CC BY 4.0 です。引用の際は出典URL（本ページ）を明記してください。
利用ポリシー もご参照ください。

コメント

タイトルとURLをコピーしました