Kombu Fernet Serializers

This library registers a set of Kombu serializers which take those built into Kombu and symmetrically encrypts them using Fernet.

The encryption key is accessed via the KOMBU_FERNET_KEY environment variable. To set the encryption key:

import os
from cryptography.fernet import Fernet

key = Fernet.generate_key()
os.environ['KOMBU_FERNET_KEY'] = key

To try it out, start a redis server and from the example directory, run:

pip install celery redis
celery -A tasks worker

Then from another shell:

python -c "from tasks import add; add.delay(1, 2)"