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)"