Ausgangsmodule
Ausgangsmodule werden in erster Linie dazu verwendet, Daten zu speichern oder an Drittsysteme zu senden. Ausgangsmodule verfügen daher nicht über einen Ausgangsport, sondern nur über einen Eingangsport für den Empfang von Daten.
Beispiel
from modules.base.outputs.base import AbstractOutputModule, models
class OutputModule(AbstractOutputModule):
...
def __init__(self, configuration: Configuration):
super().__init__(configuration=configuration)
def _run(self, data: models.Data):
"""
This method is called when new data needs to be processed.
:param data: The data object to be processed.
"""
self.logger.info(data)
Info
Die Methode
_run
wird von einem einzigen Thread aufgerufen und ist daher thread-sicher.