Aggregator

Aggregation Strategy

class AggregationStrategy[source]

Bases: ABC

Aggregation Strategy

AggregationStrategy.__init__()

Aggregation Strategy Methods

abstract AggregationStrategy.append(context, event)[source]

Appends

Parameters

context :

event :

abstract AggregationStrategy.flush()[source]: Flushes

abstract AggregationStrategy.is_empty() → bool[source]: Description:

List Aggregation Strategy

class ListAggregationStrategy[source]

Bases: AggregationStrategy

Description: … test

ListAggregationStrategy.__init__()[source]: Description:

List Aggregation Strategy Methods

ListAggregationStrategy.append(context, event)[source]

Description:

Parameters

context :

event :

ListAggregationStrategy.flush()[source]

Description:

Returns: result

ListAggregationStrategy.is_empty() → bool[source]

Description:

Returns: Aggregated Event

String Aggregation Strategy

class StringAggregationStrategy(delimiter='\n')[source]

Bases: AggregationStrategy

Description:

StringAggregationStrategy.__init__()[source]: Description:

String Aggregation Strategy Methods

StringAggregationStrategy.append(context, event)[source]

Description:

Parameters

context :

eventData with time stamp stored in any data type usually is in JSON.: You can specify an event that is passed to the method.

StringAggregationStrategy.flush()[source]

Description:

Returns: result

StringAggregationStrategy.is_empty() → bool[source]

Description:

Returns: Aggregated event

Aggregator

class Aggregator(app, pipeline, aggregation_strategy: ~bspump.common.aggregator.AggregationStrategy = <bspump.common.aggregator.ListAggregationStrategy object>, id=None, config=None)[source]

Bases: Generator

Description:

Aggregator.__init__()[source]: Description:

Aggregator

Aggregator.flush()[source]

Description:

Returns

??

Aggregator.process(context, event)[source]

Description:

Parameters

context :

event :

async Aggregator.generate(context, aggregated_event, depth)[source]

Description:

Parameters

context :

aggregated_event :

depth :