Default template for PDM package
Project description
Superstream
Installation
pip install superstream
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
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
superstream_beta-1.0.4.tar.gz
(14.3 kB
view hashes)
Built Distribution
Close
Hashes for superstream_beta-1.0.4-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 145cff8c55521a4bf0c8c291f529267acdac12c53aead0dc934e609759d3e4de |
|
MD5 | 44de35c6c9d789a706fcda628f9cdaee |
|
BLAKE2b-256 | fbaf956588dac0cb91edc8563dcb836964d0e5411eb13918a771fcb177eaf4b4 |