コンテンツにスキップ

プロジェクトテーブルをテンプレートに通してレンダリングし、ほかのエクスポートステップが書き込む生の列ダンプではなく、構造化されたドキュメントを生成します。受け取り側のシステムが、テーブルではなく、特定のXML形式やその他のテキスト形式を必要とする場合に使用します。

出力のレンダリング元となるJinjaテンプレートです。テンプレートで使用できるものを参照してください。

レンダリング結果を書き込むドキュメントアカウント、フォルダー、ファイル名です。ファイルの内容はテンプレートによって決まります。拡張子のないファイル名には .xml が付きます。

テーブルデータにPandas DataFrameを使用は、各ソースの行がテンプレートに渡される方法を変更します。テーブルとしてのソース行を参照してください。

テーブルを明示的に指定するか、パスと検索ルール(完全一致、前方一致、後方一致、部分一致、glob)で照合します。

テンプレートで使用できるもの

Section titled “テンプレートで使用できるもの”

テンプレートはサンドボックス内でレンダリングされます。ステップが渡すデータのみを読み取り、それ以外は読み取れません。

  • 各ソースは、その名前(Name)で参照します。 一覧に追加した各ソーステーブルは、指定した名前でテンプレートから利用できます。そのため、invoices のように、変数として使える名前を付けてください。
  • ワークフローの変数は variable として利用できます。たとえば {{ variable.region }} です。
<Invoices>
{% for row in invoices %}
<Invoice id="{{ row.invoice_id }}" amount="{{ row.amount }}" />
{% endfor %}
</Invoices>

テーブルデータにPandas DataFrameを使用がオフの場合、ソースは行の読み取り専用リストになります。ループで処理するか、|length、keys()、first()、one()、all()、scalar()、scalars()、mappings()、fetchmany(n)、columns('a', 'b') を使用します。行の値は row.amount、row['amount']、row[0] として読み取ります。row._mapping、row._asdict()、row._fields も使用できます。columns('a', 'b') から得られる行では、row.amount または row[0] を使用し、row['amount'] は使用できません。

テーブルデータにPandas DataFrameを使用がオンの場合、ソースは読み取り専用のテーブルになります。ループで処理すると、各行が辞書として得られるため、row.amount と row['amount'] の両方が使用できます。次のものも使用できます。

  • columns、empty、shape、values、index
  • head(n) と tail(n)
  • itertuples()。行の位置を Index として先頭に置くため、r[1] が最初の列になります。itertuples(index=False) では、これが省かれます
  • iterrows()。行の位置と行を返します
  • invoices['amount']。1つの列の値で、sum()、min()、max()、mean()、unique()、tolist() と併用できます。sum、min、max、mean はNULLをスキップします

loc や groupby など、そのほかのpandasのメソッドは使用できません。データの整形は前のステップで行い、その結果をエクスポートしてください。

  • 名前が to_ で始まるメソッドを、任意の値に対して呼び出すこと。to_csv や to_json のほか、to_pydatetime のような無害なものも含まれます。
  • 名前がアンダースコアで始まる属性を読み取ること。ただし、行の _mapping、_asdict、_fields は除きます。
  • ファイルを書き込む、または開くこと。

to_ の呼び出しやファイル操作は、ステップを失敗させます。この3つ以外のアンダースコア属性は、何も表示されません。

データマッパーの設定

Table Data Mapper

データマッパーは、ソースデータの列をターゲットのデータテーブルにマッピングするために使用します。

マッパーの検査と入力

ソースを検査メニューボタンを使うと、ソースからターゲットへ列をマッピングする方法が増えます。

  • 両方のマッピングテーブルを入力: ソースデータテーブルのすべての値をターゲットのデータテーブルに反映します。これがデフォルトです。
  • ソースマッピングテーブルのみを入力: ソースデータテーブルのすべての値のみをマッピングします。ソース列の構成が変わった既存のワークフローを修正する際に便利です。
  • ターゲットマッピングテーブルのみを入力: すべての値をターゲットのデータテーブルのみに反映します。

ソース列とターゲット列のオプションだけでは足りない場合は、次のようにいくつかの方法でターゲットのデータテーブルに列を追加できます。

  • すべてを反映は、すでに存在しているかどうかにかかわらず、すべてのソース列をターゲットのデータテーブルに挿入します。
  • 選択を反映は、選択したソース列のみを挿入します。
  • ターゲット側を右クリックして行を挿入を選択すると、現在選択している行の直上に行を挿入します。
  • ターゲット側を右クリックして行を追加を選択すると、ターゲットのデータテーブルの末尾(右端)に行を挿入します。

列の削除

ターゲットのデータテーブルから列を削除するには、対象の列を選択し、右クリックして削除を選択します。

一覧になくなったソース列

ターゲットの行がソース列として指定している列が、ソースデータテーブルの一覧にない場合があります。たとえば、ソースを再度検査した後などです。ステップがそのような行を自動的に削除することはありません。代わりに、列名が警告マーク ⚠ の後ろに赤色で表示され、その上にカーソルを置くと、その列がソース列にないことが示されます。ユニオンなど複数のテーブルを扱うステップでは、各テーブルがそれぞれのソース列に対してチェックされます。

定数、式、または件数 (NULLを含む) の集計を設定した行は、ステップがそのソース列を読み取らないため、フラグが付くことはありません。ソースデータテーブルに列が一覧表示されていない間(たとえば、ソースを初めて検査する前)は、何もフラグが付きません。

フラグが付いた行が残ったままステップを保存すると、古い列が見つかりましたダイアログに、該当する行が所属するタブまたはテーブルごとに表示され、次の3つの選択肢が提示されます。

  • すべて削除して保存 — フラグが付いた行を削除してから保存します。
  • このまま保存 — ステップをそのまま保存します。
  • キャンセル — 保存せずにステップに戻ります。

