Snowflake External Functionsで外部APIを呼び出す仕組みと構築手順

External Functionは、SnowflakeのSQLクエリから クラウドプロバイダーのAPI Gateway経由で外部のREST APIを呼び出すためのスカラー関数です。 バックエンドにAWS Lambda・Azure Functions・Google Cloud Functionsなどを配置し、 ML推論・データエンリッチメント・外部サービス連携をSQL内で完結させることができます。

External Functionのデータフロー

SELECT external_func(col) FROM table
  │
  ├─ Snowflake Virtual Warehouse
  │    └─ 入力行をバッチ化してJSON形式に変換
  │
  ├─ Cloud Services Layer
  │    └─ API Integrationの認証情報でAPI Gatewayへリクエスト
  │
  ├─ API Gateway (AWS API Gateway / Azure APIM / GCP API Gateway)
  │    └─ 認証・レート制限・ルーティング
  │
  └─ Backend (Lambda / Azure Functions / Cloud Functions)
       └─ ビジネスロジック実行 → JSON形式でレスポンスを返却

リクエスト/レスポンスのJSON形式

-- Snowflakeが送信するリクエスト形式
{
  "data": [
    [0, "Hello world"],
    [1, "Snowflake is great"],
    [2, "External functions rock"]
  ]
}

-- バックエンドが返すレスポンス形式
{
  "data": [
    [0, "positive"],
    [1, "positive"],
    [2, "positive"]
  ]
}

各行は [行番号, 値...] の配列です。行番号はSnowflakeが自動付与し、 レスポンスでも同じ行番号を返す必要があります。 バックエンドのコードではこの形式をパースし、同じ形式で結果を返却します。

AWS Lambdaバックエンドの実装例

# AWS Lambda関数 (Python)
import json

def lambda_handler(event, context):
    body = json.loads(event['body'])
    rows = body['data']

    results = []
    for row in rows:
        row_number = row[0]
        input_text = row[1]
        # ビジネスロジック: テキストの文字数を返す
        char_count = len(input_text) if input_text else 0
        results.append([row_number, char_count])

    return {
        'statusCode': 200,
        'body': json.dumps({'data': results})
    }

AWS: External Functionの作成

-- 前提: API Integrationが作成済み
-- (CREATE API INTEGRATIONの詳細はAPI Integrationsの記事を参照)

CREATE OR REPLACE EXTERNAL FUNCTION char_count(input_text VARCHAR)
  RETURNS INT
  API_INTEGRATION = aws_ml_api
  MAX_BATCH_ROWS = 500
  AS 'https://abc123.execute-api.us-east-1.amazonaws.com/prod/char-count';

Azure: External Functionの作成

CREATE OR REPLACE EXTERNAL FUNCTION translate_text(text VARCHAR, target_lang VARCHAR)
  RETURNS VARCHAR
  API_INTEGRATION = azure_translate_api
  AS 'https://my-apim.azure-api.net/translate/v1';

GCP: External Functionの作成

CREATE OR REPLACE EXTERNAL FUNCTION geocode_address(address VARCHAR)
  RETURNS VARIANT
  API_INTEGRATION = gcp_geocode_api
  AS 'https://my-gateway-abc123.uc.gateway.dev/geocode';

クラウド別の構成要素

呼び出しパターン

-- 基本的な呼び出し
SELECT id, text, char_count(text) AS count
FROM documents
LIMIT 1000;

-- CASE式と組み合わせて条件付き呼び出し（コスト最適化）
SELECT
  id,
  text,
  CASE
    WHEN needs_translation = TRUE
    THEN translate_text(text, 'ja')
    ELSE text
  END AS translated_text
FROM documents;

-- 結果を永続化
CREATE TABLE enriched_documents AS
SELECT
  d.*,
  geocode_address(d.address) AS geo_result,
  geo_result:lat::FLOAT AS latitude,
  geo_result:lng::FLOAT AS longitude
FROM documents d
WHERE d.address IS NOT NULL;

パフォーマンスチューニング

セキュリティの考慮事項

• API Integrationで通信先を制限：API_ALLOWED_PREFIXESで許可するURLを最小限にし、API_BLOCKED_PREFIXESで除外パスを追加する
• USAGE権限でアクセス制御：External FunctionのUSAGE権限を特定ロールにのみGRANTし、不正利用を防止する
• API Gateway側の認証も設定：Snowflakeからの認証に加えて、API GatewayでAPIキー検証やスロットリングを設定する
• バックエンドの入力検証：Lambda/Cloud Functions側でも入力値のバリデーションを行い、インジェクション攻撃を防止する

制約事項

• External Functionはスカラー関数としてのみ作成可能（テーブル関数は不可）
• HTTPSプロトコルのみ対応（HTTPは不可）
• 戻り値の型はVARCHAR、INT、FLOAT、BOOLEAN、VARIANTなどのスカラー型に限定
• External Functionの呼び出しにはVirtual Warehouseが必要（クレジット消費あり）
• IMMUTABLE / VOLATILE / STABLEのボラティリティ指定が可能だが、キャッシュ動作に影響する

問題で確認

よくある質問