Join us Sept 17 at .local NYC! Use code WEB50 to save 50% on tickets. Learn more >
MongoDB Event
Docs Menu
Docs Home
/ /
Atlas Architecture Center
/ / /

MongoDB によるスマート メーター解析の強化

MongoDBは、スマートメーターシステム向けにスケーラブルなプラットフォームを提供し、リアルタイムデータ収集、時系列分析、異常検出を可能にします。

ユースケース: IoTアプリ主導の分析シングル ビュー

業種: 製造・モビリティ、エネルギー・環境

製品およびツール: MongoDB AtlasAtlas ChartsChange Streams時系列コレクションMongoDB Query API

パートナー: Cedalo

2027年までに米国とカナダでスマートメーターの普及率が90%に達すると予想される中、MongoDBはスマートメーターの時系列データを大規模に管理・分析するための包括的なプラットフォームを提供します。このソリューションにより、公益事業会社は MongoDB の時系列コレクションを使用して、高周波メーターの読み取り値を収集し、ストリーミングデータをリアルタイムで処理し、履歴データを効率的に保存することができます。強力な集計パイプラインと変更ストリームにより、高度な異常検出が可能になり、電力会社は電圧スパイク、停電、異常な消費パターンなどの潜在的な問題を迅速に特定できます。

世界的にエネルギー消費量が増加し続ける中、スマートメーターによって生成されるデータ量も増加しています。私たちのソリューションは、MQTT などの IoT メッセージングプロトコルとの MongoDB の統合を活用して、スマートメーターのヘッドエンド ユニットから信頼性の高いデータ取り込みを実現します。また、MongoDB Atlas のネイティブな時系列サポートにより、一時データの効率的な保存とクエリが可能です。公益事業会社は、パフォーマンスとデータのアクセス性を維持しながら、接続されたメーターを数千から数百万にシームレスに拡大できます。データ階層化や Atlas Online Archive のような高度な機能は、履歴データをコスト効率よく管理する上で役立ちます。組み込みの分析機能により、カスタマイズ可能なダッシュボードとレポートを通じて、リアルタイムのモニタリングと運用インサイトを提供します。

このソリューションには 2 つの主要なコンポーネントがあります。

スマート メーターを利用するには、電力会社は、スマート メーター本体、メーター データ コレクション ネットワーク、ヘッドエンド システム(HES)、およびメーター データ管理システム(MDMS)を含む、スマート メーターのコア エコシステムを配置する必要があります。スマート メーターは、最終消費者からデータを収集し、それをローカル エリア ネットワーク(LAN)経由でデータ アグリゲーターに送信します。送信頻度は、15分、30分、または 1 時間単位に調整可能であり、データ需要に応じて柔軟に対応できます。アグリゲーターはデータを取得し、それをヘッドエンド システムに転送します。ヘッドエンド システムはデータを分析し、その結果を MDMS に送信します。初期の通信経路は双方向であり、メーター、顧客拠点、または配電装置に直接信号やコマンドを送信することが可能です。

私たちのソリューションでは、MongoDB は MDMS システムのバックエンド データベースです。データが HES に到達すると、MQTT プロバイダーを介して MongoDB に送信されます。主要な MQTT ブローカー プロバイダー(HiveMQ、EMQX、Cedalo など)は、スマート メーターから収集された情報のシームレスなデータ転送と効率的なマネジメントを可能にする MongoDB の統合を開発しました。

このソリューションでは、効果的なメッセージ送信を容易にするために Cedalo Pro Mosquitto MQTT ブローカーを使用します。MongoDB ブリッジを利用することで、MongoDB とのシームレスな接続が作成され、2 つのシステム間の継続的かつ効率的なデータフローが保証されます。

その後、MongoDB は、メーター ID、タイムスタンプ、測定値(エネルギー、電流、電圧など)などの情報を含むスマートメーター データを保存します。

スマートメーターデータが MongoDB Atlas に保存されると、異常の有無やインサイトの獲得のために分析することができます。このソリューションは、次世代の MDMS を作成するために、3 つの主要な MongoDB 機能である変更ストリーム時系列コレクション、強力な MongoDB Query API を活用します。

MongoDB 変更ストリームは、挿入操作などのデータベース変更をリアルタイムでキャプチャおよびプロセシングし、エネルギー消費パターン、システム異常、潜在的な障害に関する即時のインサイトを提供します。このリアルタイム機能は、MongoDB の集計フレームワークを通じてタイムリーな分析を可能にし、異常を検出し、費用のかかる損害やサービスの中断を防ぐことができるため、スマートメーターシステムにとって非常に重要です。

