Package io.openems.backend.timedata.timescaledb.internal.read

Class TimescaledbReadHandler

java.lang.Object

io.openems.backend.timedata.timescaledb.internal.read.TimescaledbReadHandler

public class TimescaledbReadHandler
extends Object

Constructor Summary

Constructors

Constructor	Description
TimescaledbReadHandler(Config config)

Method Summary

Modifier and Type	Method	Description
void	deactivate()	Called by TimescaledbImpl deactivate().
Map<String,Number>	debugMetrics()	Returns a DebugMetrics map.
Map<ChannelAddress,com.google.gson.JsonElement>	getChannelValues(String edgeId, Set<ChannelAddress> channels)	Gets the latest values for the given ChannelAddresses.
SortedMap<ZonedDateTime,SortedMap<ChannelAddress,com.google.gson.JsonElement>>	queryHistoricData(String edgeId, ZonedDateTime fromDate, ZonedDateTime toDate, Set<ChannelAddress> channels, Resolution resolution)	See CommonTimedataService.queryHistoricData(String, ZonedDateTime, ZonedDateTime, Set, Resolution).
SortedMap<ChannelAddress,com.google.gson.JsonElement>	queryHistoricEnergy(String edgeId, ZonedDateTime fromDate, ZonedDateTime toDate, Set<ChannelAddress> channels)	See CommonTimedataService.queryHistoricEnergy(String, ZonedDateTime, ZonedDateTime, Set).
SortedMap<ZonedDateTime,SortedMap<ChannelAddress,com.google.gson.JsonElement>>	queryHistoricEnergyPerPeriod(String edgeId, ZonedDateTime fromDate, ZonedDateTime toDate, Set<ChannelAddress> channels, Resolution resolution)	See CommonTimedataService.queryHistoricEnergyPerPeriod(String, ZonedDateTime, ZonedDateTime, Set, Resolution).
void	setSchema(Schema schema)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TimescaledbReadHandler

public TimescaledbReadHandler(Config config)
                       throws SQLException

Throws:

SQLException

Method Details

deactivate

public void deactivate()

Called by TimescaledbImpl deactivate().

setSchema

public void setSchema(Schema schema)

queryHistoricData

public SortedMap<ZonedDateTime,SortedMap<ChannelAddress,com.google.gson.JsonElement>> queryHistoricData(String edgeId,
 ZonedDateTime fromDate,
 ZonedDateTime toDate,
 Set<ChannelAddress> channels,
 Resolution resolution)
                                                                                                 throws OpenemsError.OpenemsNamedException

See CommonTimedataService.queryHistoricData(String, ZonedDateTime, ZonedDateTime, Set, Resolution).

Parameters:

edgeId - the Edge-ID; or null query all

fromDate - the From-Date

toDate - the To-Date

channels - the Channels

resolution - the Resolution

Returns:

the query result

Throws:

OpenemsError.OpenemsNamedException

queryHistoricEnergy

public SortedMap<ChannelAddress,com.google.gson.JsonElement> queryHistoricEnergy(String edgeId,
 ZonedDateTime fromDate,
 ZonedDateTime toDate,
 Set<ChannelAddress> channels)
                                                                          throws OpenemsError.OpenemsNamedException

See CommonTimedataService.queryHistoricEnergy(String, ZonedDateTime, ZonedDateTime, Set).

Parameters:

edgeId - the Edge-ID; or null query all

fromDate - the From-Date

toDate - the To-Date

channels - the Channels

Returns:

the query result

Throws:

OpenemsError.OpenemsNamedException

queryHistoricEnergyPerPeriod

public SortedMap<ZonedDateTime,SortedMap<ChannelAddress,com.google.gson.JsonElement>> queryHistoricEnergyPerPeriod(String edgeId,
 ZonedDateTime fromDate,
 ZonedDateTime toDate,
 Set<ChannelAddress> channels,
 Resolution resolution)
                                                                                                            throws OpenemsError.OpenemsNamedException

See CommonTimedataService.queryHistoricEnergyPerPeriod(String, ZonedDateTime, ZonedDateTime, Set, Resolution).

Parameters:

edgeId - the Edge-ID; or null query all

fromDate - the From-Date

toDate - the To-Date

channels - the Channels

resolution - the Resolution

Returns:

the query result

Throws:

OpenemsError.OpenemsNamedException

getChannelValues

public Map<ChannelAddress,com.google.gson.JsonElement> getChannelValues(String edgeId,
 Set<ChannelAddress> channels)

Gets the latest values for the given ChannelAddresses.

Parameters:

edgeId - The unique Edge-ID

channels - The ChannelAddresses

Returns:

the values

debugMetrics

public Map<String,Number> debugMetrics()

Returns a DebugMetrics map.

Returns:

metrics