Package io.openems.backend.common.timedata

Interface BackendTimedata

All Superinterfaces:

CommonTimedataService

All Known Subinterfaces:

Timedata, TimedataManager

All Known Implementing Classes:

AggregatedInflux, TimedataDummy, TimedataInfluxDb, TimedataManagerImpl, TimedataTimescaleDb

@ProviderType
public interface BackendTimedata
extends CommonTimedataService

Method Summary

Modifier and Type	Method	Description
default SortedMap<ChannelAddress,com.google.gson.JsonElement>	queryFirstValueBefore(String edgeId, ZonedDateTime date, Set<ChannelAddress> channels)	Queries the latest values which are before the given ZonedDateTime.
void	write(String edgeId, AggregatedDataNotification data)	Sends the data points to the Timedata service.
void	write(String edgeId, ResendDataNotification data)	Sends the data points to the Timedata service.
void	write(String edgeId, TimestampedDataNotification data)	Sends the data points to the Timedata service.

Methods inherited from interface io.openems.common.timedata.CommonTimedataService

handleQueryHistoricTimeseriesExportXlxsRequest, queryHistoricData, queryHistoricData, queryHistoricEnergy, queryHistoricEnergyPerPeriod

Method Details

write

void write(String edgeId,
 TimestampedDataNotification data)

Sends the data points to the Timedata service.

Parameters:

edgeId - The unique Edge-ID

data - Table of timestamp (epoch in milliseconds), Channel-Address and the Channel value as JsonElement. Sorted by timestamp.

write

void write(String edgeId,
 AggregatedDataNotification data)

Sends the data points to the Timedata service.

Parameters:

edgeId - The unique Edge-ID

data - Table of timestamp (epoch in milliseconds), Channel-Address and the Channel value as AggregatedData. Sorted by timestamp.

write

void write(String edgeId,
 ResendDataNotification data)

Sends the data points to the Timedata service.

Parameters:

edgeId - The unique Edge-ID

data - Table of timestamp (epoch in milliseconds), Channel-Address and the Channel value as ResendData. Sorted by timestamp.

queryFirstValueBefore

default SortedMap<ChannelAddress,com.google.gson.JsonElement> queryFirstValueBefore(String edgeId,
 ZonedDateTime date,
 Set<ChannelAddress> channels)
                                                                             throws OpenemsError.OpenemsNamedException

Queries the latest values which are before the given ZonedDateTime.

Parameters:

edgeId - the id of the edge

date - the bounding date exclusive

channels - the channels

Returns:

the channel values

Throws:

OpenemsError.OpenemsNamedException - on error