信号から洞察まで：ファブリックイベントを使用してリアルタイムストリーミングデータプラットフォームの構築| Microsoft Fabricブログ

ContosoがMQTTセンサー、パブリックウェザーフィード、生地のリアルタイムインテリジェンスを使用して、スマートビルディングを監視する方法。

共同執筆 アリシア・リー そして Arindam Chatterjee

なぜリアルタイムストリーム処理が重要なのか

AIの時代に、 組織が受け入れるように インテリジェントなシステムとデータ駆動型の意思決定、 能力 到着した瞬間にデータに作用する の新しいレベルのロックを解除しています 敏ility性と洞察。 異常の検出と運用の最適化から、詐欺の予防やパーソナライズされた経験まで、リアルタイムの洞察は次のイノベーションの波を動かしています。将来を見据えたビジネスの場合、リアルタイムのストリーム処理は基礎的な能力となっています。

この投稿では、Smart BuildingオペレーターのContosoがMicrosoft Fabricのリアルタイムインテリジェンスを使用して、部屋センサー、気象飼料、アラートシステムを接続するストリーミングデータプラットフォームを構築する方法を探ります。

アーキテクチャの概要

各コントーソ操作の建物には、温度と占有データをMQTTブローカーにストリーミングするルームセンサーが装備されています。このデータを豊かにするために、Contosoは公共の気象飼料も摂取し、屋内と屋外の状態の相関を可能にします。これらのリアルタイム信号は、よりスマートなエネルギーの使用を促進し、居住者の快適性を改善し、環境の変化に対するタイムリーな反応を可能にします。

図1に示すように、これらのリアルタイム信号は、Microsoft Fabricのリアルタイムインテリジェンススタックを介して流れます – 摂取から変換、アラート、視覚化まで。アーキテクチャには次のものが含まれます。

• MQTTと気象データを摂取するためのEventStream。
• データを形成するためのノーコードおよびSQLオペレーター。
• トリガーアラートのデータアクティベーター。
• タイムシリーズデータを保存および分析するためのイベントハウス。
• 最新のトレンド、異常などを監視するためのリアルタイムダッシュボード。

次のセクションでは、アーキテクチャの各段階の実装を進めます。

もっと学ぶのが待ちきれませんか？完全なウォークスルーをご覧ください デモビデオ。

ステップ1：イベントストリームでデータを摂取します

Contosoのリアルタイムの旅は、データから始まります。各建物は、ルームセンサーからMQTTブローカーへの温度と占有の測定値をストリーミングします。より賢い決定を下すために、Contosoはこれらの信号をAzureマップのリアルタイムの気象データで豊かにし、屋内条件と屋外環境と相関させることができます。この組み合わせは、HVACの使用を最適化し、異常な測定値を検出し、快適性の問題を予測し、積極的に対応するのに役立ちます。

Microsoft Fabricのリアルタイムハブはこれを簡単にします。 MQTTおよびAzureマップの天気用の組み込みコネクタを使用すると、Contosoはわずか数回クリックして多様なデータストリームを摂取できます。

ステップ2：ノーコードおよびSQLオペレーターを使用してストリーミングデータを処理および変換する

データがファブリックイベントストリームに流れ始めたら、次のステップはそれを使用可能な形式に形作ることです。生のセンサーと気象データは、アラートやダッシュボードの準備が整う前に、フィルタリング、名前変更、または濃縮が必要になることがよくあります。 Contosoの場合、これは、彼らが気にするフィールドのみを抽出し、データを再形成して、華氏などではなく摂氏で報告された温度などの一般的なデータモデルに準拠することを意味します。

ファブリックは、組み込みの変換ツールでこれを簡単にします。迅速なフィルタリングとシェーピングにノーコードオペレーターを使用するか、より高度なロジックのためにSQLに切り替えることができます。すべて同じイベントキャンバス内です。

カバーした手順を使用して、Contosoは図2に示すように、複雑なストリーミングデータパイプラインをすばやく構築およびテストできます。

ステップ3：ストリーミングデータに基づいて行動 – アラートとリアルタイムダッシュボード

センサーと気象データが摂取、処理、変換されると、次のステップはそれに基づいて行動することです。場合によっては、条件がしきい値を超えた場合にリアルタイムアラートをトリガーすることを意味します。これは、室温が100°Fを超えて上昇したり、50人を横切る占有率を超えています。その他では、建物全体の傾向を視覚化して、運用上の決定をサポートすることを意味します。自動化された応答であろうと、人間のループモニタリングであろうと、ストリーミングデータの価値は、アクションを迅速かつ明確に駆動することから生じます。

ファブリックリアルタイムインテリジェンスは、両方のアクションモードをサポートしています。データアクティベーターを使用したイベント駆動型の自動化と、イベントハウスのリアルタイムダッシュボードを使用したリアルタイムの観測可能性をサポートします。データアクティベーターを使用すると、Contosoは、ストリーミングデータで直接アラート条件を定義し、コードを作成せずに通知またはワークフローをトリガーできます。イベントハウスとリアルタイムのダッシュボードを使用すると、建物全体の現在の条件をリアルタイムで反映するライブダッシュボードを構築できます。

結論

Contoso’s Journeyは、ファブリックのリアルタイムインテリジェンスが、複雑なコードを作成したり、複数のツールをつなぎ合わせることなく、生のシグナルを実行可能な洞察に変えることができる方法を示しています。 MQTTや気象データの摂取から、アラートのトリガーやライブダッシュボードの動力まで、Fabricは、インテリジェントなイベント駆動型アプリケーションを構築するための統一された低屈折パスを提供します。

このアプローチは、スマートビルディングに限定されません。摂取、変革、ACTデザインパターンは、さまざまな業界で適用されます。

• 製造：機器の健康を監視し、メンテナンスアラートをトリガーします。
• 小売り：歩行者を追跡し、スタッフをリアルタイムで最適化します。
• ロジスティクス：GPSと気象データを組み合わせて配信を再ルーティングします。
• ファイナンス：トランザクションがストリーミングとして詐欺パターンを検出します。

工場のフロア、ロジスティクスネットワーク、またはデジタルストアフロントを管理する場合でも、フォーミュラは同じです。 ストリーミングします。それを形作ります。それに基づいて行動します。

今それはあなたの番です – あなたのときに何が可能かを探ります ストリーミングデータ あなたの副操縦士になります。

詳細な構成ガイダンスについては、次のリンクを参照してください。

フィードバックが大好きです！

メールでお気軽にご連絡ください[email protected]。フィードバックまたは機能リクエストを提出することもできます生地のアイデア、そして、仲間のユーザーとの会話に参加してくださいファブリックコミュニティ

まだ行っていない場合は、チェックしてください ビデオ 行動の完全な体験のためのウォークスルー。