updates to python wrapper README
@@ -42,17 +42,44 @@ class HelloWorldProcessor(EventProcessor):
This processor received an event `dict` and adds a new `greeting` field including the message `hello world` to it.
#### Add to processor dict
````
-from streampipes.core import StandaloneSubmitter
+from streampipes.core import StandaloneModelSubmitter
from streampipes.manager import Declarer
+from streampipes.model.pipeline_element_config import Config
+
+from helloworld import HelloWorldProcessor
def main():
+ # Configurations to be stored in key-value store (consul)
+ config = Config(app_id='pe/org.apache.streampipes.processor.python')
+
+ config.register(type='host',
+ env_key='SP_HOST',
+ default='processor-python',
+ description='processor hostname')
+
+ config.register(type='port',
+ env_key='SP_PORT',
+ default=8090,
+ description='processor port')
+
+ config.register(type='service',
+ env_key='SP_SERVICE_NAME',
+ default='Python Processor',
+ description='processor service name')
+
processors = {
'org.apache.streampipes.processors.python.helloworld': HelloWorldProcessor,
}
+ # Declarer
+ # add the dict of processors to the Declarer
+ # This is an abstract class that holds the specified processors
Declarer.add(processors=processors)
- StandaloneSubmitter.init()
+
+ # StandaloneModelSubmitter
+ # Initializes the REST api
+ StandaloneModelSubmitter.init(config=config)
if __name__ == '__main__':
