データ・フローについて

データ・フローは、次のいずれかの方法で作成できます:

• 「プロジェクト」ページから
• プロジェクト内の「データ・フロー」ページから
• ホーム・ページから

新しく作成されたデータ・フローが、関連付けられたプロジェクトの「データ・フロー」ページに表示されます。選択したデータ・フローの横にある「アクション」アイコン()をクリックして、編集、名前変更、コピー、フォルダの変更、開始、エクスポートまたは削除を行います。

「プロジェクト」ページから

「プロジェクト」ページからデータ・フローを作成するには、

1. プロジェクト・ページで、「データ・フローの作成」をクリックします。

   「データ・フローの作成」ページが表示されます:

2. 「名前」フィールドに、新しいデータ・フローの名前を入力します。
3. 新しく作成したデータ・フローに新しいプロジェクト・フォルダを作成する場合は、「新規プロジェクトの作成」を選択します。
4. あるいは、新しく作成したデータ・フローを既存プロジェクト・フォルダを追加する場合は、「既存プロジェクトに追加」をクリックします。
5. 前のオプションで「新規プロジェクトの作成」を選択した場合は、「プロジェクト名」フィールドに、新しく作成したプロジェクトの名前を入力します。
6. あるいは、前のオプションで「既存プロジェクトに追加」を選択した場合は、「プロジェクト名」ドロップダウンの矢印から必要なプロジェクトを選択してください。
7. 「説明」フィールドに、新しく作成したデータ・フローの摘要を入力します。
8. 「作成」をクリックします。

プロジェクト内の「データ・フロー」ページから

プロジェクト内の「データ・フロー」ページからデータ・フローを作成するには、

1. 「プロジェクト」ページで、新しいデータ・フローを作成するプロジェクト・タイルをクリックします。「プロジェクト詳細」ページが表示されます。
2. 「データ・フロー」ページで、「データ・フローの作成」をクリックします。
3. 新しいデータ・フローに「名前」および「説明」を指定します。
4. 「次へ」をクリックします。
5. ソース接続を定義するには、「接続」ドロップダウンから、データ・エンティティの追加先となる必要な接続を選択してください。
6. 「スキーマ」ドロップダウンに、選択した接続に対応するすべてのスキーマが2つのグループで表示されます:
   • 既存のスキーマ(Oracle Data Transformsにインポートしたスキーマ)および
   • 新規データベース・スキーマ(まだインポートしていないスキーマ)。

   使用するスキーマをドロップダウンから選択します。Oracle Object Storage接続の場合、「スキーマ」ドロップダウンには、接続の作成時にURLで指定したバケットの名前がリストされます。

7. 「保存」をクリックします。

   新しいデータ・フローを作成できるデータ・フロー・エディタが表示されます。

ホーム・ページから

「ホーム」ページからデータ・フローを作成するには、

1. ホーム・ページで、「データの変換」をクリックします。「データ・フローの作成」ページが表示されます。
2. 新しいデータ・フローに「名前」および「説明」を指定します。
3. ドロップダウンからプロジェクト名を選択します。または、「+」アイコンをクリックしてプロジェクトを作成します。
4. 「次へ」をクリックします。
5. 「接続」ドロップダウンから、データ・エンティティの追加元となる必要な接続を選択します。または、「+」アイコンをクリックして新しい接続を作成します。
6. 「スキーマ」ドロップダウンに、選択した接続に対応するすべてのスキーマが2つのグループで表示されます:
   • 既存のスキーマ(Oracle Data Transformsにインポートしたスキーマ)および
   • 新規データベース・スキーマ(まだインポートしていないスキーマ)。

   使用するスキーマをドロップダウンから選択します。

7. 「保存」をクリックします。

1. 「データ・エンティティ」パネルでは、「スキーマの追加」をクリックして、データ・フローで使用するデータベース・エンティティを含むスキーマを追加します。
2. 「スキーマの追加」ページで、接続とスキーマ名を選択します。
3. 「インポート」をクリックします。
4. 「データ・エンティティのインポート」ページで、インポートするオブジェクトのタイプを選択します。スキーマ内のすべてのオブジェクトをインポートしない場合は、マスク/フィルタを選択し、「開始」をクリックします。
5. 「データ・エンティティ」パネルに、インポートされたデータ・エンティティがリストされます。このパネルには、次を実行できる様々なオプションがあります:
   • データ・エンティティのリフレッシュ- 「リフレッシュ」アイコンをクリックして、表示されたリストをリフレッシュします。
   • 名前 - 名前でデータ・エンティティを検索します。
   • タグ - 使用されるタグの名前によってデータ・エンティティがフィルタされます。
   • データ・エンティティのインポート - このオプションを表示するには、スキーマを右クリックします。このオプションを使用して、データ・エンティティをインポートします。
   • スキーマの削除 - データ・エンティティを右クリックすると、このオプションが表示されます。このオプションを使用して、リストからスキーマを削除します。このオプションではスキーマは削除されず、スキーマとこのデータ・フローとの関連付けのみが削除されることに注意してください。
