目次 › 第3章 › 3-1

第3章 データロード・アンロードと接続 / 想定学習時間:30〜40分 / 最終確認:2026年8月

3-1. ステージとファイルフォーマット(内部/外部ステージ・PUT/GET)

1. ステージとは:ロードとアンロードの中継地点

Snowflake では、ファイルからテーブルへデータをロードするとき(またはその逆のアンロードのとき)、ファイルをいったんステージ(stage)と呼ばれる置き場に置きます。ステージは「ファイルの中継地点」であり、置き場所が Snowflake の内部にあるか外部のクラウドストレージにあるかで、大きく内部ステージと外部ステージの2つに分かれます。

2. 内部ステージ3種の使い分け

内部ステージ(internal stage)は、Snowflake が管理するストレージ上のファイル置き場です。3種類があり、それぞれ記法と性質が異なります。この対応付けは試験で問われやすいので、正確に覚えましょう。

3. 外部ステージと storage integration

外部ステージ(external stage)は、顧客が管理するクラウドストレージ(Amazon S3 / Azure Blob Storage / Google Cloud Storage)上の場所を参照するステージです。ファイルの実体は Snowflake の外にあり、Snowflake はそこを「指し示す」だけです。

-- storage integration を使った外部ステージの作成(推奨)
CREATE STAGE my_ext_stage
  URL = 's3://my-bucket/load/'
  STORAGE_INTEGRATION = my_s3_int
  FILE_FORMAT = my_csv_format;

外部ステージを作るとき、クラウドストレージへのアクセス資格情報が必要になります。SQL 文に秘密キーを直接書く方法もありますが、推奨されるのは storage integration オブジェクトを使う方法です。storage integration は IAM ロールなどのクラウド側の仕組みで認証を委任するため、資格情報(シークレット)を SQL に書かずに済みます。詳細は 3-6 で扱います。

4. ステージを操作するコマンド:PUT / GET / LIST / REMOVE

ステージ上のファイルは、次の4つのコマンドで操作します。

-- 名前付き内部ステージを作成する
CREATE STAGE my_stage
  FILE_FORMAT = (TYPE = 'CSV' SKIP_HEADER = 1);

-- SnowSQL(CLI)からローカルファイルをアップロードする
-- 既定で自動的に gzip 圧縮される(AUTO_COMPRESS = TRUE)
PUT file:///data/sales_2026*.csv @my_stage;

-- ステージ上のファイルを確認する
LIST @my_stage;

-- ロード完了後にファイルを削除する
REMOVE @my_stage PATTERN = '.*sales_2026.*';

5. ファイルフォーマット:対応形式と名前付きオブジェクト

ステージ上のファイルを正しく読み取るには、ファイルの形式(区切り文字、ヘッダーの有無、圧縮方式など)を Snowflake に伝える必要があります。これを担うのがファイルフォーマット(file format)です。Snowflake がロード・アンロードでサポートする形式は次のとおりです。

フォーマット指定は COPY 文の中に直接書くこともできますが、名前付きファイルフォーマットオブジェクトとして作成しておくと、複数のステージや COPY 文から再利用できて管理しやすくなります。

-- 名前付きファイルフォーマットの作成
CREATE FILE FORMAT my_csv_format
  TYPE = 'CSV'
  FIELD_DELIMITER = ','
  SKIP_HEADER = 1
  NULL_IF = ('NULL', '');

-- ステージに紐付けておけば COPY 時の指定を省略できる
CREATE STAGE my_stage FILE_FORMAT = my_csv_format;

6. ロードに適したファイルサイズ

Snowflake のロードは、複数ファイルを並列に処理することで高速化されます。そのため、1つの巨大なファイルより、適切なサイズに分割された複数ファイルの方が効率的です。推奨は「圧縮済みでおよそ 100〜250MB 程度」のファイルに分割することです。

• 大きすぎるファイル(数GBの単一ファイルなど):並列化できず、1つの処理系に負荷が集中してロードが遅くなる。
• 小さすぎるファイルが大量にある場合:ファイルごとの管理オーバーヘッドが積み重なり、非効率になる(Snowpipe では課金にも影響。3-3 参照)。

練習問題