分析されたデータは、時系列コレクションに保存されます。これらの専用コレクションは、高圧縮を提供し、時系列データのクエリパフォーマンスを向上させ、高速な操作を可能にします。

エンドツーエンドのスマートメーターマネジメントシステムアーキテクチャ

図1。エンドツーエンドのスマートメーターマネジメントシステムアーキテクチャ

このソリューションでは、2 つの個別の時系列データモデルを使用します。最初のモデルは、meter_id をメタフィールドとして使用する生のスマートメーターデータ用に設計されています。

{
"_id": "668cb56d3830323642e562d9" ,
"timestamp": { "$date": "1720497517183" },
"power_factor": 0.89 ,
"power": 220.1 ,
"frequency": 49.85,
"meter_id": 1,
"energy": 0.22,
"current": 1,
"voltage": 219.38
}

第 2 のデータセットには、事前に定義された基準に基づいて、さまざまな測定で検出された異常が含まれています。このソリューション例では、異常値は平均値から 3 つの標準偏差を超える測定値として定義されています。ここでは、meter_id を metaField として使用しています。

{
"_id": "668d4a023819ef77d3fc84d8",
"timestamp": { "$date": "1720535553856" },
"meter_id": 3,
"data": {
"voltage": 190.06,
"current": 18.13,
"power": 3445.67,
"energy": 3.45,
"power_factor": 0.76,
"frequency": 49.92
},
"anomalies": ["voltage", "current"]
}

このスマートメーターのデータ管理ソリューションは、MQTT ブローカーと MongoDB Atlas を活用し、現代のエネルギーインフラストラクチャにおけるデータ収集と分析の複雑な課題に対処するアーキテクチャを示しています。リファレンス実装では Cedalo の MQTT ブローカーが紹介されていますが、このソリューションはブローカーに依存しないように設計されており、さまざまな MQTT プロバイダーとの統合をサポートしています。

1
  • 安定したメッセージ処理のために MQTT ブローカーを設定します。

  • MongoDB とのブローカー統合を構成します。

  • 安全なデータストリーミングパイプラインを確立する。

  • スマートメーターからのリアルタイムデータ収集を有効にします。

  • ブローカーのマネジメントとモニタリングを実装します。

2
  • 以下の環境変数を設定します。

    • MQTT ブローカー接続の詳細。

    • MongoDB接続URI。

    • データベースおよびコレクションの名前。

    • 分析エンジンの構成。

    • Atlas Charts の統合。

3
  • 必要なコレクションを含む MongoDB データベースを作成してください。

  • 次の時系列コレクションを設定します。

    • Anomalies data.

    • メトリクス データ。

    • 変換されたデータ。

  • データ変換パイプラインを構成します。

  • リアルタイムデータプロセシング機能を有効にします。

4
  • アプリケーションコンポーネントを配置します。

  • リアルタイムモニタリング機能を実装します。

  • 異常検知アルゴリズムを設定します。

  • カスタマイズされたダッシュボードを作成してください。

  • インタラクティブなデータ探索を有効にします。

完全かつ手動の実装については、 詳細なリポジトリを確認してください。

  • データ管理は極めて重要:スマートメーターは膨大な量の時系列データを生成するため、データの相互運用性、プライバシー、効率的な処理において大きな課題が生じます。効果的なソリューションには、高頻度で複雑なデータストリームを処理できる柔軟でスケーラブルなデータベースが必要です。

  • MQTT が効率的な IoT 通信を可能に:軽量なパブリッシュ・サブスクライブプロトコルは、スマートメーターエコシステムにおいて、IoT デバイス、アグリゲーター、管理システム間で効率的かつ安全で信頼性の高いデータ伝送を提供するために不可欠です。

  • MongoDB は包括的な IoT データ ソリューションを提供: 時系列コレクション、変更ストリーム、集計フレームワーク、柔軟なドキュメント モデルなどの機能により、MongoDB は異常検知、リアルタイム分析、スケーラブルなデータストレージなど、スマート メーター データ管理における主要な課題に対処します。

  • 統合的なアプローチが鍵:スマートメーターの実装を成功させるには、堅牢なメッセージングプロトコル(MQTT など)、高度なデータベース技術、包括的な分析機能を組み合わせて、未加工のメーターデータを公益事業会社にとって実用的なインサイトに変換する包括的なソリューションが必要です。

  • Cedalo MQTTプラットフォーム

  • Dr. Humza Akhtar, MongoDB

  • Rami Pinto、MongoDB

  • Sebastian Rojas Arbulu, MongoDB

  • Diego Canales, MongoDB

戻る

IoT データ ハブの構築

項目一覧