Anypoint Studio を使用した Snowflake Connector 1.2 の設定 - Mule 4

Studio で、​[File (ファイル)] > [New (新規)] > [Mule Project (Mule プロジェクト)]​ を選択します。

Mule プロジェクトの名前を入力して、​[Finish (完了)]​ をクリックします。

[Mule Palette (Mule パレット)]​ で、​[(X) Search in Exchange ((X) Exchange 内を検索)]​ をクリックします。

[Add Dependencies to Project (連動関係をプロジェクトに追加)]​ で、検索項目に「​snowflake​」と入力します。

[Available modules (使用可能なモジュール)]​ で ​[Snowflake Connector]​ をクリックします。

[Add (追加)]​ をクリックします。

[Finish (完了)]​ をクリックします。

[Mule Palette (Mule パレット)]​ で、​[Snowflake] > [On Table Row]​ を選択します。

[On Table Row (テーブルの行)]​ を Studio キャンバスにドラッグします。

[On Table Row]​ 設定画面で、必要に応じて ​[Display Name (表示名)]​ の値を変更します。

[Connector configuration (コネクタ設定)]​ の横にある ​+​ をクリックして、アプリケーション内の ​On Table Row​ ソースのすべてのインスタンスで使用できるグローバル要素を設定します。

[Snowflake Config (Snowflake 設定)]​ ウィンドウの ​[Required Libraries (必須のライブラリ)]​ で、​[Configure (設定)] > [Add recommended libraries (推奨されるライブラリを追加)]​ または ​[Configure (設定)] > [Add Maven dependency (Maven 連動関係を追加)]​ を選択し、アーティファクト ID ​snowflake-jdbc​ を追加することで、必須の Snowflake JDBC ドライバーを追加します。

[Connection (接続)]​ セクションで、コネクタのデータベース接続情報を指定します。

[Advanced (詳細)]​ タブで、必要に応じて接続プーリングおよび再接続情報 (再接続戦略を含む) を指定します。

[Test Connection (接続をテスト)]​ をクリックして、Mule が指定された Snowflake データベースに接続できることを確認します。

[OK]​ をクリックして、ウィンドウを閉じます。

[On Table Row]​ 設定画面の ​[Table (テーブル)]​ で、選択元のテーブルの名前を選択します。

[On Table Row]​ 設定画面の ​[Watermark Column (ウォーターマーク列)]​ で、ウォーターマークに使用する列の名前を選択します。この列から取得された値を使用して次のポーリングのコンテンツが絞り込まれるため、ウォーターマークより日付が後の行のみが処理されます。

[On Table Row]​ 設定画面の ​[Id Column (ID 列)]​ で、行 ID とみなす列の名前を選択します。このパラメーターを使用することで、同じ行が同時ポーリングによって 2 回処理されないようになります。

[Mule Palette (Mule パレット)]​ で、​[HTTP] > [Listener]​ を選択します。

[Listener]​ を Studio キャンバスにドラッグします。

[Listener (リスナー)]​ 設定画面で、必要に応じて ​[Display Name (表示名)]​ の値を変更します。

[Path (パス)]​ 項目の値を指定します。

[Connector configuration (コネクタ設定)]​ の横にある ​+​ をクリックして、アプリケーション内の HTTP Listener ソースのすべてのインスタンスで使用できるグローバル要素を設定します。

[General (一般)]​ タブで、コネクタの接続情報を指定します。

[TLS]​ タブで、必要に応じてコネクタの TLS 情報を指定します。

[Advanced (詳細)]​ タブで、必要に応じて再接続戦略を含む再接続情報を指定します。

[Test Connection (接続をテスト)]​ をクリックして、Mule が指定されたサーバーに接続できることを確認します。

[OK]​ をクリックします。

[Mule Palette (Mule パレット)]​ で ​[Snowflake]​ を選択し、目的の操作を選択します。

その操作を Studio キャンバスの入力元の右にドラッグします。

Studio キャンバスで操作を選択します。

操作の設定画面で、​[Connector configuration (コネクタ設定)]​ 項目の横にある ​[+]​ をクリックし、グローバル要素設定項目にアクセスします。

[General (一般)]​ タブの ​[Required Libraries (必須のライブラリ)]​ で、​[Configure (設定)]​ をクリックし、次のオプションから選択して、必要な JDBC ドライバーをインストールします。

[General (一般)]​ タブで、次の必須情報を入力して認証を設定します。

[Advanced (詳細)]​ タブで、必要に応じて再接続戦略を含む再接続情報を指定します。

[Test Connection (接続をテスト)]​ をクリックして、Mule が指定されたサーバーに接続できることを確認します。

[OK]​ をクリックします。