{ “focus”: “YANG-Push and Message Broker Integration (RFC 8641 / draft-ietf-netconf-yang-notifications-publisher)”, “status”: “Draft / Implementation Phase”, “technical_keywords”: [“YANG-Push”, “Message Broker”, “Pub/Sub”, “Notification-Message”, “Telemetry”], “author”: “Senior Network Engineer (Protocol Implementation Spec)” }
本記事はGeminiの出力をプロンプト工学で整理した業務ドラフト（未検証）です。
RFC 8641 (YANG-Push) と draft-ietf-netconf-yang-notifications-publisher: メッセージブローカー統合による次世代テレメトリ標準
【背景と設計目標】
従来のポーリング型管理から脱却し、パブリッシュ/サブスクライブ型でリアルタイムな網状態の可視化と高い拡張性を実現する。 （SNMP/NETCONF等の1対1通信から、メッセージブローカーを介した1対多の配信モデルへの転換を目的とする。）
【通信シーケンスと動作】
メッセージブローカー（Kafka/MQTT等）を介したYANG-Pushの動的サブスクリプションとデータ配信の標準的なシーケンスを以下に示します。
sequenceDiagram
participant "Collector as Telemetry Collector"
participant "Broker as Message Broker (Kafka/MQTT)"
participant "Device as Network Device (Publisher)"
Note over Device, Collector: 1. トランスポート確立 (TLS)
Device ->> Broker: Connect / Session Establish
Collector ->> Broker: Subscribe to Topic (e.g., /telemetry/interfaces)
Note over Device, Collector: 2. サブスクリプション設定 (Config-push or Dynamic)
Collector ->> Device: (via NETCONF/RESTCONF)
Device -->> Collector: (Success/ID)
Note over Device, Collector: 3. テレメトリ配信
loop Periodic or On-change
Device ->> Broker: Publish (Encapsulated YANG Notification)
Broker ->> Collector: Forward Message
end
デバイスは直接コレクタへデータを送るのではなく、標準化されたメッセージフォーマットを用いてブローカーへパブリッシュします。これにより、コレクタ側のスケールアウトや、複数の分析基盤への同時配信が容易になります。
【データ構造 / パケットフォーマット】
draft-ietf-netconf-notification-messages に基づく、メッセージブローカー上で流通する共通通知カプセル化フォーマット（概念図）です。
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 | Flags | Message Type | (Header) +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ | Message Length | +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ | Message ID (Sequence) | +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ | Observation Time | | (PTP or NTP Timestamp) | +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ | Payload Format| Sub-ID Length | Subscription ID (Var) | +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ | | | Payload (JSON / CBOR / Protobuf Encoded) | | (Actual YANG Datastore Fragment) | | | +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
【技術的な特徴と比較】
従来のSNMPやgNMIと、YANG-Push（メッセージブローカー統合）の比較を以下にまとめます。
| 機能特性 | SNMP (Trap/Informs) | gNMI (Subscribe) | YANG-Push (w/ Broker) |
|---|---|---|---|
| データモデル | SMIv2 (MIB) | YANG | YANG |
| 転送プロトコル | UDP | HTTP/2 (gRPC) | MQTT / Kafka / HTTPS / UDP |
| 多重化 / スケール | 低（受信側ボトルネック） | 中（1:1 セッション） | 高（ブローカーによる負荷分散） |
| データ構造 | BER (Binary) | Protobuf | JSON / CBOR / Protobuf |
| 状態変化通知 | 限定的（Trapのみ） | 対応 (ON_CHANGE) | 対応 (ON_CHANGE / Periodic) |
| HOL Blocking | なし (UDP) | あり (TCP/HTTP2単位) | 緩和 (ブローカー経由の非同期処理) |
多重化 (Multiplexing): メッセージブローカーを介在させることで、デバイスは単一のストリームを維持したまま、背後の多数のコンシューマ（コレクタ）へデータを届けることが可能です。
ON_CHANGE: 特定のYANGリーフ（例：インターフェースのUP/DOWN）が変化した瞬間のみ通知を送出するため、トラフィックを劇的に削減できます。
【セキュリティ考慮事項】
エンドツーエンドの機密性: メッセージブローカーが中間者となるため、デバイス〜ブローカー間およびブローカー〜コレクタ間の両方でTLS 1.3等の暗号化が必須となります。
認可制御 (NACM): RFC 8341 (Network Configuration Access Control Model) に基づき、サブスクリプションを要求するエンティティが対象のYANGノードを閲覧する権限を持っているか厳格に検証されます。
メッセージの真正性: ブローカーの侵害に備え、ペイロード自体にデジタル署名（RFC 9168等に関連する仕組み）を付与し、コレクタ側で送信元の正当性を検証する実装が推奨されます。
【まとめと実装への影響】
ネットワークエンジニアおよび開発者が考慮すべき点は以下の3点です。
トランスポートの抽象化: gNMI一辺倒ではなく、Kafka/MQTTを前提とした設計にシフトしています。デバイス側には軽量なMQTTクライアント、上位系にはスケーラブルなKafkaクラスタを配置する階層構造の理解が不可欠です。
シリアライゼーションの選択: 帯域効率を重視するならCBORやProtobuf、デバッグ効率を重視するならJSONを選択します。特にドラフトで議論されている
draft-ietf-netconf-notification-messagesの共通ヘッダー実装が、マルチベンダー環境の統合鍵となります。サブスクリプション管理の自動化: 静的な設定（Configured Subscription）だけでなく、コレクタから動的に条件を書き換える（Dynamic Subscription）実装の作り込みが、適応型ネットワーク運用の成否を分けます。
コメント