SnapLogic を使用して RabbitMQ を外部サービスと連携

Jerod Johnson
Jerod Johnson
Director, Technology Evangelism
CData JDBC Driver を SnapLogic で使用して、RabbitMQ を外部サービスと連携する方法を説明します。

SnapLogic は、ノーコードでデータ連携フローを作成できる iPaaS（Integration Platform as a Service）です。CData JDBC Driver と組み合わせることで、RabbitMQ を含む250を超える SaaS、ビッグデータ、NoSQL ソースのリアルタイムデータに SnapLogic ワークフローからアクセスできます。

CData JDBC Driver は、最適化されたデータ処理機能を内蔵しており、リアルタイム RabbitMQ のデータ とのやり取りにおいて比類ないパフォーマンスを発揮します。外部ツールから複雑な SQL クエリが発行されると、ドライバーはフィルタや集計などのサポートされている SQL 操作を RabbitMQ に直接プッシュし、サポートされていない操作（多くの場合、SQL 関数や JOIN 操作）は内蔵の SQL エンジンを使用してクライアント側で処理します。動的なメタデータクエリ機能により、ネイティブデータ型を使用して RabbitMQ のデータ を操作できます。

SnapLogic から RabbitMQ に接続

SnapLogic から RabbitMQ のデータ に接続するには、CData RabbitMQ JDBC Driver をダウンロードしてインストールします。インストールウィザードに従って進めてください。インストールが完了すると、JAR ファイルはインストールディレクトリ（デフォルトでは C:/Program Files/CData/CData API Driver for JDBC/lib）に配置されます。

RabbitMQ JDBC Driver のアップロード

インストール後、Manager タブから SnapLogic 内の場所（例：projects/Jerod Johnson）に JDBC JAR ファイルをアップロードします。

接続の設定

JDBC Driver をアップロードしたら、RabbitMQ への接続を作成します。

  1. Designer タブに移動します
  2. Snaps から「JDBC」を展開し、「Generic JDBC - Select」snap をデザイナーにドラッグします
  3. Add Account をクリック（または既存のアカウントを選択）し、「Continue」をクリックします
  4. 次のフォームで、JDBC 接続プロパティを設定します：
    • JDBC JARs に、先ほどアップロードした JAR ファイルを追加します
    • JDBC Driver Class を cdata.jdbc.api.APIDriver に設定します

    • JDBC URL を RabbitMQ JDBC Driver の JDBC 接続文字列に設定します。例：

      jdbc:api:Profile=C:\profiles\\RabbitMQ.apip;AuthScheme=Basic;URL=http://localhost:15672;User=guest;Password=guest;RTK=XXXXXX;

      注意：RTK はトライアルキーまたは製品キーです。詳細についてはサポートチームまでお問い合わせください。

      組み込みの接続文字列デザイナー

      JDBC URL の構築には、RabbitMQ JDBC Driver に組み込まれている接続文字列デザイナーを使用できます。JAR ファイルをダブルクリックするか、コマンドラインから JAR ファイルを実行してください。

      java -jar cdata.jdbc.api.jar

      接続プロパティを入力し、接続文字列をクリップボードにコピーします。

      RabbitMQ Management HTTP API について

      RabbitMQ は、複数のメッセージングプロトコルをサポートするオープンソースのメッセージブローカーです。RabbitMQ Management HTTP API は、RabbitMQ サーバーの管理データと監視データに HTTP 経由でアクセスする手段を提供します。この API では、仮想ホスト、エクスチェンジ、キュー、バインディング、コネクション、チャネル、コンシューマー、ユーザー、権限、ポリシー、クラスター全体の統計情報を取得できます。

      HTTP API を利用するには、RabbitMQ サーバーで Management プラグインを有効化する必要があります。デフォルトでは、管理インターフェースはポート 15672 でリッスンします。

      Basic 認証の設定

      RabbitMQ Management HTTP API は HTTP Basic 認証を使用します。RabbitMQ 管理ユーザーのユーザー名とパスワードを指定する必要があります。

      管理 API へのアクセスを有効にするには、以下のステップで進めます：

      1. サーバーで RabbitMQ Management プラグインが有効になっていることを確認します（rabbitmq-plugins enable rabbitmq_management）。
      2. 既存の管理ユーザーを使用するか、適切な管理タグ（management、policymaker、monitoring、または administrator）を持つユーザーを作成します。
      3. RabbitMQ Management HTTP API の完全なベース URL を控えておきます（例：http://localhost:15672）。

      RabbitMQ サーバーを設定したら、以下の接続プロパティを設定して接続します：

      • AuthScheme：Basic に設定します。
      • URL：RabbitMQ Management HTTP API のベース URL に設定します（例：http://localhost:15672）。
      • User：RabbitMQ の管理ユーザー名に設定します（例：guest）。
      • Password：RabbitMQ の管理パスワードに設定します。

      接続文字列の例：

      Profile=C:\profiles\RabbitMQ.apip;AuthScheme=Basic;URL=http://localhost:15672;User=guest;Password=guest;

      利用可能なテーブル

      RabbitMQ プロファイルでは、以下のテーブルにアクセスできます：

      • Overview - クラスター全体の統計情報と RabbitMQ ノードに関する情報
      • Nodes - RabbitMQ クラスター内の個々のノードに関する情報
      • NodeMemory - 特定のクラスターノードの詳細なメモリ使用状況の内訳
      • Connections - ブローカーへのすべてのオープンな AMQP コネクションの一覧
      • Channels - すべてのコネクションにわたるオープンな AMQP チャネルの一覧
      • Consumers - すべてのキューに登録されたコンシューマーの一覧
      • Exchanges - すべての仮想ホストで宣言されたエクスチェンジの一覧
      • Queues - すべての仮想ホストで宣言されたキューの一覧
      • Bindings - エクスチェンジとキュー間のすべてのバインディングの一覧
      • VirtualHosts - ブローカーに設定された仮想ホストの一覧
      • VhostPermissions - 特定の仮想ホスト内のユーザー権限
      • Users - すべての RabbitMQ ユーザーの一覧
      • Permissions - すべての仮想ホストにわたる全ユーザーの権限レコード
      • TopicPermissions - 全ユーザーのトピックレベルの権限レコード
      • Policies - 仮想ホスト内のキューおよびエクスチェンジに適用されたポリシーの一覧
      • OperatorPolicies - 仮想ホスト内のキューに適用されたオペレーターポリシーの一覧
      • Parameters - 仮想ホストごとのコンポーネントパラメータ（例：federation、shovel）の一覧
      • GlobalParameters - すべての仮想ホストに適用されるグローバルパラメータの一覧
      • VhostLimits - 特定の仮想ホストに設定されたリソース制限
      • UserLimits - 特定のユーザーに設定されたリソース制限
      • FeatureFlags - フィーチャーフラグの一覧と、ノード上での有効／無効の状態
      • DeprecatedFeatures - 非推奨機能の一覧と、その使用状態
      • AuthAttempts - ノードの認証試行統計
      • ClusterName - RabbitMQ クラスターの名前
      • WhoAmI - 現在認証されている管理ユーザーに関する情報
      • ExchangeBindingsSource - 特定のエクスチェンジがソースとなっているバインディング
      • ExchangeBindingsDestination - 特定のエクスチェンジが宛先となっているバインディング
      • QueueBindings - 仮想ホスト内の特定のキューのバインディング
  5. 接続プロパティを入力したら、「Validate」をクリックし、「Apply」をクリックします

