{
  "path": "/posts/feed-03",
  "site": "at://did:plc:rgdcflm4ylsl6udghmtblydc/site.standard.publication/blog",
  "tags": [
    "Bluesky"
  ],
  "$type": "site.standard.document",
  "title": "Blueskyのカスタムフィードの仕組みを一から自分で考える #03",
  "updatedAt": "2026-02-22T10:06:58.989Z",
  "publishedAt": "2024-01-03T00:00:00.000Z",
  "textContent": "## 公式サンプルを動かす\n\nカスタムフィードの公式サンプルではNginxが必要ということになっているので手が出しにくいのではと思いますが、単純に動作確認をするのであれば、node.jsとyarnとgitがインストールさえすれば大丈夫です。ただし、動作を理解するにはTypeScript(JavaScript)とデータベースの知識が必要です。\n\n\n\n```plain text\ngit clone https://github.com/bluesky-social/feed-generator.git\ncd feed-generator\nyarn install\n```\n\n更新終ったら、Windowsはタスクマネージャーを起動した状態で\n\n```plain text\nyarn start\n```\n\nを実行すると、PDS（Relay）との連合とカスタムフィードサーバーが起動します。起動直後からRelayから全世界の投稿がすべてコンソールを流れてくるため、びっくりしないようにします。びっくりしたらタスクマネージャでnodeのプロセスをキルします。\n\nとりあえずログに大量に流れてくるとわかりにくいので、何とかします。前出の通り、Relay、すなわちBlueskyから投稿を受ける処理は「src/subscription.ts」が担います。このソースには\n\n```typescript\n// This logs the text of every post off the firehose.\n// Just for fun :)\n// Delete before actually using\n```\n\nという記載があります。直訳すると「すべてのFirehoseで流れてきた投稿のテキストをログに流すよ。実運用するときには（ログに流すところを）消してね」とあります。\n\n## 手を入れてさらに挙動を見る\n\n「console.log(post.record.text)」をコメントアウトしたうえで、２６行目の「// map alf-related posts to a db row」の下に「console.log(create)」の行を足しyarn startします。\n\n```typescript\n// This logs the text of every post off the firehose.\n// Just for fun :)\n// Delete before actually using\n//for (const post of ops.posts.creates) {\n//  console.log(post.record.text)\n//}\n\nconst postsToDelete = ops.posts.deletes.map((del) => del.uri)\nconst postsToCreate = ops.posts.creates\n  .filter((create) => {\n    // only alf-related posts\n    return create.record.text.toLowerCase().includes('alf')\n  })\n  .map((create) => {\n    // map alf-related posts to a db row\n    console.log(create)\n    return {\n      uri: create.uri,\n      cid: create.cid,\n      replyParent: create.record?.reply?.parent.uri ?? null,\n      replyRoot: create.record?.reply?.root.uri ?? null,\n      indexedAt: new Date().toISOString(),\n    }\n  })\n```\n\n実行すると、今度はログがおとなしい状態になります。ここで、自身のアカウントで「テスト投稿 alf」と投稿するとログに「テスト投稿 alf」が表示されると思います。これで現在起動したサンプルソースは、alfという文字列を含む投稿があるとそれをログに出力するようになります。もともとのソースの仕様として、本サーバーが起動している間のalfが含まれる投稿は、すべてメモリに保存するようになります。\n\nなお、この手順に沿っている場合、メモリに保存されているだけなので、時間経過またはプロセスを落とすと消えますが動作確認用なので気にしないようにします。また、起動していないときの投稿は拾うことが出来ません。\n\n## ジェネレータ本体の挙動を見る\n\nyarn startしたPCのブラウザで「http://localhost:3000/xrpc/app.bsky.feed.getFeedSkeleton?feed=at://FEEDGEN_PUBLISHER_DIDに設定したDID/app.bsky.feed.generator/whats-alf」にアクセスすると、JSONの配列で1件だけ投稿が返される状態になります。（FEEDGEN_PUBLISHER_DIDに設定したDIDは個別変えてください）\n\n「whats-alf」は「src/algos/whats-alf.ts」のソースを呼び出すようになっています。ソースを見ると、「let builder = ctx.db」からSQLを生成しています。ざっくりいうと、postテーブルの中身をすべて（.selectAll()なのでWHERE句なし全件）投稿時間の降順で表示しています。\n\n```typescript\n  let builder = ctx.db\n    .selectFrom('post')\n    .selectAll()\n    .orderBy('indexedAt', 'desc')\n    .orderBy('cid', 'desc')\n    .limit(params.limit)\n```\n\nSQLで表すと「select * from post order by indexedAt desc, cid desc limit 30」です。indexedAtは投稿時間とほぼイコールですが、Relayから本サーバーに投稿が連携された本サーバーのシステム時間となります。ですので、このサンプルソースは「データベースには「alf」が含まれる投稿だけあらかじめ絞って登録している。「whats-alf」にアクセスすると、あらかじめ絞って登録されている投稿を全件表示している」ということになります。\n\n## 今までの挙動から何ができるかを考える\n\nここまで理解すると、SkyFeedのように「正規表現を実データを見ながら徐々に変えることができる」という挙動と、サンプルソースの実装である「保存する際に条件を満たした投稿だけを保存しておく」ということに大きな乖離があります。SkyFeedと同じことをしたければ、全世界の投稿をデータベースに保存しておき、データベースの問い合わせ時に正規表現で表示するものを絞り込む、このような挙動をすればよいということになります。#FF14を含む投稿を全件取ってくるであれば、「select * from post where text  like '%#FF14%' order by indexedAt desc, cid desc limit 30」のようなSQLに組み替えるようにするということですね。\n\nただし、データベースにBlueskyの投稿を全件保存しておくことはストレージ容量的には耐えられなくはないものの、80万件/1日程度あります。仮に80万件保存したとしても、そこに正規表現を用いた検索を全件に対して行うことはパフォーマンス的には現実的ではないことに頭を抱えると思います。SkyFeedの7日間制限は、7日間の投稿しか保存していないわけではなく全期間保存はしているが、正規表現の対象にできる範囲を絞っているということですね。SkyFeedのよい仕組みを把握できたところで独自サーバーを立てる意義を見つけることに苦労することになります。\n\n\n\n"
}