Cloudflare Containersをウォームに保つ：ヘルスチェックエンドポイントでコールドスタートを排除

import http from 'node:http';

const PORT = process.env.PORT || 8080;

// 重い依存関係は必要になるまで初期化されない
let sharp;
let pipelineReady = false;

async function initializePipeline() {
  if (pipelineReady) return;

  // これが遅い部分 - 実際のリクエストでのみ実行
  sharp = (await import('sharp')).default;
  // 他の高コストなセットアップもここに
  pipelineReady = true;
  console.log('Pipeline initialized');
}

const server = http.createServer(async (req, res) => {
  // ヘルスチェック：即座に返し、すべての初期化をスキップ
  if (req.method === 'GET' && req.url === '/healthcheck') {
    res.writeHead(204, {
      'cache-control': 'no-store',
      'content-type': 'text/plain'
    });
    return res.end();
  }

  // 実際のリクエスト：必要に応じて依存関係を初期化
  await initializePipeline();

  // 実際のリクエスト処理はここに
  if (req.method === 'POST' && req.url === '/resize') {
    // sharpで画像を処理...
    res.writeHead(200, { 'content-type': 'application/json' });
    return res.end(JSON.stringify({ success: true }));
  }

  res.writeHead(404, { 'content-type': 'text/plain' });
  res.end('Not found');
});

server.listen(PORT, () => {
  // ここで重い作業をしない - コールドスタート時に実行される
  console.log(`Server listening on port ${PORT}`);
});

import express from 'express';

const app = express();
const PORT = process.env.PORT || 8080;

let pipelineReady = false;

async function ensurePipeline(req, res, next) {
  if (req.path === '/healthcheck') return next();

  if (!pipelineReady) {
    // 重い依存関係を遅延ロード
    const sharp = (await import('sharp')).default;
    app.locals.sharp = sharp;
    pipelineReady = true;
  }
  next();
}

app.use(ensurePipeline);

// ヘルスチェックは上記のチェック以外のすべてのミドルウェアをバイパス
app.get('/healthcheck', (req, res) => res.status(204).end());

// 実際のエンドポイントは初期化されたパイプラインを取得
app.post('/resize', async (req, res) => {
  const sharp = req.app.locals.sharp;
  // sharpで処理...
  res.json({ success: true });
});

app.listen(PORT, () => console.log(`Listening on ${PORT}`));

from fastapi import FastAPI, Response
from functools import lru_cache
import os

app = FastAPI()

# 重いインポートはモジュールレベルに留まるが実行されない
# 実際のロードはget_processor()で発生
_processor = None

def get_processor():
    global _processor
    if _processor is None:
        # これが遅い部分 - 重いインポートはここで発生
        from PIL import Image
        import numpy as np
        _processor = {'pil': Image, 'np': np}
        print('Processor initialized')
    return _processor

@app.get('/healthcheck')
def healthcheck():
    # 即座に返す - 初期化なし
    return Response(status_code=204)

@app.post('/resize')
async def resize():
    # 実際のリクエスト：必要に応じて初期化
    proc = get_processor()
    # proc['pil']とproc['np']を画像処理に使用...
    return {'success': True}

if __name__ == '__main__':
    import uvicorn
    port = int(os.environ.get('PORT', 8080))
    uvicorn.run(app, host='0.0.0.0', port=port)

mkdir container-warmer && cd container-warmer
npm init -y

name = "container-warmer"
main = "src/index.ts"
compatibility_date = "2025-12-01"

[triggers]
crons = ["*/5 * * * *"]

export interface Env {
  CONTAINER_URL: string;
  AUTH_TOKEN?: string;
}

export default {
  async scheduled(event: ScheduledEvent, env: Env, ctx: ExecutionContext) {
    ctx.waitUntil(pingContainer(env));
  }
};

async function pingContainer(env: Env) {
  const headers: Record<string, string> = {
    'user-agent': 'cloudflare-container-warmer/1.0'
  };

  // オプション：ヘルスチェックをベアラートークンで保護
  if (env.AUTH_TOKEN) {
    headers['authorization'] = `Bearer ${env.AUTH_TOKEN}`;
  }

  try {
    const response = await fetch(env.CONTAINER_URL, {
      method: 'GET',
      headers
    });

    if (response.ok || response.status === 204) {
      console.log('Container warmed successfully');
    } else {
      console.log(`Warm ping returned status: ${response.status}`);
    }
  } catch (error) {
    console.log(`Warm ping failed: ${error}`);
  }
}

# コンテナのヘルスチェックURLを設定
npx wrangler secret put CONTAINER_URL
# 入力: https://your-container.your-subdomain.workers.dev/healthcheck

# オプション：認証トークンを設定
npx wrangler secret put AUTH_TOKEN

# ウォーマーをデプロイ
npx wrangler deploy