You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@streampipes.apache.org by GitBox <gi...@apache.org> on 2022/11/26 13:33:31 UTC
[GitHub] [streampipes] dominikriemer opened a new issue, #365: New Python Wrapper
dominikriemer opened a new issue, #365:
URL: https://github.com/apache/streampipes/issues/365
*Apache StreamPipes*
Apache StreamPipes (incubating) is a self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams. StreamPipes offers several modules including StreamPipes Connect to easily connect data from industrial IoT sources, the Pipeline Editor to quickly create processing pipelines and several visualization modules for live and historic data exploration. Under the hood, StreamPipes utilizes an event-driven microservice paradigm of standalone, so-called analytics microservices making the system easy to extend for individual needs.
*Background*
Current wrappers such as standalone (JVM, Siddhi) or distributed (Flink) already allow to develop new processors in the given runtime environment. The idea is to extend the list of standalone runtime wrappers to also support pure Python processors. We already got a minimal working version that however is pretty inflexible and still relies on Java as a proxy to the pipeline management in the backend service for the model declaration in the setup phase ( capabilities, requirements, static properties of a processor) as well as the actual invocation in the execution phase ( receiving specific configuration from pipeline management when pipeline is started). This issue is to track the status of the development.
*Tasks*
- Add API endpoints as an interface for registration/invocation ( partly done)
- Port relevant model classes over to Python (declaration **** invocation descriptions)
- Implement support for various transport protocols and transport formats
- Implement dev friendly alternative to Java builder pattern for model declaration
- Implement overall runtime logic for Python wrapper
*Relevant Skills*
0. Don't be afraid! We'll guide you through your first steps with StreamPipes.
- Excellent Python skills
- Excellent understanding of stream processing paradigm incl. message broker such as Kafka, MQTT, etc
- Good Understanding of RESTful web services (HTTP, etc.)
- Basic Java skills to understand existing wrapper logic
*Info*
* SIP-02 to collect design decisions https://cwiki.apache.org/confluence/display/STREAMPIPES/SIP-02****Python****wrapper
* Current python runtime wrapper implementation: [https://github.com/apache/incubator-streampipes/tree/dev/streampipes-wrapper-python](https://github.com/apache/incubator-streampipes/tree/dev/streampipes-wrapper-python)
* POC example: [https://github.com/apache/incubator-streampipes-examples/tree/dev/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/python](https://github.com/apache/incubator-streampipes-examples/tree/dev/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/python)
*Mentor*
Patrick Wiener, PPMC Apache StreamPipes (wiener@apache.org)
Imported from Jira [STREAMPIPES-174](https://issues.apache.org/jira/browse/STREAMPIPES-174). Original Jira may contain additional context.
Reported by: wiener.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscribe@streampipes.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [streampipes] dominikriemer commented on issue #365: New Python Wrapper
Posted by GitBox <gi...@apache.org>.
dominikriemer commented on issue #365:
URL: https://github.com/apache/streampipes/issues/365#issuecomment-1328047441
The following subtask(s) are associated with this issue: #366, #367, #368, #369, #370, #371, #372, #373
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscribe@streampipes.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] New Python Wrapper (streampipes)
Posted by "bossenti (via GitHub)" <gi...@apache.org>.
bossenti closed issue #365: New Python Wrapper
URL: https://github.com/apache/streampipes/issues/365
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscribe@streampipes.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org