Closed markheger closed 3 years ago
https://streamsxtopology.readthedocs.io/en/v1.17.1/streamsx.topology.topology.html#streamsx.topology.topology.Stream.split
See msgs and msg:
msgs
msg
msgs = topo.source(ReadMessages()) SEVS = {'H':0, 'M':1, 'L':2} severities = msg.split(3, lambda SEVS.get(msg.get('SEV'), -1), names=['high','medium','low'], name='SeveritySplit') high_severity = severities.high high_severity.for_each(SendAlert()) medium_severity = severities.medium medium_severity.for_each(LogMessage()) low_severity = severities.low low_severity.for_each(Archive())
https://streamsxtopology.readthedocs.io/en/v1.17.1/streamsx.topology.topology.html#streamsx.topology.topology.Stream.split
See
msgs
andmsg
: