Crypto Kafka serialize python library
Project description
kser-crypto
Kser module allow you to encrypt and decrypt messages in kafka using libsodium.
Quickstart
First, install kser-crypto using pip:
$ pip install kser-crypto[pykafka]
Note
Only kafka-python is implemented at the moment.
Examples
Make sure to have the environment variable KSER_SECRETBOX_KEY definded.
Consumer
from kser_crypto.python_kafka.consumer import CryptoConsumer consumer = CryptoConsumer(config=dict(...), topics=[...]) consumer.run()
Producer
import time from uuid import uuid4 from kser.schemas import Message from kser_crypto.python_kafka.producer import CryptoProducer producer = CryptoProducer(config=dict(...)) producer.send("test", Message(uuid=str(uuid4()), entrypoint="myTest")) time.sleep(1)
Requirements
- Python 3.x
- Libsodium
Documentations
- Project: http://kser.readthedocs.io/
- Libsodium: https://download.libsodium.org/doc/
- confluent-kafka-python: http://docs.confluent.io/current/clients/confluent-kafka-python
- kafka-python: http://kafka-python.readthedocs.io/en/master/
Other links
- PyPI: https://pypi.python.org/pypi/kser-crypto
- Project issues: https://github.com/cdumay/kser-crypto/issues
License
Licensed under MIT license (LICENSE or http://opensource.org/licenses/MIT)
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Filename, size | File type | Python version | Upload date | Hashes |
---|---|---|---|---|
Filename, size kser-crypto-0.1.8.tar.gz (4.6 kB) | File type Source | Python version None | Upload date | Hashes View |