--- title: "データマート - Snowflake | TROCCO Docs" slug: "datamart-snowflake" updated: 2026-07-15T04:02:27Z published: 2026-07-15T04:02:27Z canonical: "documents.trocco.io/datamart-snowflake" --- > ## Documentation Index > Fetch the complete documentation index at: https://documents.trocco.io/llms.txt > Use this file to discover all available pages before exploring further. # データマート - Snowflake ## 概要 Snowflakeを用いたデータマート定義の設定のDocsです。 ## 書き込みモードについて TROCCOでは、SQLと出力先テーブルを指定するだけで、簡単にテーブルへの洗い替えや追記などの操作が可能です。 Snowflakeでは、テーブルへの書き込み方法を5つのモードから選択できます。 ### 書き込みモード：全件洗い替え (TRUNCATE INSERT) 既存のテーブルのレコードをすべて置き換えるモードです。 既存テーブルのレコードを`TRUNCATE`した後、クエリ実行結果を`INSERT`します。テーブルオブジェクト自体は維持されます。 ### 書き込みモード：全件洗い替え（REPLACE） 既存のテーブルのレコードをすべて置き換えるモードです。 既存テーブルを`DROP`し、クエリ実行結果で作り直します。 TRUNCATE INSERTとREPLACEの違い Snowflakeでは、テーブルの作り直し方が異なる2つの全件洗い替えがあります。既存のレコードをすべて置き換える点は共通ですが、**既存テーブルのスキーマとSnowflakeのTime Travel履歴を維持できるかどうか**が異なります。 | モード | スキーマ | Time Travel履歴 | | --- | --- | --- | | **全件洗い替え (TRUNCATE INSERT)** | 既存のスキーマ維持 | 維持 | | **全件洗い替え (REPLACE)** | クエリ実行結果に基づいて再作成 | リセット | 用途に応じて、以下のように使い分けてください。 - 既存テーブルのスキーマやTime Travel履歴を維持したまま洗い替えたい場合は、**全件洗い替え (TRUNCATE INSERT)** を選択します。 - クエリ実行結果に合わせて、スキーマごとテーブルを作り直したい場合は、**全件洗い替え (REPLACE)** を選択します。 ### 書き込みモード：追記 既存のテーブルのレコードの後に、クエリ実行結果が追記されます。 「全件洗い替え」とは異なりデータの追記のみ行うため、増分データ（新しいレコード）だけを追加するシンプルな運用に適しています。 既存データとの重複チェックや正確な履歴保持が必要な場合は、他の書き込みモード「増分更新」「SCD Type 2（履歴保持）」のご利用を検討ください。 ### 書き込みモード：増分更新 増分更新は、キーカラムに基づく既存のデータが存在した場合には`DELETE`してから`INSERT`を行う書き込みモードです。 日次・週次のセグメント・ユーザー別売上データなど、時系列ごとの統計値などを格納するテーブルを作成する処理に適しています。 ![増分更新モードの処理イメージ](https://cdn.document360.io/3a3bae1e-f157-487f-8798-01e9d820e760/Images/Documentation/datamart-bigquery-2026-02-16-09-18-19.png) ### 書き込みモード：SCD Type 2（履歴保持） SCD Type 2（Slowly Changing Dimension Type 2）モードは、履歴を保持しながらディメンションの変更を追跡するモードです。 SCD Type 2（履歴保持）モードを利用することで、利用者や契約者の「住所」や「契約プラン」といった変化する情報について「いつ」「どうであったか」を単一のテーブルに保持できます。 これにより多様な分析要件に柔軟に対応できるほか、過去時点のテーブル（スナップショット）をすべて保持する方法と比較しても、コスト面での優位性を持つテーブル構成となります。 ![SCD Type 2（履歴保持）の処理イメージ](https://cdn.document360.io/3a3bae1e-f157-487f-8798-01e9d820e760/Images/Documentation/datamart-bigquery-2026-02-16-09-18-41.png) プラン上の制約 増分更新およびSCD Type 2（履歴保持）は、**Essential**プラン以上の契約アカウントでのみ、ご利用いただけます。 ## STEP1：基本設定 | 項目名 | 必須 | 内容 | | --- | --- | --- | | データマート定義名 | ✓ | データマート定義名を入力します。 | | メモ | - | TROCCO内部で利用するデータマート定義のメモを入力できます。 | ## STEP2：データ取得設定 STEP2のデータ取得設定では、主に以下の項目を設定します。 - データ取得設定 - クエリ設定 - 転送オプション設定 - その他データ転送モードに依存する設定 ### データ取得設定 | 項目名 | 必須 | 内容 | | --- | --- | --- | | Snowflake接続情報 | ✓ | あらかじめ登録してある[Snowflakeの接続情報](/docs/connection-configuration-snowflake)から、今回のデータマート定義に必要な権限を持つものを選択します。 | | クエリ実行モード | ✓ | 以下のいずれかのモードを選択します。 - データ転送モード クエリと出力先テーブルを指定するだけで、簡単にテーブルへの洗い替え・追記を実行できます。 - 自由記述モード 接続先のDWHに対して、任意のDML・DDLステートメント(`INSERT`・`DELETE`や、`CREATE`・`DROP`など)を記述し、実行できます。`CREATE TABLE` や `DELETE` など、既存のTROCCOのデータマート定義の転送モードだと実現できないような処理を実行するのに適したモードです。 | | 書き込みモード | ✓ | 以下のいずれかのモードを選択します。 - 追記 - 既存のテーブルのレコードの後に、クエリ実行結果が追記されます。 - 全件洗い替え (TRUNCATE INSERT) - 既存のテーブルのレコードが`TRUNCATE`されてクエリ実行結果に置き換えられます。既存テーブルのスキーマは保持されます。 - 全件洗い替え (REPLACE) - 既存のテーブルが`DROP`されてクエリ実行結果に置き換えられます。スキーマは再作成され、Time Travel履歴はリセットされます。 - 増分更新 - キーカラムを指定し、差分データのみを効率的に更新できます。詳細は[書き込みモード：増分更新](/docs/datamart-snowflake#%E6%9B%B8%E3%81%8D%E8%BE%BC%E3%81%BF%E3%83%A2%E3%83%BC%E3%83%89%EF%BC%9A%E5%A2%97%E5%88%86%E6%9B%B4%E6%96%B0)を参照ください。 - SCD Type 2（履歴保持） - 履歴を保持しながらデータを更新します。詳細は[書き込みモード：SCD Type 2（履歴保持）](/docs/datamart-snowflake#%E6%9B%B8%E3%81%8D%E8%BE%BC%E3%81%BF%E3%83%A2%E3%83%BC%E3%83%89%EF%BC%9Ascdtype2%EF%BC%88%E5%B1%A5%E6%AD%B4%E4%BF%9D%E6%8C%81%EF%BC%89)を参照ください。 | ### クエリ設定 データマートのクエリに関する設定項目です。 クエリの整形 クエリ編集欄の左下にある **クエリを整形**をクリックすることで、入力したSQLクエリを自動で整形できます。 整形処理では、キーワードの配置やインデント、改行などが見やすく再配置されます。 #### データ転送モードの場合 データ取得設定のクエリ実行モードで**データ転送モード**を選択した場合の項目です。 | 項目名 | 必須 | 内容 | | --- | --- | --- | | ウェアハウス | ✓ | 処理に利用するウェアハウスを指定します。 | | 出力先データベース | ✓ | データ出力先のデータベースを指定します。 存在するデータベースを指定してください。 | | 出力先スキーマ | ✓ | データ出力先のスキーマ名を指定します。 スキーマ名は英字・数字・アンダースコアのみで構成されている必要があります。 存在するスキーマを指定してください。 | | 出力先テーブル | ✓ | データ出力先のテーブル名を指定します。 テーブル名は英字・数字・アンダースコアのみで構成されている必要があります。 テーブルが存在しない場合は転送時に新しく作成されます。 | | ステートメントタイムアウト (秒) | ✓ | 実行中のクエリをタイムアウトする秒数を入力します（デフォルト：43200）。 0を指定した場合は、Snowflake側の`STATEMENT_TIMEOUT_IN_SECONDS`で設定した値が使用されます。 | | クエリ | ✓ | Snowflakeから転送データを取得するためのSQLを入力します。 [カスタム変数](/docs/custom-variables)を利用し、TROCCOのデータ転送時に動的に設定値を決定することも可能です。 **プレビューを実行**をクリックすることで、実行結果を確認できます。 | | スキーマ追従モード | ✓ | 書き込みモードが**増分更新**または**SCD Type 2（履歴保持）**の場合に指定できます。転送先でスキーマ変更があった場合に自動で追従を行うかを設定します。 - 検知のみ スキーマの変更を検知しますが、自動的には追従しません。 - カラム自動追加 スキーマの変更を検知し、カラムを自動的に追加します。カラムの削除やデータ型の変更は自動では行われません。 詳しくは、[スキーマ追従モード](/docs/datamart-snowflake#%E3%82%B9%E3%82%AD%E3%83%BC%E3%83%9E%E8%BF%BD%E5%BE%93%E3%83%A2%E3%83%BC%E3%83%89)を参照ください。 | 増分更新のクエリ設定について - [増分更新設定](/docs/datamart-snowflake#%E5%A2%97%E5%88%86%E6%9B%B4%E6%96%B0%E8%A8%AD%E5%AE%9A)でキーカラムや処理対象期間の基準カラムに利用するカラムを指定したクエリを記載します。 - クエリ設定で入力したクエリは、そのままデータマートジョブでは実行されません。 - 処理対象期間は増分更新設定で行うため、カスタム変数による日時範囲の指定などは不要です。 - 「プレビューを実行」ボタンを押下することで、増分更新設定でキーカラムや基準カラムの設定が可能になります。 SCD Type 2のクエリ設定について - [SCD Type 2 設定](/docs/datamart-snowflake#scdtype2%E8%A8%AD%E5%AE%9A)でキーカラムや増分基準カラム、処理対象期間の基準カラムに利用するカラムを指定したクエリを記載します。 - クエリ設定で入力したクエリは、そのままデータマートジョブでは実行されません。 - 処理対象期間はSCD Type 2 設定で行うため、カスタム変数による日時範囲の指定などは不要です。 - 「プレビューを実行」ボタンを押下することで、SCD Type 2 設定でキーカラムや増分基準カラム、基準カラムの設定が可能になります。 #### 自由記述モードの場合 データ取得設定のクエリ実行モードで**自由記述モード**を選択した場合の項目です。 | 項目名 | 必須 | 内容 | | --- | --- | --- | | ウェアハウス | ✓ | 処理に利用するウェアハウスを指定します。 | | ステートメントタイムアウト (秒) | ✓ | 実行中のクエリをタイムアウトする秒数を入力します（デフォルト：43200）。 0を指定した場合は、Snowflake側の`STATEMENT_TIMEOUT_IN_SECONDS`で設定した値が使用されます。 | | クエリ | ✓ | 接続先のDWHに対して、任意のクエリ (DDL、DELETE、INSERTなど) を入力します。 クエリ内でテーブル名を指定するときは、`database_name.schema_name.table_name`の形式で記述ください。 | ### データ転送モードで利用できる設定 以下の設定は、クエリ実行モードが**データ転送モード**の場合に利用できます。 #### スキーマ追従モード スキーマ自動追従モードとは、データマートジョブの実行時に、クエリのスキーマと出力先テーブルのスキーマを比較し、差分を自動で検知・追従できる機能です。 分析要件の追加などによりテーブルのスキーマが変化した際、TROCCOのデータマート定義のクエリを書き換えるだけで運用を継続できます。 書き込みモードが**増分更新**または**SCD Type 2（履歴保持）**の場合に表示されます。 検知結果や処理内容は、データマートジョブ詳細画面で確認できます。 **カラム自動追加を選択した場合** スキーマ追従モードで**カラム自動追加**を選択した場合、追従対象と動作は以下となります。 | 種別 | 検知対象 | 動作 | | --- | --- | --- | | カラム追加 | クエリ結果に存在し、出力先テーブルに存在しないカラム | 出力先テーブルにカラムが自動で追加されます。 | | カラム削除 | 出力先テーブルに存在し、クエリ結果に存在しないカラム | 自動では行われません。ジョブが失敗します。 | | 型変更 | 両方に存在するが、データ型が異なるカラム | 自動では行われません。ジョブが失敗します。 | カラム削除・型変更が検知された場合 追従モードがカラム自動追加の場合、カラム削除や型変更が検知されるとジョブが失敗します。 出力先テーブルのスキーマを手動で変更してから、ジョブを再実行してください。 カラム削除および型変更は、誤ったクエリ変更による影響が大きく復旧難易度も高いため、ジョブそのものの失敗として処理されます。 自動追従するのはスキーマのみのため、過去のデータ追加は行われません。必要に応じて過去データを追加してください。 増分更新の場合、該当のデータマートジョブ実行画面から「処理対象期間を上書きする」を有効にすることで、最新のスキーマに基づいて過去の処理対象期間のデータを上書きできます。 **検知のみを選択した場合** スキーマ自動追従モードで**検知のみ**を選択した場合、変更の検知のみ行います。 #### 転送オプション設定 書き込みモードが**追記**または**全件洗い替え（TRUNCATE INSERT、REPLACE）**の場合に表示されます。 | 項目名 | 必須 | デフォルト値 | 内容 | | --- | --- | --- | --- | | ジョブの並列実行 | ✓ | 並列でのジョブ実行はしない | ジョブ実行時点で、同一のデータマート定義による他のジョブが実行中の場合に、ジョブを実行するかどうかを選択します。 - **並列でのジョブ実行はしない**：ジョブは実行されずスキップされます。 - **並列でのジョブ実行を許可**：ジョブは実行されます。 | 「ジョブの並列実行」が設定可能な書き込みモードについて データマートジョブ実行時に発行するクエリの都合上、書き込みモード「増分更新」「SCD Type 2（履歴保持）」ではジョブの並列実行はできません。 #### 増分更新設定 書き込みモードが**増分更新**の場合に表示されます。 クエリ設定のクエリで取得したカラムを利用して、増分更新のデータ更新方法を定義します。 | 項目名 | 必須 | 内容 | | --- | --- | --- | | キーカラム | ✓ | レコードを一意に識別するキーを指定します。複数のカラムを指定できます。 | | キーが一致するレコードが存在した場合の挙動 | ✓ | キーカラムが一致するレコードが既に存在する場合の処理を選択します。 - 上書き：キーカラムが一致する既存のレコードを一旦`DELETE`してから、新しいレコードを`INSERT`します。データの整合性を重視します。 - スキップ：既存のレコードをそのまま残し、キーカラムが一致しない新しいレコードだけを`INSERT`します。 | | 処理対象期間 | ✓ | 処理対象とするデータの期間を指定します。 - 範囲を指定する：指定したカラムを基準に、任意の期間でデータを処理します。範囲の指定方法は[処理対象期間の範囲指定について](/docs/datamart-snowflake#%E5%87%A6%E7%90%86%E5%AF%BE%E8%B1%A1%E6%9C%9F%E9%96%93%E3%81%AE%E7%AF%84%E5%9B%B2%E6%8C%87%E5%AE%9A%E3%81%AB%E3%81%A4%E3%81%84%E3%81%A6)を参照ください。 - 全データを対象にする：全データを処理対象とします。DWH内のスキャン範囲が広がり、クエリコストが大きく増加する可能性があります。 | 設定後、実行されるクエリは「実行クエリプレビュー」より確認できます。 #### SCD Type 2 設定 書き込みモードが**SCD Type 2（履歴保持）**の場合に表示されます。 クエリ設定に基づいてデータの更新方法を定義します。 | 項目名 | 必須 | 内容 | | --- | --- | --- | | キーカラム | ✓ | ビジネスキーとなるカラムを指定します。複数のカラムを指定できます。指定したキーカラムが一致する既存レコードに対して、増分基準カラムの値が更新されている場合は、新しいレコードが作成されます。 | | 増分基準カラム | ✓ | データの新しさを判定できる「更新日時」や「連番」のカラムを1つ指定します。このカラムに変更があった場合、既存レコードの有効終了日時を更新し、新しいレコードが作成されます。 指定可能なデータ型：日時型・数値型 | | 処理対象期間 | ✓ | 処理対象とするデータの期間を指定します。 - 範囲を指定する：指定したカラムを基準に、任意の期間でデータを処理します。範囲の指定方法は[処理対象期間の範囲指定について](/docs/datamart-snowflake#%E5%87%A6%E7%90%86%E5%AF%BE%E8%B1%A1%E6%9C%9F%E9%96%93%E3%81%AE%E7%AF%84%E5%9B%B2%E6%8C%87%E5%AE%9A%E3%81%AB%E3%81%A4%E3%81%84%E3%81%A6)を参照ください。 - 全データを対象にする：全データを処理対象とします。DWH内のスキャン範囲が広がり、クエリコストが大きく増加する可能性があります。 | 設定後、実行されるクエリは「実行クエリプレビュー」より確認できます。 増分基準カラムの選定 増分基準カラムの選定に迷われた際は、ソーステーブルに存在する「更新日時」カラムを指定するケースが一般的です。 #### 自動管理カラム SCD Type 2（履歴保持）モードを使用すると、以下のカラムが出力先テーブルに自動的に追加・管理されます。 | カラム名 | データ型 | 内容 | | --- | --- | --- | | `trocco_valid_from` | `TIMESTAMP_NTZ` | レコードの有効開始時刻。ジョブの実行時刻が入ります。 | | `trocco_valid_to` | `TIMESTAMP_NTZ` | レコードの有効終了時刻（`NULL`は現在有効であることを示します）。nullでない場合は、`trocco_is_current` が無効にされた時刻が入ります。 | | `trocco_is_current` | `BOOLEAN` | 現行フラグ（`TRUE`は現在有効なレコードであることを示します。） | SCD Type 2（履歴保持）モードの処理概要 SCD Type 2（履歴保持）モードでは、トランザクション内で以下の処理を行います。 1. **Step 1**：変更があるレコードの既存行をクローズ - `trocco_valid_to`に現在時刻を設定 - `trocco_is_current`を`FALSE`に更新 2. **Step 2**：新規レコードまたは変更レコードの新バージョンを挿入 - `trocco_valid_from`に現在時刻を設定 - `trocco_valid_to`に`NULL`を設定 - `trocco_is_current`を`TRUE`に設定 出力先テーブルのスキーマ SCD Type 2（履歴保持）モードを使用する場合、出力先テーブルには自動管理カラム（`trocco_valid_from`、`trocco_valid_to`、`trocco_is_current`）が必要です。 テーブルが存在しない場合は自動的に作成されます。既存のテーブルを使用する場合は、これらのカラムが存在することを確認してください。出力先テーブルに同名のカラムがある場合は、意図しない値で上書きされる可能性があるためご注意ください。 出力元テーブルからレコードを削除した場合 SCD Type 2（履歴保持）モードにて、出力元テーブルからレコードを削除しても、出力先テーブルのレコードは削除されずそのまま残ります。 スキーマ自動追従と自動管理カラムについて スキーマ自動追従モードで**カラム自動追加**を選択した場合でも、自動的に追加される管理カラムは比較対象から除外されます。 ## STEP3：品質チェック設定 プラン上の制約 本機能は以下のプランで提供しています。 - **Professionalプラン** - **Essentialプラン**、**Advancedプラン**（有償オプション） 詳しくは、営業担当者またはカスタマーサクセスまでお問い合わせください。 利用できるクエリ実行モード 品質チェック設定が有効にできるのは、クエリ実行モードが**データ転送モード**の場合のみです。 **自由記述モード**では品質チェック設定は利用できません。 ジョブ実行時に重複する値や不正なNULLのチェックを実施できます。 品質チェックを有効にすると、以下の項目を設定できます。 | 項目名 | 必須 | 内容 | | --- | --- | --- | | 単一カラムチェック | ✓（※） | 各カラム単位での品質チェック（一意性チェック・NOT NULLチェック）の対象カラムを選択します。各チェックの仕様については[品質チェックできる内容について](/docs/datamart-snowflake#%E5%93%81%E8%B3%AA%E3%83%81%E3%82%A7%E3%83%83%E3%82%AF%E3%81%A7%E3%81%8D%E3%82%8B%E5%86%85%E5%AE%B9%E3%81%AB%E3%81%A4%E3%81%84%E3%81%A6)を参照ください。 | | 複合カラム一意性チェック | ✓（※） | 複数カラムの値の組み合わせに重複がないかチェックします。複数の組み合わせを追加できます。各組み合わせでは2つ以上のカラムを指定する必要があります。各チェックの仕様については[品質チェックできる内容について](/docs/datamart-snowflake#%E5%93%81%E8%B3%AA%E3%83%81%E3%82%A7%E3%83%83%E3%82%AF%E3%81%A7%E3%81%8D%E3%82%8B%E5%86%85%E5%AE%B9%E3%81%AB%E3%81%A4%E3%81%84%E3%81%A6)を参照ください。 | | 失敗時の挙動 | ✓ | 品質チェックで失敗となった場合の挙動を設定します。 - 記録のみ：品質チェック失敗時、警告として記録しますがジョブは失敗になりません。 - ジョブ失敗として扱う：品質チェック失敗時、ジョブ全体を失敗状態にします。 | | 品質チェック対象データ設定 | ✓ | 品質チェックの対象とするデータの範囲を設定します。 - 範囲を指定してチェックする：指定したカラムを基準に、任意の期間で品質チェックを行います。範囲の指定方法は[処理対象期間の範囲指定について](/docs/datamart-snowflake#%E5%87%A6%E7%90%86%E5%AF%BE%E8%B1%A1%E6%9C%9F%E9%96%93%E3%81%AE%E7%AF%84%E5%9B%B2%E6%8C%87%E5%AE%9A%E3%81%AB%E3%81%A4%E3%81%84%E3%81%A6)を参照ください。 - 全データを対象にチェックする：チェック対象を全データとします。DWH内のスキャン範囲が広がり、クエリコストが大きく増加する可能性があります。 | ※ 単一カラムチェックまたは複合カラム一意性チェックのいずれか1つ以上の設定が必須です。 「記録のみ」を選択した場合の通知設定について 「失敗時の挙動」を「記録のみ」に設定した場合、品質チェックでエラーが検出されてもジョブは成功として扱われます。 品質チェックのエラーを見逃さないために、[通知設定](/docs/notification)にて通知タイプ「**ジョブ成功、かつ品質チェックエラー検出時**」を設定することをおすすめします。 ### 品質チェックできる内容について 以下のチェック方法をサポートしています。 | 項目名 | 内容 | | --- | --- | | 一意性チェック | 指定カラムの値、もしくはカラムの組み合わせが一意であることを検証できます。 | | NOT NULLチェック | 指定カラムに NULL 値が含まれていないか検証できます。 | 一意性チェックと品質チェック対象データ設定の組み合わせについて 「範囲を指定してチェックする」を有効にしたうえで単一カラムまたは複合カラムに対して一意性チェックを実行した場合、チェックが行われるのは処理対象期間内のみになります。テーブル全体でのチェックが行われるわけではないのでご注意ください。 テーブル全体でのチェックが必要な場合は「全データを対象にチェックする」を選択してください。 ## 処理対象期間の範囲指定について | 項目名 | 必須 | 内容 | | --- | --- | --- | | 基準カラム | ✓ | 範囲指定の基準とするカラムを選択します。`DATE`・`TIMESTAMP_NTZ`・`TIMESTAMP_TZ`・`TIMESTAMP_LTZ`型のカラムのみ選択可能です。 | | 期間 | ✓ | 対象とする範囲を「○日前から○日前まで」のように指定します。単位は日・時間から選択できます。 | | タイムゾーン | ✓ | 範囲の基準とする現在の日時のタイムゾーンを指定します。基準カラムが`DATE`型の場合、指定したタイムゾーンで日時が解釈されます。 |