コピー アクティビティで Azure Table Storage を構成する
この記事では、データ パイプラインでのコピー アクティビティを使用して、Azure Table Storage との間でデータをコピーする方法について説明します。
サポートされている構成
Copy アクティビティの下の各タブの構成については、それぞれ次のセクションを参照してください。
全般
[全般設定] タブを構成するには、全般設定のガイダンスを参照してください。
Source
[ソース] タブに移動して、コピー アクティビティのソースを構成します。 詳細な構成については、次の内容を参照してください。
次の 3 つのプロパティが必要です。
[データ ストアの種類]: [外部] を選択します。
[接続]: 接続リストから Azure Table Storage の接続を選択します。 接続が存在しない場合は、[新規] を選択して新しい Azure Table Storage 接続を作成します。
[クエリの使用]: データの読み取り方法を指定します。 [テーブル] を選択して指定したテーブルからデータを読み取るか、[クエリ] を選択してクエリでデータを読み取ります。
[テーブル] を選択した場合:
- [テーブル]: Azure Table Storage データベース インスタンス内のテーブルの名前を指定します。 ドロップダウン リストからテーブルを選択するか、[編集] を選択して手動で名前を入力します。
[クエリ] を選択した場合:
[テーブル]: Azure Table Storage データベース インスタンス内のテーブルの名前を指定します。 ドロップダウン リストからテーブルを選択するか、[編集] を選択して手動で名前を入力します。
[クエリ]: データを読み取るカスタム テーブル ストレージ クエリを指定します。 ソース クエリは、Azure Table Storage でサポートされている
$filter
クエリ オプションからの直接マップです。このアーティクルの構文について詳しく説明します。Note
Azure Table のクエリ操作は、Azure Table サービスによって適用されるとおり、30 秒でタイムアウトとなります。 クエリの最適化方法については、「クエリに対応した設計」という記事をご覧ください。
[詳細設定] では、次のフィールドを指定できます。
[見つからないテーブルを無視する]: テーブルが存在しないという例外を許可するかどうかを指定します。 既定では選択されていません。
[追加の列]: ソース ファイルの相対パスまたは静的値を格納するための追加のデータ列を追加します。 後者では式がサポートされています。
宛先
[コピー先] タブに移動して、コピー アクティビティのコピー先を構成します。 詳細な構成については、次の内容を参照してください。
次の 3 つのプロパティが必要です。
- [データ ストアの種類]: [外部] を選択します。
- [接続]: 接続リストから Azure Table Storage の接続を選択します。 接続が存在しない場合は、[新規] を選択して新しい Azure Table Storage 接続を作成します。
- [テーブル]: Azure Table Storage データベース インスタンス内のテーブルの名前を指定します。 ドロップダウン リストからテーブルを選択するか、[編集] を選択して手動で名前を入力します。
[詳細設定] では、次のフィールドを指定できます。
[型の挿入]: Azure Table にデータを挿入するモードを選択します。 モードは [マージ] と [置換] です。 このプロパティは、一致するパーティションと列キーを持つ出力テーブル内の既存の行で、値を置換するか結合するかを制御します。 この設定は、テーブル レベルではなく、行レベルで適用されます。 どちらを選択しても、出力テーブルにおいて、入力に存在しない行は削除されません。 結合と置換の設定の機能については、「Insert or Merge Entity (エンティティの挿入または結合)」および「Insert or Replace Entity (エンティティの挿入または置換)」をご覧ください。
[パーティション キー値の選択]: [パーティション値の指定] または [移行先の列を使用する] から選択します。 パーティション キーの値は固定値にすることも、移行先の列から値を取得することもできます。
[パーティション値の指定] を選択した場合:
- [既定のパーティション値]: 移行先で使用できる既定のパーティション キーの値を指定します。
[移行先の列を使用する] を選択した場合:
- [パーティション キー列]: 列の値がパーティション キーとして使用される列の名前を選択します。 指定しない場合、AzureTableDefaultPartitionKeyValue がパーティション キーとして使用されます。
[行キー値の選択]: [一意識別子] または [移行先の列を使用する] から選択します。 行キーの値は、自動生成された一意識別子にすることも、移行先の列から値を取得することもできます。
[移行先の列を使用する] を選択した場合:
- [行キー列]: 列の値が行キーとして使用される列の名前を選択します。 指定しない場合、各行に GUID を使用します。
[書き込みバッチ サイズ]: 指定した書き込みバッチ サイズに達すると、Azure Table にデータを挿入します。 使用可能な値: 整数 (行数)。 既定値は 10,000 です。
[書き込みバッチ タイムアウト]: 指定した書き込みバッチ タイムアウトに達すると、Azure Table にデータを挿入します。 使用可能な値は timespan です。
[最大コンカレント接続数]: アクティビティの実行中にデータ ストアに対して確立されるコンカレント接続数の上限。 コンカレント接続数を制限する場合にのみ、値を指定します。
マッピング
[マッピング] タブの構成については、「[マッピング] タブでマッピングを構成する」をご覧ください。
設定
[設定] タブの構成については、「[設定] タブで他の設定を構成する」を参照してください。
表の概要
次の表には、Azure Table Storage のコピー アクティビティの詳細があります。
ソース情報
名前 | Description | Value | 必須 | JSON スクリプト プロパティ |
---|---|---|---|---|
データ ストアの種類 | データ ストアの種類。 | 外部品目番号 | はい | / |
接続 | ソース データ ストアへの実際の接続。 | < 実際の Azure Table Storage 接続 > | はい | つながり |
[クエリの使用] | データを読み取る方法。 特定のテーブルからデータを読み込むには [テーブル] を、クエリを使用してデータを読み込むには [クエリ] を選択します。 | • [テーブル] • クエリ |
はい | / |
テーブル | Azure Table Storage データベース インスタンスでのテーブルの名前。 | < 実際のテーブル名 > | はい | tableName |
クエリ | データを読み取るカスタム テーブル ストレージ クエリを指定します。 ソース クエリは、Azure Table Storage でサポートされている $filter クエリ オプションからの直接マップです。このアーティクルの構文について詳しく説明します。 |
< クエリ > | いいえ | azureTableSourceQuery |
見つからないテーブルを無視する | テーブルが存在しないという例外を受け入れるかどうかを示します。 | 選択または非選択 (既定値) | いいえ | azureTableSourceIgnoreTableNotFound: true または false (既定値) |
追加の列 | ソース ファイルの相対パスまたは静的値を格納するための追加のデータ列を追加します。 後者では式がサポートされています。 | • 名前 • 値 |
いいえ | additionalColumns: • name • value |
コピー先の情報
名前 | Description | Value | 必須 | JSON スクリプト プロパティ |
---|---|---|---|---|
データ ストアの種類 | データ ストアの種類。 | 外部品目番号 | はい | / |
接続 | コピー先データ ストアへの接続。 | < 実際の Azure Table Storage 接続 > | はい | つながり |
テーブル | Azure Table Storage データベース インスタンスでのテーブルの名前。 | < 実際のテーブル名 > | はい | tableName |
型の挿入 | Azure Table にデータを挿入する方法です。 このプロパティは、一致するパーティションと列キーを持つ出力テーブル内の既存の行で、値を置換するか結合するかを制御します。 | • マージ • 置換 |
いいえ | azureTableInsertType: • マージ • 置換 |
パーティション キー値の選択 | パーティション キーの値は固定値にすることも、移行先の列から値を取得することもできます。 | • パーティション値の指定 • 移行先列の使用 |
いいえ | / |
既定のパーティション値 | 移行先で使用できる既定のパーティション キー値 | < 実際の既定のパーティション値 > | いいえ | azureTableDefaultPartitionKeyValue |
パーティション キー列 | 値がパーティション キーとして使用される列の名前。 指定しない場合、AzureTableDefaultPartitionKeyValue がパーティション キーとして使用されます。 | < 実際のパーティション キー列 > | いいえ | azureTablePartitionKeyName |
行キー値の選択 | 行キーの値は、自動生成された一意識別子にすることも、移行先の列から値を取得することもできます。 | • 一意識別子 • 移行先列の使用 |
いいえ | / |
行キー列 | 列の値が行キーとして使用される列の名前。 指定しない場合、各行に GUID を使用します。 | < 実際の行キー列 > | いいえ | azureTableRowKeyName |
[Write batch size](書き込みバッチ サイズ) | 書き込みバッチ サイズに達すると Azure Table にデータを挿入します。 | 整数 (既定値は 10,000) |
いいえ | writeBatchSize |
[書き込みバッチ タイムアウト] | 書き込みバッチ タイムアウトに達すると Azure Table にデータを挿入します。 | TimeSpan | いいえ | writeBatchTimeout |
最大コンカレント接続数 | アクティビティの実行中にデータ ストアに対して確立されたコンカレント接続数の上限。 コンカレント接続を制限する場合にのみ、値を指定します。 | < 実際の最大コンカレント接続数 > | いいえ | maxConcurrentConnections |