IoTPy.tools.multicore package

Submodules

IoTPy.tools.multicore.run module

IoTPy.tools.multicore.run.run(name, template_name, module_name, dict_parts, queues)

Assembles a template and starts sink and source

Parameters:

name : str

Name of the part

template_name : str

Name of the template

module_name : str

Name of the module

dict_parts : dict

Dict containing values for fields

queues : dict

Dict of queues for each part

IoTPy.tools.multicore.sink module

IoTPy.tools.multicore.sink.addToQueue(value, queue, part_name, name, index=None)

Adds a value to a queue

Parameters:

value : object

Value to send

queue : multiprocessing.Queue

Queue to add value

part_name : str

Name of the part to send to

name : str

Name of the parameter

index : int, optional

Index of the parameter (the default is None)

IoTPy.tools.multicore.sink.sink(queues, fields, dict_parts)

Create sinks for each stream in fields

Parameters:

queues : dict

Dict of queues for each part

fields : list

List of field names

dict_parts : dict

Dict containing values for fields

IoTPy.tools.multicore.source module

IoTPy.tools.multicore.source.source(queue, dict_parts)

Listens on queue and adds values to streams

Parameters:

queue : multiprocessing.Queue

Queue to listen to

dict_parts : dict

Dict containing values for fields

Module contents