Протокольные сервисы Bluesky: Jetstream v2 с сетевым повтором

Bluesky запустил Bluesky Protocol Services — новый бренд и сайт для публичной инфраструктуры, на которой работает сеть AT Protocol. Главная новость — Jetstream v2, который добавляет Network Replay — способ получения исторических данных сети через HTTP с последующим переходом на живой WebSocket-поток без разрыва.

Jetstream v2: Network Replay

Jetstream — это сервис, позволяющий подписаться на часть сети AT Protocol в виде простого JSON через WebSocket. Раньше нельзя было получить исторические записи из Jetstream; приходилось самостоятельно заполнять репозитории. Jetstream v2 исправляет это с помощью новой функции Network Replay.

Вот как это работает:

• Отправьте POST-запрос с фильтрами на planSnapshot, чтобы получить план для исторических данных.
• Загрузите закрытые сегменты по обычному HTTP.
• Подключитесь к живому WebSocket в конце, чтобы продолжить в реальном времени.

Replay не сохраняет состояние на сервере: нет курсора для каждого потребителя, нет регистрации подписки, ничего не нужно подготавливать на стороне клиента. Вы также можете просто сделать снимок сети (копию на определенный момент времени) только через HTTP, используя listSegments и getSegment, без живой ленты.

Это позволяет выполнять серверный анализ исторических данных без локального заполнения. Примеры использования: запуск приложения, анализ месяца постов или восстановление после простоя.

Поскольку обслуживание архивов требует большой пропускной способности, Bluesky теперь требует API-токен для запросов архивов. Живая лента остается открытой и без аутентификации. Пока нет планов добавлять аутентификацию в живой поток.

Экземпляры v2 уже работают:

wss://jetstream.us-west.bsky.network
wss://jetstream.us-east.bsky.network

Существующие экземпляры v1 продолжают работать без изменений, и живая лента ведет себя идентично, так что спешить с миграцией не нужно.

Новые SDK для Jetstream

Также выпущены официальные SDK для Jetstream для TypeScript и Go. Вот пример на TypeScript из документации:

import { Jetstream } from '@bsky/jetstream'
import { app } from '@bsky/sdk/lexicons'

const js = new Jetstream('https://jetstream.us-east.bsky.network')
for await (const evt of js.live({ collections: [app.bsky.feed.post] })) {
    if (evt.kind === 'commit' && evt.commit.operation === 'create') {
        console.log(evt.commit.collection, evt.commit.record.text)
    }
}

TypeScript SDK доступен на npm; Go SDK является частью проекта Jetstream.

TypeScript SDK Bluesky переписан на lex

TypeScript SDK Bluesky перестроен на @atproto/lex, что убирает устаревшие пути кода. Он полностью типизирован от начала до конца, от уровня протокола до записей app.bsky. Все новые примеры в документации используют его. Старый @atproto/api по-прежнему работает, но новый SDK устраняет рекомендации LLM по использованию устаревших версий.

Обновления на endpoints.bsky.app

HTTP-справочник на endpoints.bsky.app обновлен. Старый docs.bsky.app заменен новым сайтом Protocol Services.

Вся инфраструктура имеет открытый исходный код и может быть размещена самостоятельно.