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 :