-
Notifications
You must be signed in to change notification settings - Fork 24
ICP4D Updates for Python development guide
markheger edited this page Dec 11, 2020
·
38 revisions
Proposed additions in bold
Completed additions in strikethrough
- Installing Python APIs
- Developing for the IBM Streaming Analytics service
Developing for ICP4Data
- Developing with an IBM Streams installation
- Common Streams operations
4.1 Connecting to known data sources-
4.x AggregationCreating a window usinglast()
orbatch()
-
Simple aggregation usingWindow.aggregate
(use pandas)Partitioned windows
4.x Newfilter
option for splitting streams in matching and non-matching streams4.x Newsplit
function for splitting streams4.x Data model - namedtuples vs streams schema etc-
4.x Using viewsUsing views in a notebook
- API features:
Scalablity, fault toleranceUDP (parallel
fns)Fault tolerance (consistent regions)
- The Python REST API
connect to CP4D examples
-
Using SPL Operators in Python
- Using Aggregate, Functor, Deduplicate etc. from streamsx.standard
Invoke SPL operators: reference Streams-SPLToolkitsTutorial.ipynb from sample.starter_notebooks
-
AI - CP4D services
- Connecting to Watson Machine learning (streamsx.wml)
- Connecting to Speech to Text Gateway (streamsx.sttgateway)
- Scoring a model in Python
-
Improving performance - best practice
- Reduce latency using
low_latency
- Using
isolate
- resource tags?
- Saving credentials in app configs - a best practice to make code reusable
- Reduce latency using
- Metrics/Logging