SolarNode Datum Queue
SolarNode has a DatumQueue service that acts as a central facility for processing all datum
captured by all data source plugins deployed in the SolarNode runtime. The queue can be configured
with various filters that can augment, modify, or discard the datum. The queue buffers the datum
for a short amount of time and then processes them sequentially in order of time, oldest to newest.
Data sources are polled for datum on a recurring schedule and those datum are then posted to and
stored in SolarNetwork. Data sources can also offer datum directly to the DatumQueue if they
emit datum based on external events. When offering datum directly, the datum can be tagged as
transient and they will then still be processed by the queue but will not be posted/stored in
SolarNetwork.
Plugins can also hook into the DatumQueue to be notified of each datum that gets processed. This
hook will receive all datum, including transient datum. An example plugin that makes use of this
feature is the SolarFlux Upload Service, which posts a copy of each datum to a
MQTT server.
Here is a screen shot of the datum queue settings available in the SolarNode UI:
