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: Beyonder Deutschland

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.4.1.tar.gz (88.4 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.4.1-py3-none-any.whl (12.1 kB view details)

Uploaded Python 3

File details

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

File metadata

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

File hashes

Hashes for django_queuebie-0.4.1.tar.gz
Algorithm Hash digest
SHA256 e512dd80d7fec925275bdb34f9d60ca96abe1f2fa4b779c7969b6b6701eb9bc3
MD5 ac0c6261e3c8c5b3462d7f3bac3ab536
BLAKE2b-256 99112a19a0109c599bb85825803a4b2ebcfde3770d03314f2d0ffaf7e965315e

See more details on using hashes here.

Provenance

The following attestation bundles were made for django_queuebie-0.4.1.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.4.1-py3-none-any.whl.

File metadata

File hashes

Hashes for django_queuebie-0.4.1-py3-none-any.whl
Algorithm Hash digest
SHA256 d9bd225d111c1c75172c85ee5f44303e88ed441d38496de850ade9118569cf78
MD5 347d469574ecd1dab7b23d5044eeeb49
BLAKE2b-256 024f97740e568d3ff8074798626a06766e284ce3ac50e676b1feb9d34897d131

See more details on using hashes here.

Provenance

The following attestation bundles were made for django_queuebie-0.4.1-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