Snowflakeステージ

ステージ（Stage）は、Snowflakeでデータのロード（取り込み）とアンロード（書き出し）を行う際のファイル中間置き場です。COPY INTO文によるバルクロード、Snowpipeによる自動取り込み、データエクスポートなど、ほぼすべてのファイル連携はステージを経由します。SnowPro Core試験ではData Loadingドメインの必須トピックです。

ステージの種類と比較

Snowflakeには4種類のステージがあり、用途・管理方法・セキュリティモデルが異なります。

Internal Stage（Named）の作成と活用

Named Internal StageはSnowflake内部ストレージにファイルを格納するステージです。GRANTで権限制御が可能なため、チーム運用ではUser/Table Stageよりも推奨されます。

-- Named Internal Stageの作成
CREATE OR REPLACE STAGE hr_load_stage
  FILE_FORMAT = (TYPE = CSV SKIP_HEADER = 1 FIELD_OPTIONALLY_ENCLOSED_BY = '"')
  COMMENT = 'HR部門のCSVロード用ステージ';

-- ファイルアップロード（SnowSQL / PUT）
PUT file:///data/employees.csv @hr_load_stage AUTO_COMPRESS = TRUE;

-- ステージ上のファイル一覧を確認
LIST @hr_load_stage;

-- ロード実行
COPY INTO hr.employees
FROM @hr_load_stage
PATTERN = '.*employees.*\.csv\.gz'
ON_ERROR = 'CONTINUE';

External Stage + Storage Integration

External Stageは、S3・Azure Blob Storage・GCS上の外部ストレージを直接参照するステージです。データをSnowflake内部にコピーせずにロード元として利用できるため、既存データレイクとの連携に最適です。

Storage Integrationの設計

Storage IntegrationはSnowflakeとクラウドストレージ間のアクセスを、IAMロールベースの委任で安全に管理するオブジェクトです。長期鍵の埋め込みが不要になり、ACCOUNTADMIN権限で一元管理できます。

-- Storage Integrationの作成（ACCOUNTADMIN）
CREATE OR REPLACE STORAGE INTEGRATION s3_integration
  TYPE = EXTERNAL_STAGE
  STORAGE_PROVIDER = 'S3'
  STORAGE_AWS_ROLE_ARN = 'arn:aws:iam::123456789012:role/snowflake-access'
  ENABLED = TRUE
  STORAGE_ALLOWED_LOCATIONS = ('s3://data-lake-prod/raw/', 's3://data-lake-prod/staging/');

-- IAM信頼関係に必要な情報を取得
DESC INTEGRATION s3_integration;

-- External Stageの作成
CREATE OR REPLACE STAGE data_lake_stage
  STORAGE_INTEGRATION = s3_integration
  URL = 's3://data-lake-prod/raw/'
  FILE_FORMAT = (TYPE = PARQUET);

COPY INTOとステージの連携パターン

COPY INTOはステージからテーブルへのロードと、テーブルからステージへのアンロードの両方向で使用します。

-- ロード：ステージ → テーブル
COPY INTO analytics.orders
FROM @data_lake_stage/orders/2026/03/
FILE_FORMAT = (TYPE = PARQUET)
MATCH_BY_COLUMN_NAME = CASE_INSENSITIVE;

-- アンロード：テーブル → ステージ
COPY INTO @export_stage/monthly_report/
FROM (
  SELECT region, SUM(amount) AS total_amount
  FROM analytics.orders
  WHERE order_date >= '2026-03-01'
  GROUP BY region
)
FILE_FORMAT = (TYPE = CSV COMPRESSION = GZIP)
HEADER = TRUE
OVERWRITE = TRUE;

COPY INTOの主要オプション

FILE FORMATの定義と再利用

Named File Formatを事前に定義しておくと、複数のステージやCOPY INTOで一貫したフォーマット設定を再利用できます。

-- Named File Formatの作成
CREATE OR REPLACE FILE FORMAT csv_standard
  TYPE = CSV
  SKIP_HEADER = 1
  FIELD_DELIMITER = ','
  FIELD_OPTIONALLY_ENCLOSED_BY = '"'
  NULL_IF = ('NULL', 'null', '')
  EMPTY_FIELD_AS_NULL = TRUE;

-- ステージでFile Formatを参照
CREATE OR REPLACE STAGE shared_csv_stage
  FILE_FORMAT = csv_standard;

Directory Tables

Directory Tablesは、ステージ上のファイルメタデータ（ファイルパス・サイズ・最終更新日時等）をテーブルとしてクエリできる機能です。ステージ作成時にDIRECTORY = (ENABLE = TRUE)を指定して有効化します。

-- Directory Table有効化
ALTER STAGE data_lake_stage SET DIRECTORY = (ENABLE = TRUE);

-- メタデータの手動リフレッシュ
ALTER STAGE data_lake_stage REFRESH;

-- Directory Tableのクエリ
SELECT *
FROM DIRECTORY(@data_lake_stage)
WHERE FILE_URL LIKE '%2026/03%'
ORDER BY LAST_MODIFIED DESC;

セキュリティのベストプラクティス

• External StageではStorage Integrationを必ず使用：長期鍵の埋め込みを避け、IAMロールによるアクセス委任を行う
• STORAGE_ALLOWED_LOCATIONSで範囲制限：Storage Integrationで許可するバケット/パスを最小限に絞る
• Named Stageに適切なGRANTを設定：チーム運用ではUSAGE / READ / WRITE権限をロール単位で制御する
• Internal Stageの暗号化：Snowflakeが自動的にAES-256暗号化を適用（追加設定不要）

問題で確認

よくある質問