AT Protocol Jetstream Trigger icon

AT Protocol Jetstream Trigger

Subscribe to the AT Protocol firehose via Jetstream

AT Protocol Jetstream Trigger

AI-generated

Summary

Connects to an AT Protocol Jetstream WebSocket and emits matching events as n8n trigger items. Configure the event types and optional collection or repo filters to limit which events reach the workflow.

Inputs

  • Jetstream Endpoint — Select a listed Jetstream instance or choose Custom and provide its WebSocket URL.
  • Custom Endpoint (required) — Required when the endpoint is Custom; the full WebSocket URL of the Jetstream instance.
  • Collections — Optional collection NSIDs to filter events, including wildcard prefixes in By NSID mode. Leave empty to accept all collections.
  • Wanted DIDs — Optional repo DIDs to watch. Leave empty to accept events from all repos.
  • Event Kinds — Choose commit events, identity updates, and/or account status changes; defaults to Commits.
  • Operations — For commit events, choose creates, updates, and/or deletes; defaults to all three.
  • Use Compression — Enable zstd compression, on by default.
  • Max Message Size (Bytes) — Optional server-side message size limit; 0 means no limit.

Output shape

A stream of event items, one per emitted Jetstream event.

The trigger flattens events into JSON before emitting them. It reconnects with exponential backoff and rewinds the cursor by 3 seconds for gapless playback.

Examples

Example 1: Watch for new Bluesky posts from selected accounts

Use a listed endpoint, set Collections to app.bsky.feed.post, add the accounts’ DIDs under Wanted DIDs, select Commits and Create, and leave compression enabled.

Links

Discussion