行を残したまま警告を解除するには、その列をソースデータテーブルに追加し直すか、ソースデータテーブルに一覧表示されている列を選択します。

ソーステーブルに存在しない列

保存時には、ソースデータテーブル自体の現在の状態が確認されます。ステップのソース列に一覧表示されている列がテーブルに存在しない場合(たとえば、前のステップで名前が変更されたか削除された列)、ステップの列が古くなっていることを意味し、そのような列を読み取るステップは実行時に失敗します。その場合、保存すると不足しているソース列ダイアログが開き、各テーブルと、そのテーブルにない列が表示されます。選択肢は次の2つです。

  • このまま保存 — ステップをそのまま保存します。
  • キャンセル — 保存せずにステップに戻ります。

テーブル側が誤っている可能性があり、ステップの実行前に再び変わる可能性もあるため、自動的に削除されるものはありません。行が一覧に含まれなくなったものとしてフラグ付けされている場合は、両方が古い列が見つかりましたダイアログにまとめて表示され、すべて削除して保存ではフラグ付けされた行のみが削除されます。ソース列のリストが空の間は、代わりにステップがマッピングする列が確認されます。ただし、定数、式、または件数 (NULLを含む) の集計を持つ行は、どの列も読み取らないため対象外です。

{year}/Sales のように変数で指定されたソースは、保存時点の変数の値で確認され、ダイアログには 2026/Sales (from {year}/Sales) のように確認したテーブルが表示されます。ループが設定する変数には最後の反復の値が入っているため、形状の異なるテーブルをループ処理する場合、次の実行では読み取られないテーブルについて警告が表示されることがあります。まだ存在しないテーブル(たとえば、ワークフロー内の前のステップが作成するテーブル)は確認されません。値のない変数で指定されたソース、実行時にステップが検索して見つけるテーブル、現時点で読み取れないテーブルも同様です。

列のデータ型

ターゲットの各列にはタイプがあります。ソースから反映した列はソース列のタイプを引き継ぎます。手動で追加した行はテキストから始まるため、実際に必要なタイプをタイプで設定します。合計や並べ替えを行う列には数値型や日付型が必要です。テキストはテキストとして並べ替えられ、合計されるためです。

タイプがまったく設定されていない列を含んだままステップを保存しても、ステップは実行されます。タイプは、ステップの開始時に、その列が読み取るソース列から判定されます。読み取り元がない場合はテキストとして扱われます。たとえば、SQL抽出ステップの列は、マッピングされたソースではなく、記述したクエリから決まります。また、同じ列名でタイプが一致しないソースが複数ある場合は、いずれかを推測せずテキストが使われます。推測が外れるとウェアハウスが拒否する変換が生じる可能性がありますが、どんな値もテキストには変換できるためです。

列がどうあるべきかを指定する方法は、引き続きタイプを自分で設定することです。未設定のままにすると、ソース列がたまたまそうであるタイプをそのまま受け入れることになります。

列の順序の変更

ターゲットのデータテーブルの列を並べ替えるには、対象の列を選択します。次のどちらかを使用できます。

  • 一括移動の矢印: 右上の矢印から目的の移動オプションを選択します
  • コンテキストメニュー: 右クリックして、先頭へ移動、上へ移動、下へ移動、末尾へ移動のいずれかを選択します。

結果を重複のないレコードのみに絞り込む

重複のないオプションのみを返すには、重複排除メニューオプションを選択します。ソースの各列にチェックボックスが表示されます。重複を排除したい列の横にあるチェックボックスをオンにすると、重複のない結果のみが返されます。

状況によっては、代わりに集計の使用を検討することをお勧めします。

重複排除では、最初に見つかった一意のレコードを残し、残りを破棄します。実行間で一貫性が必要な場合は、データに並べ替えを適用することをお勧めします。

集計とグループ化

結果を集計するには、集計メニューオプションを選択します。ターゲットのデータテーブルの各列に選択ボックスが表示されます。列ごとに適切な集計方法を選択します。

ソースを検査で列が入力される際、数値列は、名前が id、customer_id、Order No、CustomerKey のように識別子と読み取れる場合、テーブルでキーに設定されている場合、または結合でキーとして使用されている場合に、合計ではなくグループ化から始まります。

  • グループ化
  • 合計
  • 最小
  • 最大
  • 最初
  • 最後
  • 件数
  • 件数 (NULLを含む)
  • 平均
  • 標準偏差
  • 標本標準偏差
  • 母標準偏差
  • 分散
  • 標本分散
  • 母分散
  • 高度な非グループ化

式、クレンジング、定数などのデータマッパーの高度な使い方については、データマッパーの高度な使い方を参照してください。

Table Data Filters

柔軟性を最大限に高めるため、データフィルターはソースデータとターゲットデータの両方で使用できます。データセットが大きい場合は、ソース側で行を絞り込んでおくと、残りの処理を小さなデータセットに対して実行できるため、特に効果的です。

データのサブセットを選択

このフィルタータイプでは、指定した条件に基づいて、受信するソースデータをフィルター処理できます。

結果データにセカンダリフィルターを適用

このフィルタータイプでは、変換後の結果データに対して、指定した条件に基づくフィルターを適用できます。 変換後の結果にフィルターを適用できるため、複雑な計算、集計、ウィンドウ関数の結果に基づいて行を除外できます。

最終データテーブルのスライス(制限)

行のスライス機能では、範囲と開始位置に基づいて、結果セットの行数を制限できます。

フィルター構文

フィルター構文には Python SQLAlchemy を使用します。これは他の式と同じ構文です。

式の例と式関数については、式のセクションを参照してください。