Output Modules
Output modules are primarily used to store or send data to third-party systems. Output modules therefore do not have an output port - only an input port for receiving data.
Example
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
The
_run
method is called by a single thread and is therefore thread-safe.