Guides¶
Step-by-step tutorials and practical guides for common pgqrs use cases.
Available Guides¶
-
Basic Queue
The smallest producer-consumer setup using queue primitives.
-
Basic Workflow
Set up a complete producer-consumer workflow using the new Trigger/Worker architecture.
-
S3 Queue
Bootstrap and operate a queue stored as a SQLite object in S3.
-
Batch Processing
Efficiently process high volumes of messages.
-
Delayed Messages
Schedule messages for future processing.
-
Worker Management
Scale and manage multiple workers in production.
-
Durable Workflows
Build crash-resistant, resumable multi-step workflows with automatic recovery.
-
Retry Strategies
Handle transient failures with automatic, non-blocking retries and backoff.
-
Pausing Workflows
Suspend execution to wait for external events or human approval.
Quick Reference¶
| Guide | Use Case |
|---|---|
| Basic Queue | Minimal producer-consumer queue usage |
| Basic Workflow | Getting started, understanding the basics |
| S3 Queue | Object-storage-backed queues with bootstrap and sync semantics |
| Durable Workflows | Multi-step processes, crash recovery |
| Retry Strategies | Error handling, backoff |
| Pausing Workflows | Human-in-the-loop, external webhooks |
| Batch Processing | High throughput, many messages |
| Delayed Messages | Scheduled tasks, reminders, deferred work |
| Worker Management | Production deployment, scaling |
Prerequisites¶
Before following these guides, ensure you have:
- pgqrs installed (Installation Guide)
- A supported backend DSN
- The pgqrs schema installed with
admin.install()
Code Examples¶
All guides include complete, runnable code examples in both Rust and Python. Choose the tab for your preferred language.