Hono + Cloudflare Workersでキャッシュを利用する

1
export type CacheMetadata = {
2
  expiresIn: string
3
}
4

5
export type CacheResult = {
6
  cache: string | null
7
  isExpired: boolean
8
}

1
export namespace KVCache {
2
  export const get = async (c: Context<{ Bindings: Bindings }>): Promise<CacheResult> => {
3
    // KEYは適当に設定する感じで
4
    // 私のプロジェクトではアクセスされたURLに対してキーを発行している
5
    const { value, metadata } = await c.env.Cache.getWithMetadata<CacheMetadata>('KEY')
6
    if (value === null || metadata === null) {
7
      return {
8
        cache: null,
9
        isExpired: true
10
      }
11
    }
12
    return {
13
      cache: value,
14
      // dayjsを利用してキャッシュの有効期限と現在時刻を比較する
15
      isExpired: dayjs(metadata.expiresIn).unix() < dayjs().unix()
16
    }
17
  }
18

19
  export const put = async (c: Context<{ Bindings: Bindings }>, value: any): Promise<void> => {
20
    // KEYは適当に設定する感じで
21
    // 私のプロジェクトではアクセスされたURLに対してキーを発行している
22
    await c.env.Cache.put('KEY', JSON.stringify(value), { metadata: { expiresIn: expiresIn } })
23
  }
24
}

1
// 重い処理
2
export const CACHE_CREATE = async (c: Context<{ Bindings: Bindings }>): Promise<DATA> => {
3
  const data = // 何らかのデータを作成する
4
  await KVCache.put(c, data)
5
  return data
6
}
7

8
app.get('/', async (c) => {
9
  const { cache, isExpired } = await KVCache.get(c)
10
  if (isExpired) {
11
    // キャッシュが有効期限切れの場合、バックグラウンドで更新する
12
    c.executionCtx.waitUntil(CACHE_CREATE())
13
  }
14
  if (cache !== null) {
15
    // キャッシュがあればその値を返す
16
    return c.json({ JSON.parse(cache) })
17
  }
18
  // 最初の一回だけ実行される
19
  // キャッシュがなければ作成して更新する
20
  return c.json({ JSON.parse(CACHE_CREATE()) })
21
})

1
[triggers]
2
crons = ["*/15 * * * *"]

1
const UPDATE_CACHE = async (controller: ScheduledController, env: Env, ctx: ExecutionContext): Promise<void> => {
2
  // 実行されるコードを書きます
3
}
4

5
const scheduled = (event: ScheduledController, env: Env, ctx: ExecutionContext) => {
6
  // 定期実行したいコードを書く
7
  // 今回の場合はUPDATE_CACHEを実行したいわけなので
8
  ctx.waitUntil(UPDATE_CACHE())
9
}
10

11
export default {
12
  port: 3000,
13
  fetch: app.fetch,
14
  scheduled // 必須
15
}