AgentGenerator

class kafkaaggregator.generator.AgentGenerator(configfile: Path, aggregated_topic: str)

Bases: object

Generate Faust agents from a list of source topics.

Creates the context and renders the agents code template.

Parameters:

source_topic_names (list) – List of source topic names.

Attributes Summary

logger
template	Get the agent template.

Methods Summary

run()

Run agents code generation.

Attributes Documentation

logger = <Logger kafkaaggregator (WARNING)>

template

Get the agent template.

Methods Documentation

async run() → None

Run agents code generation.