csrd.message
Transport-agnostic message abstractions for publish/consume workflows.
Why this package exists
- Provide a stable API for messaging behavior independent of broker choice
- Enable optional broker installs with extras (
rabbit,kafka) - Keep service code portable across RabbitMQ and Kafka backends
Installation
# Core abstractions only
uv add csrd-message
# RabbitMQ support
uv add 'csrd-message[rabbit]'
# Kafka support
uv add 'csrd-message[kafka]'
# Both brokers
uv add 'csrd-message[all]'
Important extras note
Python extras are part of the same PyPI project, not a separate project.
csrd-messageandcsrd-message[rabbit]resolve to the same package name (csrd-message)- The extra only adds optional dependencies declared by this package
- Extras do not create new package names on PyPI
Initial API surface
Message- immutable message envelopeMessagePublisher- protocol for publishing messagesMessageConsumer- protocol for consuming messagesAcknowledgement- ack/retry/reject semantics
Quick example
from csrd.message import Acknowledgement, Message, MessagePublisher
class InMemoryPublisher:
async def publish(self, message: Message) -> None:
print(message.topic, message.payload)
async def send(publisher: MessagePublisher) -> None:
await publisher.publish(Message(topic="orders.created", payload={"order_id": "o-1"}))
Status
This is a v0 skeleton package to reserve naming and establish contracts. Concrete RabbitMQ/Kafka adapters are planned follow-up work, while the shared envelope/protocol API is considered stable for early adopters.
1 maintainer
Metadata
1 maintainer
Release files for csrd-message 0.5.30
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| csrd_message-0.5.30.tar.gz | 10.1 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| csrd_message-0.5.30-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 20.6 kB
Release files / csrd_message-0.5.30.tar.gz
| Download URL | csrd_message-0.5.30.tar.gz |
|---|---|
| Size | 10.1 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
8a025312ef82e0d1dae1a7f58fc45072ac33a3aa9e1c8444cbd7132f15b2db3c
|
|
BLAKE2b-256 checksum How to use checksums |
408b71c1c55492159ea7e6a795ae9a2f639d088db2110705e2b4db2d2ba6df08
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
Yes |
| Uploaded via |
twine/6.1.0 CPython/3.13.14
|
Provenance
Provenance describes where a file came from. On PyPI, provenance is shared via attestations, which provide a verifiable record of the build or publishing details. View details, limitations and caveats.
PyPI Publish Attestation
PyPI verified that this artifact, at this checksum, originated from the publisher listed below.
Signed by GitHub Actions, verified by PyPI on Jul 26, 2026.
Transparency logRelease files / csrd_message-0.5.30-py3-none-any.whl
| Download URL | csrd_message-0.5.30-py3-none-any.whl |
|---|---|
| Size | 10.4 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
28e0d9b8c67c60333585a5edc37b43cee404b7c54a3cbd7c25729a4a933ad59f
|
|
BLAKE2b-256 checksum How to use checksums |
66ffed9111d49a8eb75de24da0393f011feae11946576ecb76816fdffc110def
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
Yes |
| Uploaded via |
twine/6.1.0 CPython/3.13.14
|
Provenance
Provenance describes where a file came from. On PyPI, provenance is shared via attestations, which provide a verifiable record of the build or publishing details. View details, limitations and caveats.
PyPI Publish Attestation
PyPI verified that this artifact, at this checksum, originated from the publisher listed below.
Signed by GitHub Actions, verified by PyPI on Jul 26, 2026.
Transparency log
