sp.processor.sample()
Definition
New in version 7.0: Returns arrays of sampled results from a currently running Stream Processor on the current Stream Processing Instance.
Compatibility
This method is supported in Atlas Stream Processing Instances.
Syntax
The sp.processor.sample()
method has the following syntax:
sp.processor.sample()
Command Fields
sp.processor.sample()
takes no fields.
Behavior
sp.processor.sample()
returns arrays of sampled results
from the named, currently running stream processor to STDOUT
. This
command runs continuously until you cancel it using CTRL-C
, or until
the returned samples cumulatively reach 40 MB
.
Access Control
The user running sp.processor.sample()
must have the
atlasAdmin
role.
Example
The following example shows an expected response from calling sp.solarDemo.sample()
to sample from a stream processor called solarDemo
:
sp.solarDemo.sample()
{ _id: { device_id: 'device_5' }, max_temp: 8, max_watts: 66, min_watts: 66, avg_watts: 66, median_watts: 66, _stream_meta: { window: { start: ISODate('2024-03-19T22:09:10.000Z'), end: ISODate('2024-03-19T22:09:20.000Z') } } } { _id: { device_id: 'device_0' }, max_temp: 18, max_watts: 210, min_watts: 68, avg_watts: 157, median_watts: 193, _stream_meta: { window: { start: ISODate('2024-03-19T22:09:10.000Z'), end: ISODate('2024-03-19T22:09:20.000Z') } } } { _id: { device_id: 'device_10' }, max_temp: 21, max_watts: 128, min_watts: 4, avg_watts: 66, median_watts: 4, _stream_meta: { window: { start: ISODate('2024-03-19T22:09:10.000Z'), end: ISODate('2024-03-19T22:09:20.000Z') } } } { _id: { device_id: 'device_9' }, max_temp: 10, max_watts: 227, min_watts: 66, avg_watts: 131.4, median_watts: 108, _stream_meta: { window: { start: ISODate('2024-03-19T22:09:10.000Z'), end: ISODate('2024-03-19T22:09:20.000Z') } } }