製品をチェック

製品の情報と無償トライアル:

Azure Data Lake Storage 連携ソリューション

データ連携でお困りですか?

お問い合わせ

CData BizTalk Adapter for ADLS に一方向送信ポートを構成


Adapter for ADLS を一方向送信ポートと兼用することにより、BizTalk でアップデートグラムとデータ操作SQL を実行できます。


azuredatalake ロゴ画像
biztalk ロゴ画像

Biztalk ロゴ画像

ここでは、CData BizTalk Adapter for ADLS を使用して静的な一方向送信ポートを作成、構成、テストする手順を説明します。静的な一方向送信ポートを使用することで、アップデートグラム、SQL コマンド、ストアドプロシージャを実行できます。送信ポートは、 返答データを持たない Azure Data Lake Storage データ変更の操作に役立ちます。通常、これはDELETE またはUPDATE のSQL コマンドか、アップデートグラムですが、場合によっては、ストアドプロシージャになります。

SELECT コマンドの実行や、作成したレコードId の取得のような、応答するアクションをトリガーする場合は、要請応答送信ポートを使用します。

一方向送信ポートを作成し実行する

静的な一方向送信ポートを作成し、Azure Data Lake Storage アダプタをトランスポートタイプとして使用するように構成します。

  1. 未実行の場合、BizTalk 管理コンソールでBizTalk アプリケーションを開きます。
  2. BizTalk アプリのノードで、[Send Ports]を右クリックし、[New]->[Static One-Way Send Port]を選択します。送信ポートプロパティのダイアログが表示されます。
  3. [Name]メニューで、送信ポートの名前を入力します。
  4. [Type]メニューで、CData.ADLS を選択します。
  5. [Send Pipeline]メニューで、デフォルトオプションの[PassThruTransmit]を選択します。
The send port properties dialog.(Salesforce is shown.)

アダプタを構成する

[Transport Properties]ダイアログで、アダプタが実行するコマンドを定義します。

  1. 送信ポートのプロパティで、[Configure]ボタンをクリックします。CData.Azure Data Lake Storage トランスポートプロパティのダイアログが表示されます。
  2. [CommandType]プロパティで、実行したいコマンドタイプを選択します。
  3. SQL コマンドを実行したい場合は、[SQL Command]のボックスにコマンドを入力してください。
プロパティとその機能についての説明は、ヘルプドキュメントの[Adapter Configuration]を参照してください。 The Adapter Transport  Properties dialog.(Salesforce is shown.)

Azure Data Lake Storage への接続を構成する

Connection String Options ダイアログで、Azure Data Lake Storage への接続に必要な資格情報とその他のプロパティを設定します。

  1. 送信ポートのプロパティダイアログで[Configure]をクリックすると、アダプタのプロパティダイアログが表示されます。
  2. [Connection String]プロパティのボタンをクリックします。
  3. [Connection String]プロパティのボックスをクリックします。[Connection String Options]ダイアログが表示されます。
  4. 接続プロパティを入力します。下は一般的な接続文字列です。

    Schema=ADLSGen2;Account=myAccount;FileSystem=myFileSystem;AccessKey=myAccessKey;

    Authenticating to a Gen 1 DataLakeStore Account

    Gen 1 uses OAuth 2.0 in Azure AD for authentication.

    For this, an Active Directory web application is required. You can create one as follows:

    1. Sign in to your Azure Account through the .
    2. Select "Azure Active Directory".
    3. Select "App registrations".
    4. Select "New application registration".
    5. Provide a name and URL for the application. Select Web app for the type of application you want to create.
    6. Select "Required permissions" and change the required permissions for this app. At a minimum, "Azure Data Lake" and "Windows Azure Service Management API" are required.
    7. Select "Key" and generate a new key. Add a description, a duration, and take note of the generated key. You won't be able to see it again.

    To authenticate against a Gen 1 DataLakeStore account, the following properties are required:

    • Schema: Set this to ADLSGen1.
    • Account: Set this to the name of the account.
    • OAuthClientId: Set this to the application Id of the app you created.
    • OAuthClientSecret: Set this to the key generated for the app you created.
    • TenantId: Set this to the tenant Id. See the property for more information on how to acquire this.
    • Directory: Set this to the path which will be used to store the replicated file. If not specified, the root directory will be used.

    Authenticating to a Gen 2 DataLakeStore Account

    To authenticate against a Gen 2 DataLakeStore account, the following properties are required:

    • Schema: Set this to ADLSGen2.
    • Account: Set this to the name of the account.
    • FileSystem: Set this to the file system which will be used for this account.
    • AccessKey: Set this to the access key which will be used to authenticate the calls to the API. See the property for more information on how to acquire this.
    • Directory: Set this to the path which will be used to store the replicated file. If not specified, the root directory will be used.

  5. [Test Connection]をクリックして値を確認し、接続を確認します。
プロパティとその機能の説明については、ヘルプドキュメントの[Connection String Options]チャプターを参照してください。 Credentials and other connection properties used to connect to the data source.(Salesforce is shown.)

接続に成功し、アダプターが実行するコマンドを定義することで、送信ポートを使用できるようになります。アプリケーションで一方向送信ポートを使用する例については、次のセクションを参照してください。アプリケーションはファイルに含まれているアップデートグラムコマンドを読み取り、送信ポートを使用してコマンドを実行します。

この例ではフィルターを利用して、アップデートグラムを含むメッセージを受信場所から送信ポートに移動します。フィルターについてのより詳しい説明は次のセクションを参照してください。

フィルターを作成し、アプリケーションを介してBizTalk メッセージをルーティングする

送信ポートを必要なメッセージに関連付けるには、その送信ポートのプロパティの[Filters]セクションでフィルタールールを作成します。条件に一致するメッセージは、送信ポートにルーティングされます。受信場所でのフィルタリングに関しては、次の例を参照してください。

例:一方向送信ポートでアップデートグラムを実行する

このセクションでは、一方向送信ポートをアプリケーションで使用する方法について説明します。アプリケーションはファイルに含まれているアップデートグラムコマンドを読み取り、コマンドを実行します。

  1. 一方向受信場所はアップデートグラムを含むXML ドキュメントをピックアップします。
  2. 受信場所は、コマンドの結果を含むBizTalk メッセージを作成します。
  3. 一方向送信ポートは、受信場所のURI をフィルタリングします。ドキュメントは一方向送信ポートにルーティングされます。
  4. 送信ポートは、アップデートグラムコマンドを実行します。

前の例と同様に次のステップでは、ファイルからアップデートグラムを読み取るための受信場所を設定し、送信ポートを使用してコマンドを実行する方法を説明します。

  1. 静的な一方向の受信場所を作成、構成します。転送タイプのファイルを使用します。「CData BizTalk Adapter for ADLS の受信場所を作成、構成する」と同じ手順に従います。
  2. 静的な一方向送信ポートを作成します。
  3. 送信ポートのプロパティで、[Filters]をクリックします。
  4. 空のプロパティで、次の値を設定します。
    プロパティ
    メニューから BTS.InboundTransportLocation を選択します。
    新しく作成された一方向受信場所のURI を入力します。
A filter that routes updategrams from a one-way receive location to a one-way send port that is configured for the adapter.