RabbitMQ のデータ の読み取り

接続の検証と適用後に開くフォームで、クエリを設定します。

  • Schema name を「API」に設定します
  • Table name を RabbitMQ のテーブルに設定します。スキーマ名を使用して、例：「API」.「AuthAttempts」（ドロップダウンで利用可能なテーブルの一覧を確認できます）
  • テーブルから使用する各項目の Output fields を追加します

Generic JDBC - Select snap を保存します。

接続とクエリを設定したら、snap の末尾をクリックしてデータをプレビューします（下図でハイライト表示）。

結果が期待通りであることを確認したら、追加の snap を使用して RabbitMQ のデータ を別のエンドポイントに送信できます。

RabbitMQ のデータ を外部サービスにパイプ

この記事では、データを Google スプレッドシートに読み込みます。サポートされている任意の snap を使用するか、別の CData JDBC Driver と Generic JDBC snap を使用して、外部サービスにデータを移動できます。

  1. 「Worksheet Writer」snap を「Generic JDBC - Select」snap の末尾にドロップします。
  2. Google Sheets に接続するためのアカウントを追加します
  3. Worksheet Writer snap を設定して、RabbitMQ のデータ を Google スプレッドシートに書き込みます

これで、完全に設定されたパイプラインを実行して、RabbitMQ からデータを抽出し、Google スプレッドシートにプッシュできます。

詳細情報と無料トライアル

CData API Driver for JDBC を使用することで、SnapLogic で RabbitMQ のデータ を外部サービスと連携するパイプラインを作成できます。RabbitMQ への接続の詳細については、CData API Driver for JDBC ページをご覧ください。CData API Driver for JDBC の30日間無料トライアルをダウンロードして、今すぐお試しください。

はじめる準備はできましたか？

API Driver で RabbitMQ のライブデータに接続

RabbitMQ に接続

この記事の内容

関連記事