6. 同様に、必要に応じて、データ・フローにスキーマを追加します。
7. データ・フローで使用する必要なデータ・エンティティをドラッグして、デザイン・キャンバス上にドロップします。
8. 「データベース関数」ツールバーで、データ・フローで使用する変換コンポーネントをドラッグして、デザイン・キャンバスにドロップします。データ・フローで変数を使用できます。詳細は、「データ・フローでの変数の使用」を参照してください。
9. デザイン・キャンバスのオブジェクトを選択し、横にある「コネクタ」アイコン()をドラッグして、コンポーネントを接続します。
10. データ・フローを保存すると、1つ以上のコンポーネント接続に転送アイコンが重ねて表示される場合があります。これは、ODIによって追加ステップが検出され、データ・サーバー間でデータの移動が必要であることを示しています。このアイコンをクリックすると、そのステップに関連付けられたプロパティを表示できます。

例

次の例は、SQL文で集計コンポーネントを使用してデータ・フローを生成する方法を示しています。

create table DEMO_TARGET.SUB_QUANTITY
(
  QUANTITY_SOLD NUMBER(10,2),
PROD_SUBCATEGORY VARCHAR2(50 CHAR)
)

INSERT 
  /*+  APPEND PARALLEL  */ 
  INTO DEMO_TARGET.SUB_QUANTITY
  (
    QUANTITY_SOLD ,
    PROD_SUBCATEGORY 
  ) 
SELECT 
  (SUM(SALES.QUANTITY_SOLD)) ,
  PRODUCTS.PROD_SUBCATEGORY  
FROM 
  SH.SALES SALES  INNER JOIN  SH.PRODUCTS PRODUCTS  
    ON  SALES.PROD_ID=PRODUCTS.PROD_ID
GROUP BY
  PRODUCTS.PROD_SUBCATEGORY  

生成されたデータ・フローは次のようになります。

データ・フロー・エディタでマテリアライズド・ビュー・データ・エンティティを使用するには、

1. マテリアライズド・ビューを作成するデータ・エンティティをデザイン・キャンバスにドラッグします。
2. コンポーネントを選択し、コンポーネントの右上隅にある「データ・エンティティの追加」アイコンをクリックします。
3. 「データ・エンティティの追加」ページが表示され、ターゲット・コンポーネントの次の詳細を構成できます:

   「一般」タブ

   • 「名前」テキスト・ボックスに、新規に作成したデータ・エンティティの名前を入力します。
   • 「エンティティ・タイプ」ドロップダウンから、データ・エンティティ・タイプとして「マテリアライズド・ビュー」を選択します。

     このエンティティ・タイプを選択すると、「接続タイプ」ドロップダウンにはオプションとして「Oracle」のみがリストされ、「接続」ドロップダウンにはソース・データ・エンティティと同じ接続が移入されます。どちらのオプションもグレー表示されます。

   • 「スキーマ」ドロップダウンで、選択した接続に対応するすべてのスキーマが2つのグループで表示されます。
     • 「新規データベース・スキーマ」(以前にインポートしたことがないもの)と、
     • 既存のデータベース・スキーマ(以前にインポートされて、データ・エンティティを置換する可能性があるもの)です。
     「スキーマ」ドロップダウンで、必要なスキーマを選択します。
   • 「タグ」テキスト・ボックスに、希望するタグを入力します。タグを使用して、「データ・エンティティ」ページに表示されるデータ・エンティティをフィルタできます。
   • このデータ・エンティティを機能グループとしてマークする場合は、「拡張オプション」を展開し、「機能グループとして処理」チェック・ボックスをクリックします。
   • 「次へ」をクリックします。

   「列」タブ

   • 新しく作成したデータ・エンティティに新しい列を追加するには、「列の追加」アイコンをクリックします。

     表示されている表に新しい列が追加されます。

   • この表には次の列が表示されます:
     • 名前
     • データ型 - セルをクリックして、必要なデータ型を構成します。
     • スケール
     • 長さ
     • アクション - 作成した列を削除するには、クロス・アイコンをクリックします。
   • 列を一括で削除するには、列を選択して「削除」アイコンをクリックします。
   • 必要な列詳細を検索するには、「検索」テキスト・ボックスに必要な列名を入力し、[Enter]を押します。必要な列の詳細が表示されます。
   • 「次へ」をクリックします。

   「データ・エンティティのプレビュー」タブ

   このタブには、作成したすべての列とその構成済の詳細のプレビューが表示されます。

4. 「保存」をクリックして構成を保存し、ウィザードを終了します。マテリアライズド・ビュー・データ・エンティティは、デザイン・キャンバスでコンポーネントとして追加されます。
5. マテリアライズド・ビュー・データ・エンティティをクリックし、右側の「プロパティ」ペインで「オプション」()をクリックします。

   次のオプションを設定して、リフレッシュ設定を定義します。

   • マテリアライズド・ビューの再作成: このオプションを使用すると、既存のマテリアライズド・ビューを削除し、定義が変更された場合に新しいマテリアライズド・ビューを作成できます。更新されたデータ・フローからの問合せと一致するようにマテリアライズド・ビューを再作成するには、これをtrueに設定します。これを実行する必要があるのは1回のみです。デフォルト値はfalseです。
   • リフレッシュ: このオプションを使用すると、増分リフレッシュをPRIMARY KEYまたは内部ROWIDのどちらを使用して実行するかを指定できます。デフォルト値はROWIDです。
6. データ・フローを保存して実行します。データ・フローの詳細ページの左パネルには、データ・フローのソース・コンポーネントとして使用できるマテリアライズド・ビューのデータ・エンティティがリストされます。
7. マテリアライズド・ビューのデータ・エンティティをデザイン・キャンバスにドラッグ・アンド・ドロップします。データ・フローで使用する必要なデータ・エンティティをドラッグして、デザイン・キャンバス上にドロップします。
8. データ・フローを保存して実行します。データ・フローの実行時に、マテリアライズド・ビューは構成済の設定に従ってリフレッシュされます。

位置または名前に基づいて列をマップするには:

1. ターゲット・データ・エンティティを選択します。
2. 右上隅にある矢印アイコンをクリックして、プロパティ・パネルを展開します。これにより、作業領域が広がります。
3. プロパティ・パネルで、「列マッピング」アイコン()をクリックします。
4. 位置または名前で列をマップするには、「自動マップ」ドロップダウン・メニューから「位置別」または「名前別」を選択します。

手動で列をマップするには:

1. 「自動マップ」ドロップダウン・メニューから「クリア」を選択して、既存のマッピングをクリアします。
2. 左側のツリーから、「式」列でマップする属性をドラッグ・アンド・ドロップします。
3. 式を編集するには、各列の「編集」アイコンをクリックします。式エディタが表示され、必要な変更を行うことができます(たとえば、単に式"UPPER"を追加したり、式エディタを開いて式を編集したりできます)。
   ノート
   
   式エディタは、特定の列に複雑な式が含まれる場合にのみ使用してください。
4. 「OK」をクリックします。

1. 「保存」をクリックします。

   保存後、変換前にデータをステージングする必要がある場合、転送ボタンが1つ以上のリンクに追加されます。これらのボタンをクリックして、別のオプションを設定できます(使用可能な場合)。

2. データ・フロー・ジョブ実行時に実行されるタスクを完了するために実行するコードを確認する場合は、コードのシミュレート・アイコン()をクリックします。参照しやすいように、ソースとターゲットの詳細は異なる色で表示されます。これは、ジョブを実行する前にマッピングが正しいかどうかを確認する場合、またはジョブが失敗した場合に便利です。コードはデバッグに使用できないことに注意してください。ジョブの詳細は、「ジョブの詳細」ページを参照してください。
3. デザイン・キャンバスの上にあるツールバーの「検証」アイコン()をクリックして、データ・フローを検証します。
4. 検証に成功したら、「検証」アイコンの横にある「実行」アイコン()をクリックして、データ・フローを実行します。

   データ・フローに変数を追加した場合は、データ・フローに追加した変数のリストを表示する「変数値」ページが表示されます。現在の値、デフォルト値を使用するか、変数ごとにカスタム値を設定するかを選択できます。カスタム値は、データ・フローの現在の実行にのみ適用されます。カスタム値は後続のセッションでは保持されません。

   実行ジョブのIDおよび名前を示すメッセージが表示されます。データ・フローのステータスを確認するには、「プロパティ」パネルのすぐ下にある「ステータス」パネルを参照してください。「ステータス」パネルの詳細は、「データ・ロード、データ・フローおよびワークフローのステータスのモニター」を参照してください。このパネルには、「ジョブ」ページで進行状況をモニターするためにクリックできるジョブIDへのリンクも表示されます。詳細は、ジョブの作成および管理を参照してください。

   Oracle Object Storage接続を使用して作成されたデータ・フローの場合、ソースCSVファイルのデータはターゲットOracle Autonomous Databaseにロードされます。Oracle Autonomous Database表のデータをOracle Object StorageのCSVファイルにエクスポートすることもできます。