EMQX Tables
EMQX Tablesは、EMQX Cloudに組み込まれたフルマネージドの時系列データベースサービスであり、GreptimeDBによって動作しています。外部データベースや統合パイプラインのセットアップを必要とせずに、MQTTメッセージの保存、クエリ、および分析をシームレスに行う方法を提供します。
EMQX Tablesを使用すると、IoTデータがデバイスからEMQXブローカーを経由してスケーラブルで効率的な時系列ストレージエンジンに直接流れ込み、標準SQLクエリや一般的な可視化ツールとのネイティブ統合によりリアルタイムのインサイトを得ることが可能です。
GreptimeDBによる動作
EMQX Tablesは、クラウドネイティブで高性能な時系列データベースであるGreptimeDBを活用しています。高速な取り込み、効率的な圧縮、スケーラブルなクエリに最適化されており、デバイスデータへのアクセス性を維持しつつ、高速なクエリとコスト効率を実現します。
なぜEMQX Tablesなのか？
MQTTブローカーとデータベースを別々のシステムとして管理すると、統合の複雑さ、配信遅延、コスト増加が発生しがちです。EMQX Tablesは以下を提供することでこれらの課題を解決します。
- MQTTトピックからデータベース、ダッシュボードまでの統合されたデータパイプライン。
- ゼロセットアップのフルマネージドバックエンド。
- リアルタイムのSQLベースクエリと可視化。
- 単一ベンダーのシンプルさで、ツールやベンダー、セキュリティモデルを行き来する必要がありません。
主な機能
- シームレスなMQTT統合：EMQXルールエンジンや直接シンクを使ってMQTTトピックからデータを直接取り込み保存。
- 組み込みの時系列データベース：時系列およびテレメトリデータの保存とクエリに特化したGreptimeDBを搭載。
- 高性能：IoTシステムで一般的な高頻度取り込みに最適化され、リアルタイム分析をサポート。
- 高可用性オプション：本番環境での高可用性と強力なレジリエンスが必要な場合はProプランを利用可能。
- SQLおよびプロトコル互換性：SQLやInfluxDB Line Protocolでのクエリが可能。
- ユーザーおよび権限管理：カスタムユーザーの作成、権限割り当て、データベースやテーブルパターンへのアクセス制御。
- 可視化向け設計：Grafana、Streamlitなどのツールと簡単に接続し、時系列データのダッシュボードを構築可能。
- 統合された操作体験：外部ストレージシステムの設定不要で、EMQXコンソール内でMQTTブローカーと時系列データベースを一元管理。
動作の仕組み
EMQX Tablesは、MQTTメッセージから時系列ストレージおよび分析までのエンドツーエンドのデータフローをEMQX Cloud内でフルマネージドで提供します。一般的なワークフローは以下の通りです。
- EMQX CloudコンソールでEMQX Tablesのデプロイメントを作成します。
- ワークロードに必要な権限とデータベースアクセスを持つカスタムEMQX Tablesユーザーを作成します。
- EMQXブローカーを組み込み統合またはルールエンジン経由でEMQX Tablesに接続します。
- MQTTトピックにデータをパブリッシュします（例：デバイスからのテレメトリ）。
- EMQXがGreptimeDB対応テーブルに自動的にデータを保存します。
- コンソールのSQLエディターやクライアントツールを使ってデータをクエリします。
- GrafanaやMetabaseでデバイスの状態や過去の傾向を可視化します。
EMQX Tablesを使うべきタイミング
EMQX Tablesは、外部インフラを管理せずにMQTTデータの保存、クエリ、分析をシームレスに行いたいIoT開発者やデータエンジニア向けに設計されています。
以下のような場合にEMQX Tablesの利用をおすすめします。
- MQTTデータのためのフルマネージドでメンテナンス不要なストレージソリューションが欲しい。
- EMQX Cloudから直接テレメトリや時系列データを保存・クエリしたい。
- デバイスデータを基にダッシュボード、分析、監視システムを構築したい。
- 自身で時系列データベースをデプロイ・運用したくない。
よくあるユースケース
- IoTテレメトリストレージ
接続されたデバイスからの温度、湿度、GPS、センサー読み取り値を時間軸で取得・保持。 - 運用監視
バッテリー残量、アップタイム、状態などのデバイス指標を追跡し、リアルタイムのアラートや監視システムを実現。 - リアルタイムダッシュボード
GrafanaやMetabaseなどの可視化ツールを使ってデバイスの状態や過去の傾向を表示。 - データ分析
時系列データにSQLクエリを実行し、インサイト抽出、パターン検出、下流ワークフローの駆動に活用。
料金
EMQX TablesはEMQX Cloudサブスクリプションの一部として、コンピュート、ストレージ、アウトバウンドトラフィックの使用量に基づく課金が行われます。詳細は料金と請求をご参照ください。