Skip to main content

A simple and synchronous message queue for commands and events for Django

Project description

PyPI release Downloads Coverage Linting Coding Style Documentation Status

A simple and synchronous message queue for commands and events for Django.

PyPIGitHubFull documentation

Creator & Maintainer: Ambient Digital

Features

  • Split up your business logic in commands and events
  • Commands are imperatives telling your system what to do, events reflect that something has happened
  • Register light-weight functions via a decorator to listen to your commands and events
  • Message handlers receive the context of the message (command or event), providing an explicit API
  • No magic, no side effects since the queue works synchronously
import dataclasses

from queuebie.runner import handle_message
from queuebie.messages import Command, Event
from queuebie import message_registry


# Example command
@dataclasses.dataclass(kw_only=True)
class BuyProduct(Command):
    product_id: int
    customer_id: int
    price: float
    currency: str


# Example event
@dataclasses.dataclass(kw_only=True)
class ProductBought(Event):
    product_id: int
    customer_id: int


# Example handler
@message_registry.register_command(BuyProduct)
def handle_buy_product(context: BuyProduct) -> Event:
    # Here lives your business logic

    return ProductBought(
        product_id=context.product_id,
        customer_id=context.customer_id,
    )


# Start queue and process messages
handle_message(
    BuyProduct(
        product_id=product.id,
        customer_id=customer.id,
        price=12.99,
        currency="EUR",
    )
)

Installation

  • Install the package via pip:

    pip install django_queuebie

    or via uv:

    uv add django_queuebie

  • Add module to INSTALLED_APPS within the main django settings.py:

INSTALLED_APPS = (
    # ...
    "queuebie",
)

Releasing a new version

Releases are fully automated. Push a version tag and the pipeline will build, sign with Sigstore, publish to PyPI via Trusted Publishing, and create a GitHub Release — no API tokens needed.

git tag v<version>          # e.g. git tag v1.2.3
git push origin v<version>

Tags must start with v. Tags without the prefix won't trigger the pipeline.

First-time setup

Before the pipeline can run for the first time, an admin must:

  1. Create GitHub Environment pypi

    • Go to Settings → Environments → New environment, name it exactly pypi
    • Under Deployment branches and tags, add a tag rule with pattern v*
    • Optionally add required reviewers for a manual approval gate
  2. Configure PyPI Trusted Publisher

    • Go to PyPI → Project settings → Publishing → Add a new publisher
    • Fill in: Owner ambient-innovation, Repository django-queuebie, Workflow release.yml, Environment pypi

Publish to ReadTheDocs.io

  • Fetch the latest changes in GitHub mirror and push them
  • Trigger new build at ReadTheDocs.io (follow instructions in admin panel at RTD) if the GitHub webhook is not yet set up.

Maintenance

Please note that this package supports the ambient-package-update. So you don't have to worry about the maintenance of this package. This updater is rendering all important configuration and setup files. It works similar to well-known updaters like pyupgrade or django-upgrade.

To run an update, refer to the documentation page of the "ambient-package-update".

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

django_queuebie-0.3.10.tar.gz (85.6 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

django_queuebie-0.3.10-py3-none-any.whl (12.9 kB view details)

Uploaded Python 3

File details

Details for the file django_queuebie-0.3.10.tar.gz.

File metadata

  • Download URL: django_queuebie-0.3.10.tar.gz
  • Upload date:
  • Size: 85.6 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? Yes
  • Uploaded via: twine/6.1.0 CPython/3.13.7

File hashes

Hashes for django_queuebie-0.3.10.tar.gz
Algorithm Hash digest
SHA256 f7476f5055c92c5519e417586868a9270588bd80291ab75e87aa70dd1af57199
MD5 60a65e81ec94a9a3be082c4f138b87ba
BLAKE2b-256 a5cac95d1deee4d4fb381e1fa9f5f0ce2150dd5833b618aaaba62701641fe883

See more details on using hashes here.

Provenance

The following attestation bundles were made for django_queuebie-0.3.10.tar.gz:

Publisher: release.yml on ambient-innovation/django-queuebie

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file django_queuebie-0.3.10-py3-none-any.whl.

File metadata

File hashes

Hashes for django_queuebie-0.3.10-py3-none-any.whl
Algorithm Hash digest
SHA256 b2c942a4f3719dd53e8a70af40953ce7db2e8cdef82a75fe7babdcd3f3b0f8b9
MD5 727220aa3a838b3db3187d6f16bd02c6
BLAKE2b-256 947b316f20dea77d5dff7702f3862c127f7803734438496cce12fc58aa3a61b9

See more details on using hashes here.

Provenance

The following attestation bundles were made for django_queuebie-0.3.10-py3-none-any.whl:

Publisher: release.yml on ambient-innovation/django-queuebie

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page