bobocep.setup.simple.BoboSetupSimpleDistributed

class bobocep.setup.simple.BoboSetupSimpleDistributed(phenomena: List[bobocep.cep.phenom.phenom.BoboPhenomenon], handler: bobocep.cep.action.handler.BoboActionHandler, urn: str, devices: List[bobocep.dist.device.BoboDevice], aes_key: str, validator: Optional[bobocep.cep.engine.receiver.validator.BoboValidatorJSONable] = None, gen_event: Optional[bobocep.cep.gen.event.BoboGenEvent] = None)[source]

Bases: bobocep.setup.setup.BoboSetup

A simple setup to make distributed configuration easier.

__init__(phenomena: List[bobocep.cep.phenom.phenom.BoboPhenomenon], handler: bobocep.cep.action.handler.BoboActionHandler, urn: str, devices: List[bobocep.dist.device.BoboDevice], aes_key: str, validator: Optional[bobocep.cep.engine.receiver.validator.BoboValidatorJSONable] = None, gen_event: Optional[bobocep.cep.gen.event.BoboGenEvent] = None)[source]
Parameters

  • phenomena – A list of phenomena.

  • handler – An action handler.

  • urn – A URN that is unique across devices in the network.

  • devices – Devices in the network (including this device).

  • aes_key – The AES key to use for encryption.

  • validator – A data validator for the engine’s Receiver task. Default: BoboValidatorAll.

  • gen_event – An event generator. Default: None.

generate() → Tuple[bobocep.cep.engine.engine.BoboEngine, bobocep.dist.tcp.BoboDistributedTCP][source]
Returns

The CEP engine and distributed TCP instance with AES encryption.