EMQX Enterprise

日本語

简体中文
English

日本語

简体中文
English

Appearance

お問い合わせ
お問い合わせ

コネクター ​

EMQXのコネクターはデータ統合における重要な概念であり、Sink/Sourceの基盤となる接続チャネルとして機能し、外部データシステムへの接続に使用されます。

基本概念 ​

コネクターは外部データシステムへの接続に特化しています。ユーザーは異なる外部データシステムごとに複数のコネクターを作成でき、1つのコネクターが複数のSink/Sourceへの接続を提供することも可能です。

MySQL Sinkを例に、コネクター、ルール、およびSinkの関係は以下の図のように示されます。

EMQX Connector Concept

特徴と利点 ​

Sink/Sourceを作成する際、ユーザーは既存のコネクターを選択するだけで、基盤となる接続の詳細を気にする必要がありません。この設計の利点は以下の通りです。

  • 接続設定をデータ処理やマッピング設定から分離することで、データ処理フローの設計がよりモジュール化され柔軟になります。
  • コネクターの作成および設定はデータ処理フローの設計に影響を与えません。接続情報を変更する必要がある場合はコネクター側で修正でき、設定や保守の簡素化に寄与します。
  • 複数のSink/Sourceに接続する必要がある外部データシステムの場合、単一のコネクターを作成することで対応でき、設定の重複を避けられます。

コネクターの作成 ​

データ統合を作成する際は、統合が機能するためにSink/Source用のコネクターを作成する必要があります。コネクターはダッシュボードから作成および管理でき、1つのコネクターを複数のSink/Sourceで再利用可能です。

TIP

Sink/Source作成の過程でコネクターを作成することもでき、その場合は自動的にコネクター作成プロセスに入ります。

  1. ダッシュボードの左ナビゲーションメニューで Integration -> Connectors をクリックします。

  2. ページ右上の Create ボタンをクリックして、コネクター作成プロセスに入ります。

  3. コネクタータイプ選択ページで必要なコネクターを選択し、Next をクリックして接続パラメータを入力します。対応するコネクターはこちらを参照してください。

    EMQX Select Connector

  4. コネクター設定情報ページで、コネクター名、説明、接続パラメータなどの基本情報を入力します。ここでの内容は各Sink/Sourceの使用ドキュメント内のコネクターパラメータセクションを参照しており、詳細は省略します。

    EMQX Connector Configuration

コネクターの表示と管理 ​

コネクター作成後は、Connectorsページで基本情報を確認できます。有効化／無効化の切り替えや、設定の編集、ルール作成、コネクターの複製、削除などの管理操作はコネクター一覧の Actions 列から行えます。

コネクターの表示

コネクターがSink/Sourceで使用されている場合、コネクター設定の更新によりSink/Sourceがリロードされ、データ処理が一時的に中断される可能性があります。更新は業務の閑散時間帯に行うことを推奨します。

使用中のコネクターは削除できません。コネクターを削除するには、まずそのコネクターを使用しているSink/Sourceを削除する必要があります。削除時には、コネクターに関連付けられたSink/Sourceが警告ダイアログで表示されます。Sink/Sourceをクリックすると、ルール設定ページに遷移し、そこでSink/Sourceの削除が可能です。

delete_associated_sink

コネクターの状態 ​

ダッシュボードでコネクターの稼働状況を確認でき、トラブルシューティングや監視に役立ちます。

コネクターの状態は以下の通りです。

  • Connecting：ヘルスチェックが行われる前の初期状態で、まだ外部データシステムへの接続を試みている段階です。
  • Connected：コネクターが外部データシステムに正常に接続されている状態です。この状態でヘルスチェックに失敗すると、障害の程度に応じて「connecting」または「disconnected」状態に切り替わることがあります。
  • Disconnected：ヘルスチェックに失敗し、不健康な状態です。設定によっては定期的に自動再接続を試みます。
  • Inconsistent：クラスター内のノード間でコネクターの状態が不一致です。例えば、一部のノードでは接続済み、他のノードでは切断済みとなっている場合です。

注意点 - コネクションプール ​

一部のコネクターはコネクションプールという再利用可能な接続オブジェクトの集合を提供しています。コネクションプールを利用することで、リクエストごとに接続を再作成する必要がなくなり、リソース消費の削減や接続効率・同時実行性の向上に寄与します。

コネクションプールのサイズは各EMQXノードごとのサイズを指し、EMQXは各ノードに別々のコネクションプールを作成します。EMQXは通常クラスターでデプロイされるため、外部データシステムの制限を超える接続数になる可能性があります。

例えば、3ノードのEMQXクラスターでコネクターのコネクションプールサイズを8に設定した場合、EMQXは3 × 8 = 24の接続を作成します。