EMQX

日本語

简体中文
English

日本語

简体中文
English

Appearance

お問い合わせ

ルールエンジン ​

EMQXは、データ処理のためのルールエンジン機能を提供しており、データ統合と連携してIoTデータの抽出、フィルタリング、強化、変換、保存を行います。これにより、アプリケーション統合が加速し、ビジネスのイノベーションを促進します。

data-integration-arch

EMQXのルールエンジンは、特に受信したメッセージの変換やルーティングに有効です。例えば、不要なデータをフィルタリングしたり、変換を行ったり、特定のイベントや条件に基づいてアラートや通知をトリガーするルールを作成できます。

本章では、ルールエンジンの詳細な機能とその使い方について解説します。

ルールエンジンの仕組み ​

ルールは、データソースからデータを取得し、データ変換を行い、その結果に対して適用すべきアクションを指定します。

sql_process

  • データソース：ルールのデータソースは、メッセージ、イベント、または外部データシステムが対象となります。ルールのSQLのFROM句でデータソースを指定し、WHERE句で処理対象となるメッセージに対する追加の制約を設定します。

    対応するデータソースの種類やWHERE句で参照可能なフィールドの詳細については、データソースとフィールドをご参照ください。

  • データ変換：データ変換は入力メッセージを変換する処理を指します。SQLのSELECT部分で入力メッセージからデータを抽出・変換します。埋め込みSQLのサンプル文を用いて、出力メッセージにタイムスタンプを付加するなどの高度な変換も実装可能です。

    SQL文法や組み込みSQL関数の詳細は、ルールSQLリファレンスおよび組み込みSQL関数をご覧ください。

  • アクション：入力がルールに従って処理された後、SQLの実行結果に対して1つ以上のアクションを定義できます。ルールエンジンは順次対応するアクションを実行し、処理結果をデータベースに保存したり、別のMQTTトピックにパブリッシュしたりします。サポートされるアクションは以下の通りです。

EMQXダッシュボードでルールを作成する手順については、ルールの作成をご参照ください。

ルールSQLの例 ​

ルールSQLは、ルールのデータソースを指定し、データ処理の手順を定義するために使用します。以下はSQL文の例です。

sql
SELECT
    payload.data as d
FROM
    "t/#"
WHERE
    clientid = 'foo'

上記のSQL文では、

  • データソース：トピックt/#のメッセージ
  • データ処理：メッセージ送信者のクライアントIDがfooの場合、メッセージ内容のdataフィールドを抽出し、新しい変数dに割り当てる

TIP

.構文はデータがJSONまたはMap形式である必要があります。別のデータ型の場合は、SQL関数を用いて型変換を行う必要があります。

ルールSQL文の形式や使い方の詳細は、SQLマニュアルをご参照ください。

ルールの典型的な適用シナリオ ​

  • アクション監視：スマートホームのインテリジェントロック開発において、ネットワーク障害や電源切れ、破壊行為によりロックがオフラインになると機能異常が発生します。ルールでオフラインイベントを監視し、この障害情報をアプリケーションサービスにプッシュすることで、アクセス層での即時障害検知が可能になります。
  • データフィルタリング：コネクテッドビークルのトラック車両管理では、車両センサーが大量の運行データを収集・報告します。アプリケーションプラットフォームは車速が40km/hを超えた場合のみデータを必要とします。この場合、ルールで条件付きフィルタリングを行い、関連するデータのみを業務用メッセージキューに書き込みます。
  • メッセージルーティング：スマート課金アプリケーションでは、端末デバイスが異なるトピックで業務種別を区別します。ルールを設定することで、課金関連メッセージを課金メッセージキューに振り分け、端末到着時に業務システムへ確認通知を送信します。課金以外の情報は別のメッセージキューに振り分けることで、業務メッセージのルーティング設定を実現します。
  • メッセージのエンコード／デコード：他のパブリック／プライベートTCPプロトコルアクセスや産業用途などのアプリケーションでは、ルール内のローカル処理機能（EMQX上でカスタム開発可能）を使ってバイナリや特殊フォーマットのメッセージボディをエンコード／デコードできます。また、ルールを通じてメッセージをサーバーレス関数など外部計算リソースにルーティングし（ユーザー開発可能）、業務アプリケーションで扱いやすいJSON形式に変換することも可能です。これによりプロジェクト統合の難易度が軽減され、迅速なアプリケーション開発・提供が促進されます。

主なメリット ​

EMQXのルールエンジン機能は、ユーザーに以下のメリットを提供します。

データ処理の簡素化

SQLライクな文法とストリーム処理機能により、カスタムコードや追加ツールなしでデータのフィルタリング、変換、配信を効率的に行えます。

リアルタイムのインサイトとアクション

特定条件に基づくアクションのトリガーにより、リアルタイムでのインサイト取得と適切な対応が可能です。

開発時間と工数の削減

豊富な組み込み機能により、カスタムコードやメンテナンスの負担を軽減し、IoTアプリケーション開発を容易にします。

スケーラビリティと信頼性

高スループットおよび多数の接続デバイスに対応できる設計で、性能や信頼性を損なうことなくIoTソリューションのスケールアップが可能です。