＜目次＞
Azure Synapse AnalyticsのパイプラインからREST APIを呼び出す方法
やりたいこと／概要
STEP0：前提
STEP1：事前準備
STEP2：パイプラインの作成
STEP3：データフローキャンバスでの変換ロジック作成
STEP4：データフローの実行とモニタリング
【注意】Azure Synapse Analyticsの料金について
Azure Synapse AnalyticsのパイプラインからREST APIを呼び出す方法
やりたいこと／概要
●やりたいこと
・Azure Synapse AnalyticsのパイプラインからREST APIを呼び出す
・REST APIから取得したデータを加工処理する
●概要
パイプライン
STEP1：事前準備
・①Synapse Studioを開く
（図１１１）
＜備考＞
Azure Synapse Analyticsのリソース未作成の方は下記を参照。
・②テストデータのダウンロード
下記をテキストに貼り付けてcsv形式でローカルに保存。
https://raw.githubusercontent.com/djpmsft/adf-ready-demo/master/moviesDB.csv
（図１１２）
・③ダウンロードしたファイルをAzure Storageのコンテナ（sample-data）にアップロード
（図１１３①②③）
↓
↓
STEP2：パイプラインの作成
・①左メニューで「結合」→「＋」→「パイプライン」
（図１２１）
↓
・②「アクティビティ」ペインの「移動と変換」で「データフロー」を中央キャンバスにドラッグ＆ドロップ
（図１２２）
↓
・③「データフローアクティビティ」名前を付ける（例：TransformMovies）
（図１２３）
↓
・④「設定」→「＋新規」を選択
（図１２４）
↓
・⑤「データフロー」の名前を付ける（例：TransformMoviesDataFlow）
（図１２５）
STEP3：データフローキャンバスでの変換ロジック作成
Data Flow を作成すると、データ フロー キャンバスが自動的に表示されます。 この手順では、ADLS ストレージ内の MoviesDB.csv を取得し、1910 年から 2000 年までのコメディの平均評価を集計するデータ フローを作成します。 次に、このファイルを ADLS ストレージに書き戻します。
STEP3-1：「データフローのデバッグ」をONにする
・変換ロジックの対話的なテストが行える
（図２１１）
（図２１２）
STEP3-2：データソースの追加
・①「ソースの追加」
（図２１３①②）
↓
・②「＋New」で「データソース」を新規作成
（図２１４）
↓
・③「Azure Data Lake Storage Gen2」→「DelimitedText」を選択
（図２１５①②）
↓
↓
・④データ（例：moviesDB.csv）が格納されているストレージの情報を設定してOK
（図２１６）
↓
・④データ（例：moviesDB.csv）が格納されているストレージの情報を設定してOK
（図２１６）
↓
・⑤データのプレビューが表示された
（図２１７）
STEP3-3：フィルター
・①「＋」→「フィルター」を押下
（図２２１）
↓
・②「フィルターオン」項目右側の「ANY」押下
（図２２２）
↓
・③式を入力
抽出条件：1910年と2000年の間のコメディ映画を抽出
式：toInteger(year) >= 1910 && toInteger(year) <= 2000
（図２２３）
↓
・④式が入力された
（図２２４）
↓
・⑤デバッグがONなら「最新の情報に更新」で指定の期間にフィルターされる
（図２２５）
STEP3-4：「集約」の設定
・①「＋」→「集約」を押下
（図２３１）
↓
・②集計の設定
（図２３２①②）
↓
↓
・③式を入力→「保存して終了」
avg(toInteger(Rating))
（図２３３）
↓
・④年度毎の評価の平均点が算出できた
（図２３４）
STEP3-5：「シンク」の設定
目的地（ターゲットデータソース）に同期する。
・①「＋」→「シンク」
（図２４１）
↓
・②「データセット」→「＋新規」
（図２４２）
↓
・③「Azure Data Lake Storage Gen2」→「Delimited Text」
（図２４３①②）
↓
・④出力条件の設定
（図２４４）
STEP4：データフローの実行とモニタリング
・①「デバッグ」
（図３１１）
↓
・②出力タブで状況チェック（処理中→成功）
（図３１２①②）
↓
↓
・③「眼鏡マーク」から詳細に飛びます。
（図３１３①②）
↓
【注意】Azure Synapse Analyticsの料金について
非常に強力な分、料金も他のAzureサービスと比較すると高いので、注意が必要。
