superstream
Project description
Superstream
Installation
pip install superstream-py
Importing
import superstream
from superstream.types import Option
Producer
To use superstream
with kafka producer, first define the kafka and superstream configurations:
token = "<superstream-token>"
superstream_host = "<superstream-host>"
brokers = "<kafka-broker>"
topic = "<kafka-topic>"
config = {"bootstrap.servers": brokers}
options = Option(learning_factor=10, servers=brokers)
To initialize superstream, use init
function and pass the producer instance as an argument:
producer = Producer(config)
producer = superstream.init(token, superstream_host, config, options, producer=producer)
Finally, to produce messages to kafka, use produce
function:
person = {"name": "John Doe", "message": f"Hello, World!"}
producer.produce(
topic,
person,
on_delivery=delivery_callback,
headers={"key": "value"},
)
Consumer
To use superstream
with kafka consumer, first define the consumer configurations:
token = "<superstream-token>"
superstream_host = "<superstream-host>"
group = "<kafka-consumer-group>"
topics = ["<kafka-topic>"]
brokers = "<kafka-broker>"
config = {
"bootstrap.servers": brokers,
"group.id": group
}
options = Option(learning_factor=10, servers=brokers)
To initialize superstream, use init
function and pass the consumer instance as an argument:
consumer = Consumer(config)
consumer = superstream.init(token, superstream_host, config, options, consumer=consumer)
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
superstream_py-1.0.0.tar.gz
(14.3 kB
view hashes)
Built Distribution
Close
Hashes for superstream_py-1.0.0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 569f8d41209a6452abcca0b52cf2e29fd55047ccbb49a3736d0253d031293449 |
|
MD5 | c2042b1abe237c894fb76e24bd8283e9 |
|
BLAKE2b-256 | 5ca45afef97ab86835fb3654ed49b2bde673192acc725cf9612414e9e4fb31b2 |