snews_pt.messages

Classes

Publisher

Functions

test()

Module Contents

class snews_pt.messages.Publisher(kafka_topic, auth=True)

kafka_topic

auth = True

message_queue = []

add_message(message: dict | snews.models.messages.MessageBase, verbose: int = 0) → None

This method will add a message to the message queue.

Parameters:

• message (dict or snews.messages.MessageBase) – observation message.

• verbose (int) – verbosity level. 0: no output, 1: print simple feedback, 2: print message details.

send(verbose: int = 0) → None

This method will send the messages to the Kafka topic.

Parameters:

verbose (int) – verbosity level. 0: no output, 1: print simple feedback, 2: print message details.

snews_pt.messages.test()