Prisma Pulse

Managed real-time database event streaming for PostgreSQL accessed via Prisma Client. Subscribe to insert, update, and delete events on any Prisma model with client.model.stream() returning a type-safe async iterable. Prisma Pulse manages the PostgreSQL logical replication connection and replication slot as a hosted service. Designed for event-driven architectures, live dashboards, and sync pipelines. Confidence is docs-derived.

Prisma Client extension: import withPulse from '@prisma/extension-pulse'; const client = new PrismaClient().$extends(withPulse({ apiKey })); const stream = await client.model.stream({ create: {}, update: {}, delete: {} }); for await (const event of stream) {} — type-safe event object includes action, created/updated/deleted record fields; filter by operation type; stream.stop() to unsubscribe.

Prisma Pulse API key (project-scoped) passed to withPulse({ apiKey }) — should be an environment variable, not hardcoded; Prisma Data Platform account for API key management; Pulse connects to your PostgreSQL using the DATABASE_URL you configure in the Data Platform — Prisma manages the replication slot; no direct database credential exposure in application code beyond DATABASE_URL.

Logical replication delivers events after WAL commit — effectively at-most-once with potential for missed events if consumer is offline without persistent subscription; stream() returns async generator — consumer back-pressure is natural; Pulse handles replication lag and reconnection transparently; structured TypeScript error types for stream errors; replication slot cleanup managed by Prisma Pulse service.

Documentation covers extension installation, stream() API reference, event filtering, TypeScript type inference walkthrough, and connection setup in Prisma Data Platform. Part of the Prisma ecosystem (ORM + Accelerate + Pulse). Tight Prisma schema type propagation is the main developer experience win. Confidence is docs-derived.