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