この記事では、CData BizTalk アダプターを使用して取得したHive を処理するスキーマを作り出す方法を紹介します。SELECT コマンド用のスキーマを作成します。
CData BizTalk Adapter for ApacheHive を使用して、Hive に標準のSQL コマンドを実行できます。 このガイドに従って、SELECT やINSERT、UPDATE、DELETE のコマンドを実行できます。
プロジェクトのHive 用アダプターを追加する
以下のステップに従って、アダプターをBizTalk サーバープロジェクトに追加します。
- 未作成の場合は、Visual Studio で新規のBizTalk サーバープロジェクトを作成します。
- [Solution Explorer] の[project] で右クリックし、[Add] -> [Add Generated Items] と進みます。
- [resulting dialog box] の[Add Adapter Metadata] を選択します。
- 表示される[Add Adapter] ウィザードで、リストからアダプターを選択します。
- [Port menu] では、選択を空白のままにします。そのトランスポートタイプに合わせて構成されたアダプターを持つ受信場所や送信ポートを選択することもできます。
SQL コマンド用のスキーマを作り出す
[Add Adapter] ウィザードでアダプターを選択すると、[Schema] ウィザードが表示されます。以下のステップに従って接続プロパティを構成し、コマンドの結果のメタデータを取得します。
- BizTalk アプリで構成済みのアダプターを選択しなかった場合は、[Connection String] ページで、認証資格情報とその他の接続プロパティを入力します。下は一般的な接続文字列です。
Server=127.0.0.1;Port=10000;TransportMode=BINARY;
Apache Hive への接続を確立するには以下を指定します。
- Server:HiveServer2 をホストするサーバーのホスト名またはIP アドレスに設定。
- Port:HiveServer2 インスタンスへの接続用のポートに設定。
- TransportMode:Hive サーバーとの通信に使用するトランスポートモード。有効な入力値は、BINARY およびHTTP です。デフォルトではBINARY が選択されます。
- AuthScheme:使用される認証スキーム。有効な入力値はPLAIN、LDAP、NOSASL、およびKERBEROS です。デフォルトではPLAIN が選択されます。
- 本製品においてTLS/SSL を有効化するには、UseSSL をTrue に設定します
- 次ページ[Schema Information] の[General Options] セクションで、アダプターの構成に応じて[Send Port] または[Receive Location] を選択します。
- 結果セット全体のスキーマを作成するには、[Message Mode]メニューの[Single Message] オプションを選択します。結果セットの行ごとに1つずつのスキーマを作成したい場合は、[Message Per Row] オプションを選択し、メッセージのルート要素が[row] であることを確認します。
- [Command Type] メニューで、SQL コマンドを選択します。
[Statement Information] ページの[SQL Command Text box] に、SQL コマンドを入力します。(受信場所や送信ポートが構成してある場合は、そのSQL コマンドがボックスに入力されます。)ここでは、下のクエリを使用します。
SELECT * FROM Customers
- ウィザードで表示される概要の設定を確認し、[Finish] をクリックしてschema.xsd ファイルを作成します。
スキーマの処理
簡易版BizTalk アプリでスキーマを利用する場合、 こちらのチュートリアルをご覧ください。