メインコンテンツまでスキップ
に最終更新

チュートリアル: ビジュアルデータ準備を作成する

このチュートリアルでは、Lakeflow Designer でビジュアルデータ準備を作成します。これにより、「どのタイプのバケーションレンタル物件が確定予約から最も収益を得ているか？」というビジネス上の問いに答えます。Wanderbricks サンプルデータセットを使用します。これは、すべての Unity Catalog 有効化ワークスペースにプリロードされているシミュレートされた旅行予約プラットフォームです。

次の方法を学習します。

  • データソースをキャンバスに追加します。
  • 組み込み演算子でデータのフィルタリング、結合、集計、ソートを行います。
  • 各ステップの結果を出力ペインで確認します。
  • 結果をUnity Catalogテーブルに書き込みます。

前提条件​

  • Unity Catalog が有効になっている Databricks ワークスペース。
  • CAN USE 少なくとも 1 つの汎用コンピュート リソース (サーバレスまたは汎用) に対する許可。
  • USE CATALOG、 USE SCHEMAおよびCREATE TABLEの権限（main.defaultなど）を出力テーブルに書き込めるスキーマに対して。

ステップ1: ビジュアルデータ準備を作成する​

  1. サイドバーのプラスアイコン。 新規 をクリックし、 ビジュアルデータの準備 を選択します。Designerが開き、ウェルカム画面が表示されます。
  2. エディター上部のファイル名をクリックし、ファイル名を Wanderbricks revenue に変更してください。
  3. スケジュール ボタンの横にあるコンピュートピッカーで、使用するコンピュートを選択します。

ステップ 2: 予約データを追加する​

すべてのビジュアルデータ準備は1つ以上のデータソースから起動し、 ソース 演算子がキャンバスに表示されます。

  1. ようこそ画面で、 ソース演算子を選択 をクリックします。
  2. ソース 構成ペインで、 samples.wanderbricks.bookings を検索してテーブルを選択します。テーブルの「ソース」演算子がキャンバスに表示されます。
  3. 「ソース」演算子を選択します。エディターの下部にある出力ペインには、property_id、total_amount、statusの各列を含む予約データのプレビューが表示されます。

カタログ ペインからキャンバスにテーブルをドラッグして、ソースとして追加することもできます。データを取得する他の方法については、 Lakeflow Designer へのデータの取り込み」を参照してください。

ステップ 3: 確定済みの予約のみを保持する​

  1. bookingsソース演算子の上にカーソルを置き、その横にあるプラスアイコン。ボタンをクリックします。 [フィルタ] を選択します。新しいフィルタ演算子はすでにソースに接続されています。
  2. フィルター構成ペインで、条件を追加します。status列を選択し、 次の値と等しい を選択して、confirmedを入力します。
  3. [適用] をクリックします。
  4. フィルター演算子を選択し、出力ペインを確認します。「 Included 」出力には、確定した予約のみが含まれます。

フィルター演算子には2つの出力があります。 対象 には条件を満たす行が含まれ、 対象外 にはそれ以外の行が含まれます。「フィルター」を参照してください。

ステップ 4: 予約とプロパティを結合する​

各予約にはproperty_idがあります。物件タイプで予約をグループ化するには、それらをpropertiesテーブルに結合します。

  1. samples.wanderbricks.propertiesに2つ目のソースオペレーターを追加します。 オペレーター ペインで ソース をクリックし、テーブルを検索して選択します。
  2. オペレーター ペインで、 結合 をクリックして結合オペレーターを追加します。
  3. Filter演算子の Included 出力をJoin演算子の最初の入力に接続します。次に、propertiesソース演算子をJoin演算子の2番目の入力に接続します。2つの演算子を接続するには、出力ポートから入力ポートにドラッグします。
  4. 結合構成ペインで、両方のテーブルの property_id に一致するように結合条件を設定します。
  5. 結合タイプ で Inner join を選択すると、結合された単一の出力が生成されます。
  6. 適用 をクリックし、結合演算子を選択して結合された行をプレビューします。

演算子の接続の詳細については、「演算子の接続」を参照してください。

ステップ5:プロパティタイプ別に収益を集計する​

  1. 結合演算子の横にあるプラスアイコン。ボタンをクリックし、 集計 を選択します。

  2. [集計条件] で、次の2つの集計を追加します。

    • total_amountを選択し、SUMを選択して、出力列にtotal_revenueという名前を付けます。
    • + 集計の追加 をクリックします。booking_idを選択し、COUNTを選択して、出力列にbooking_countという名前を付けます。

  3. グループ化 の下で property_typeを選択します。

  4. [適用] をクリックします。

ステップ6:結果をソートする​

  1. Aggregate演算子の横にあるプラスアイコン。ボタンをクリックして、 [並べ替え] を選択します。
  2. total_revenue と DESC を選択し、 [適用] をクリックします。

ステップ 7: 結果を確認する​

「ソート」演算子を選択します。出力ペインには、プロパティタイプごとに 1 行が示され、収益の最も高いタイプが先頭に表示されます。

defaultでは、プレビューは入力行のサンプルを処理するため、合計はサンプルの内容のみを反映します。フルデータセットの合計を表示するには、ツールバーの [すべてラン] をクリックします。フルデータセットでは、結果は4つのプロパティタイプを示しており、 Urban Year-Round が最も高い収益を上げています。列の分布を検査するには、列を選択してデータプロファイリングを開きます。Lakeflow Designer での結果のプレビューと調整を参照してください。

ステップ8: 結果をテーブルに書き込む​

  1. [ソート] オペレーターの横にある プラスアイコン。 ボタンをクリックし、 [出力] を選択します。
  2. 「出力設定」ペインの「 出力タイプ 」で「 テーブル 」を選択します。
  3. テーブル名 に wanderbricks_revenue_by_property_type を入力し、 出力場所 のカタログとスキーマ（main.default など）を選択します。
  4. 書き込みモード は 上書き に設定したままにします。
  5. ラン をクリックします。Designerはビジュアルデータ準備をランし、テーブルを作成します。

完成したビジュアルデータ準備は、2つのテーブルを読み取り、それらをフィルタリングして結合し、プロパティタイプごとの収益を合計して、その結果を Unity Catalogに書き込みます。

オプション: Genie Code で試す​

作成したい内容を説明することで、ビジュアルデータの準備も作成できます。新しいビジュアルデータの準備では、キャンバス上部にあるGenie Codeプロンプトを使用します。

プロンプト

Genie Code にこれを行うように伝えます:

Using samples.wanderbricks.bookings and samples.wanderbricks.properties, show total revenue and booking count by property type for confirmed bookings, highest revenue first.

Genie Codeが演算子を追加して接続します。各演算子を選択して、その設定と結果を確認します。Lakeflow DesignerでGenie Codeを使用する」を参照してください。

次のステップ​

このページの見出し