新機能
本ページでは、現在のリリースでサポートされている主な新機能を紹介します。なお、EMQX Cloudが提供するすべての機能を網羅しているわけではありません。
EMQX CloudがEMQX Agentsで拡張
EMQX Cloudには、EMQX Agentsが含まれるようになりました。これは、MQTTおよび時系列データの上に構築されたイベント駆動型エージェントを構築・デプロイするためのホスティングされたAIエージェントランタイムです。カスタムの自動化コードを書く代わりに、エージェントに何をさせたいかを自然言語で記述すると、プラットフォームがそれを構築・デプロイします。
主な機能
- AI駆動のチャット：自動化の目標を自然言語で記述すると、LLMがエージェントの指示、スキル、構成を生成します。
- 組み込みテンプレート：あらかじめ定義されたエージェントシナリオから開始し、新しいチャットやワークスペース向けに指示、変数、コネクターをカスタマイズ可能です。
- イベント駆動の実行：各エージェントは設定されたMQTTトピックを監視し、トリガーに一致する受信メッセージごとに実行を行います。
- 組み込みツール：エージェントはEMQX ブローカー経由でMQTTメッセージをパブリッシュし、EMQX Tables経由で時系列データをクエリできます。
- 完全な可観測性：各実行には、エージェントが取った各ステップ、トークン使用量、最終ステータスを示す完全なタイムラインがあります。
EMQX Agentsを使うべき場合
以下のような場合にEMQX Agentsを利用してください：
- カスタムサービスコードを書かずにMQTTイベントに自動応答したいとき
- AI駆動の異常検知、条件付きアクション、またはライブデバイスデータのデータ強化が必要なとき
- 自然言語を使ったIoT自動化ロジックの迅速なプロトタイピングを行いたいとき
詳細情報
EMQX Agentsの作成と利用については以下を参照してください：
EMQX CloudがEMQX Fleetsで拡張
EMQX Cloudには、EMQX Fleetsが含まれるようになりました。これは、EMQX ブローカーの上にアプリケーション層を追加する、完全管理型のIoTデバイス管理サービスです。EMQX ブローカーがメッセージ輸送を、EMQX Tablesがデータストレージを担当する一方で、EMQX Fleetsはデバイス管理層、すなわちデバイスの識別、状態同期、リモートコマンド、バッチジョブの配信を担います。
主な機能
- デバイスレジストリ：Thing Typesでデバイススキーマを定義し、デバイスをThingsとして登録、タグを使ってThing Groupsに整理可能
- デバイスシャドウ：報告済み、希望値、差分の3状態モデルで、クラウドの意図とデバイス状態を切断時も同期維持
- デバイスクエリ：接続状態、シャドウプロパティ、タグなどでフィルタリング可能なSQLライクなクエリ言語でフリート全体を検索
- コマンド：個別デバイスにリアルタイムのリクエスト・レスポンスコマンドを送信し、実行状況を追跡
- ジョブ：デバイスグループへのバッチ操作を配信し、各デバイスの進捗をライフサイクル全体で監視
EMQX Fleetsを使うべき場合
以下のような場合にEMQX Fleetsを利用してください：
- スキーマベースのデバイスモデルを持つ永続的なデバイスレジストリが必要なとき
- クラウドと断続的に接続されるデバイス間で信頼性の高い状態同期が必要なとき
- 確認済みの結果を伴うリモートコマンド実行が必要なとき
- デバイスグループへのファームウェア展開などのバッチ操作が必要なとき
- デバイスの状態やプロパティによるフリート全体の検索・フィルタリングが必要なとき
詳細情報
EMQX Fleetsの作成と利用については以下を参照してください：
EMQX CloudがEMQX Tablesで拡張
EMQX Cloudには、EMQX Tablesが含まれるようになりました。これは、外部ストレージシステムをデプロイせずにMQTTデータの保存、クエリ、分析を行うための完全管理型時系列データベースです。
GreptimeDBを基盤とし、IoTデータの取り込みとSQLベースの分析に最適化されたスケーラブルな時系列ストレージを提供します。EMQX Tablesは、Serverless、Dedicated、Dedicated FlexのEMQX ブローカー展開タイプと統合可能です。
主な機能
- ルールエンジンのアクションや直接シンク統合を使ったMQTTトピックからの直接取り込み
- 高い取り込み性能に最適化された管理された時系列ストレージ
- EMQX コンソールや外部クライアントからのSQLベースのクエリ
- Grafana、Metabaseなどの分析ツールとのダッシュボード統合
EMQX Tablesを使うべき場合
以下のような場合にEMQX Tablesを利用してください：
- テレメトリやデバイスイベントデータの長期保存が必要なとき
- リアルタイムダッシュボードや過去のトレンド分析を行いたいとき
- 時系列データセットに対するSQLベースのクエリが必要なとき
- 外部データベースやETLパイプラインの代替としてシンプルなソリューションが欲しいとき
- EMQX Cloud内で統合されたデータ処理とストレージを利用したいとき
詳細情報
EMQX Tablesの作成と利用については以下を参照してください：
EMQX CloudがEMQX v6 ブローカー展開をサポート
EMQX Cloudは、DedicatedおよびDedicated Flexのブローカー展開でEMQX v6をサポートします。EMQX v6 ブローカーの機能や、EMQX v6展開向けに導入されたCloud固有の機能が必要な場合はEMQX v6を選択してください。Serverless展開ではEMQXバージョンの選択はできません。
主な機能
- EMQX v6展開バージョン：対応するDedicatedまたはDedicated Flex展開作成時に、EMQX VersionフィールドでEMQX v6を選択すると、EMQX v6上で展開が実行されます。
- ログトレース：特定のMQTTクライアント、トピック、送信元IPアドレス、ルールIDのデバッグレベルログを収集可能。展開全体の詳細ログを有効にする必要はありません。
- イベント履歴：最近のクライアント接続、認証、サブスクライブイベントを記録し、接続失敗、予期しない切断、認証失敗、サブスクライブが反映されない問題のトラブルシューティングに役立ちます。
- BigQueryデータ統合：ルールエンジンとBigQueryシンクを通じてMQTTデータをBigQueryにストリームし、SQLベースの分析やレポートに利用可能。
- Snowflakeストリーミングデータ統合：ルールエンジンとSnowflakeストリーミングシンクを通じてMQTTデータをSnowflakeに低レイテンシで取り込み可能。
- MQTTソースの強化：共有サブスクリプショントピックを使用して重複メッセージを回避し、リモートMQTTサービスからのブリッジ時にMQTT 5.0のサブスクライブオプション（No Local、Retain As Published）を設定可能。
詳細情報
EMQX v6 ブローカー展開機能の詳細は以下を参照してください：
EMQX ブローカーの新機能
EMQX Cloudは、管理されたデータ処理、クラスター間通信、および顧客管理クラウド展開のためのブローカー機能を追加しました。
注意
Smart Data HubおよびCluster LinkingはEMQX Dedicated Flexエディションで利用可能です。
Azure上のBYOC
EMQX Cloudは、選択された国際リージョンのAzureパブリッククラウド上でv5 BYOCブローカー展開の作成をサポートします。Azure上のBYOCにより、EMQX Cloudのデプロイガイダンスやライフサイクル操作を利用しながら、お客様自身のAzureアカウントでEMQX ブローカーを実行できます。
Azure BYOC展開を作成する前に、選択したリージョンのAzureリソースグループと、そのリソースグループにスコープされたContributorロールを持つMicrosoft Entraサービスプリンシパルを準備してください。対応リージョン、必要なリソース、権限、展開手順については以下を参照してください：
Smart Data Hub
Smart Data Hubは、EMQX ブローカー内でのインテリジェントなデータ処理のための統合ソリューションであり、MQTTデータストリームの簡素化と効率的な管理を目的としています。
主な機能：
- スキーマレジストリ：データスキーマの作成、変更、削除を行い、データ形式と標準の一貫性を確保します。
- スキーマ検証：受信データを事前定義されたスキーマに対して検証し、フォーマットエラーやデータ不整合を防止します。
- メッセージ変換：リアルタイムでデータメッセージを変換し、MQTTデータを様々なアプリケーションシナリオに合わせてフォーマットやマッピングします。
Smart Data Hubを使うことで、ユーザーは広範なカスタムコードなしにIoTデバイスとエンタープライズシステムやクラウドプラットフォームを橋渡しする高度なデータワークフローを構築できます。
Cluster Linking
Cluster Linkingは、異なるEMQX クラスター間でシームレスかつ安全な通信を可能にし、地理的に分散したクラスター上のクライアント間で効率的なメッセージ伝送を実現します。
主な機能：
- クラスター間データレプリケーション：複数リージョンの冗長性や分散処理のためにリアルタイムでメッセージを共有します。
- 効率的な通信：関連するメッセージのみを転送し、帯域幅の使用を削減。ネットワーク障害時でも効率的な通信を維持します。
- 選択的トピック転送：共有するトピックを厳密に制御し、帯域幅の最適化とデータ境界の維持を可能にします。
- 安全な通信：TLS暗号化と相互認証を利用し、クラスター間のデータ転送を保護します。
Cluster Linkingは、組織が水平スケール、地理的冗長化、高可用性を実現し、ミッションクリティカルなIoTワークロードを支えます。
Dedicated Flex v5の新機能
EMQX Dedicated Flexは、専用クラウド環境でMQTTクラスターをホストすることで知られ、EMQX製品群の中核を成しています。このたび、最新バージョンのDedicated Flexにアップグレードし、さまざまな業界のミッションクリティカルなIoTアプリケーションを支える多彩な新機能と能力を導入しました。
強化されたメトリクスと可観測性
アップグレードされた監視システムは、クライアント接続、認証、認可、データ統合のメトリクスを包括的かつ詳細に表示し、より深い洞察を提供します。
クライアントメトリクス
Dedicated Flex v5コンソールは、サービスに接続された各クライアントのメッセージ、パケット、バイトなどの多様なメトリクスをカテゴリ別に整理しています。この詳細な区分により、クライアントの活動を深く分析でき、関連メトリクスを直感的なチャート形式で表示します。 
認証／認可メトリクス
EMQX Dedicated Flex v5では、認証および認可プロセスに関する詳細なメトリクスを導入し、潜在的な問題の早期発見を支援します。認証用の新APIを組み込み、認証プロセスの管理をよりシームレスかつ効果的に行えるようになりました。 
データ統合メトリクス
以前のv4ではメトリクスが限定的でトラブルシューティングに十分な情報がありませんでした。v5ではルールとアクションに関連するメトリクスの範囲を大幅に拡大し、データ処理活動の包括的な理解を可能にしています。 
使いやすさの向上
Dedicated Flex v5の使いやすさ向上には、詳細な情報と簡単な削除機能を備えた保持メッセージ管理システムや、認証／認可データソースの並び替えを直感的に行えるインターフェースが含まれます。
保持メッセージ管理
v5では、v4の保持メッセージ数表示に比べて大幅に進化した保持メッセージ管理システムをコンソールに導入しました。メッセージのトピック、QoS、パブリッシュ時間、ペイロードの詳細表示が可能で、個別メッセージの削除やすべての保持メッセージの一括クリアも行えます。これは、以前の空メッセージ送信による削除方法に比べて明確な改善です。 
認証／認可データソースの並び替え
v5では、デフォルトを含む拡張認証／認可データソースの設定と並び替えが可能になりました。ユーザーはドラッグ＆ドロップで認証チェーンの実行順序を簡単に調整でき、認証ロジックを明確かつ直感的に可視化できます。 
高度な機能
以下はDedicated Flex v5の高度な機能の一部です。
QUIC上のMQTT
次世代インターネットプロトコルHTTP/3の基盤となるトランスポートプロトコルQUICを活用し、v5はモダンなモバイルインターネット向けに接続性を強化しました。この技術により、従来のTCP/TLSプロトコルに比べて接続オーバーヘッドとメッセージレイテンシが低減され、EMQX Dedicated FlexはMQTT通信における最先端技術の先駆けとなっています。
証明書失効リスト（CRL）
CRLは証明書機関（CA）が管理する、失効した証明書のシリアル番号と失効日時の一覧です。この機能により、EMQX Dedicated FlexはSSL/TLSハンドシェイク時にクライアント証明書の失効をチェックし、安全な接続を確保します。
オンライン証明書状態プロトコル（OCSP）ステイプリング
証明書失効チェックの別の層を提供します。OCSPステイプリングを有効にすると、EMQX Dedicated FlexはOCSPサーバーに証明書状態を問い合わせ、結果をキャッシュします。SSLハンドシェイク時にEMQXはOCSPデータを証明書チェーンとともにクライアントに提示し検証を行います。
EMQX Dedicated Flex v5の力でIoTソリューションを強化し、IoTデータ管理の可能性を最大限に引き出しましょう。