Package io.openems.edge.timedata.influxdb

Class TimedataInfluxDbImpl

java.lang.Object

io.openems.edge.common.component.AbstractOpenemsComponent

io.openems.edge.timedata.influxdb.TimedataInfluxDbImpl

All Implemented Interfaces:

CommonTimedataService, OpenemsComponent, Timedata, TimedataInfluxDb, org.osgi.service.event.EventHandler

public class TimedataInfluxDbImpl
extends AbstractOpenemsComponent
implements TimedataInfluxDb, Timedata, OpenemsComponent, org.osgi.service.event.EventHandler

Provides read and write access to InfluxDB.

Nested Class Summary

Nested classes/interfaces inherited from interface io.openems.edge.common.component.OpenemsComponent

OpenemsComponent.ChannelId

Nested classes/interfaces inherited from interface io.openems.edge.timedata.api.Timedata

Timedata.ChannelId

Nested classes/interfaces inherited from interface io.openems.edge.timedata.influxdb.TimedataInfluxDb

TimedataInfluxDb.ChannelId

Constructor Summary

Constructors

Constructor	Description
TimedataInfluxDbImpl()

Method Summary

Modifier and Type	Method	Description
protected void	collectAndWriteChannelValues()
protected void	deactivate()	Handles @Deactivate of implementations.
CompletableFuture<Optional<Object>>	getLatestValue(ChannelAddress channelAddress)	Gets the latest known value for the given ChannelAddress.
Timeranges	getResendTimeranges(ChannelAddress notSendChannel, long lastResendTimestamp)	Gets the Timeranges to data which got not send.
void	handleEvent(org.osgi.service.event.Event event)
SortedMap<ZonedDateTime,SortedMap<ChannelAddress,com.google.gson.JsonElement>>	queryHistoricData(String edgeId, ZonedDateTime fromDate, ZonedDateTime toDate, Set<ChannelAddress> channels, Resolution resolution)	Queries historic data.
SortedMap<ChannelAddress,com.google.gson.JsonElement>	queryHistoricEnergy(String edgeId, ZonedDateTime fromDate, ZonedDateTime toDate, Set<ChannelAddress> channels)	Queries historic energy.
SortedMap<ZonedDateTime,SortedMap<ChannelAddress,com.google.gson.JsonElement>>	queryHistoricEnergyPerPeriod(String edgeId, ZonedDateTime fromDate, ZonedDateTime toDate, Set<ChannelAddress> channels, Resolution resolution)	Queries historic energy per period.
SortedMap<Long,SortedMap<ChannelAddress,com.google.gson.JsonElement>>	queryResendData(ZonedDateTime fromDate, ZonedDateTime toDate, Set<ChannelAddress> channels)	Queries data to resend.

Methods inherited from class io.openems.edge.common.component.AbstractOpenemsComponent

_channel, activate, activate, addChannel, addChannels, addChannels, alias, channels, getComponentContext, id, isEnabled, logDebug, logError, logInfo, logWarn, modified, removeChannel

Methods inherited from class java.lang.Object

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

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

handleQueryHistoricTimeseriesExportXlxsRequest, queryHistoricData

Methods inherited from interface io.openems.edge.common.component.OpenemsComponent

_channel, _getChannelAs, alias, channel, channel, channels, debugLog, getComponentContext, getState, getStateChannel, hasFaults, id, isEnabled, serviceFactoryPid, servicePid

Methods inherited from interface io.openems.edge.timedata.api.Timedata

getLatestValueOfNotExistingChannel

Constructor Details

TimedataInfluxDbImpl

public TimedataInfluxDbImpl()

Method Details

deactivate

protected void deactivate()

Description copied from class: AbstractOpenemsComponent

Handles @Deactivate of implementations. Prints log output.

Overrides:

deactivate in class AbstractOpenemsComponent

handleEvent

public void handleEvent(org.osgi.service.event.Event event)

Specified by:

handleEvent in interface org.osgi.service.event.EventHandler

collectAndWriteChannelValues

protected void collectAndWriteChannelValues()

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

Description copied from interface: CommonTimedataService

Queries historic data.

Specified by:

queryHistoricData in interface CommonTimedataService

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; possibly null

Throws:

OpenemsError.OpenemsNamedException

queryHistoricEnergy

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

Description copied from interface: CommonTimedataService

Queries historic energy.

Specified by:

queryHistoricEnergy in interface CommonTimedataService

Parameters:

edgeId - the Edge-ID; or null query all

fromDate - the From-Date

toDate - the To-Date

channels - the Channels

Returns:

the query result; possibly null

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

Description copied from interface: CommonTimedataService

Queries historic energy per period.

This is for use-cases where you want to get the energy for each period (with Resolution) per Channel, e.g. to visualize energy in a histogram chart. For each period the energy is calculated by subtracting first value of the period from the last value of the period.

Specified by:

queryHistoricEnergyPerPeriod in interface CommonTimedataService

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; possibly null

Throws:

OpenemsError.OpenemsNamedException

queryResendData

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

Description copied from interface: Timedata

Queries data to resend.

Specified by:

queryResendData in interface Timedata

Parameters:

fromDate - the start date

toDate - the end date

channels - the channels to resend

Returns:

the query result; possibly null

Throws:

OpenemsError.OpenemsNamedException - on error

getLatestValue

public CompletableFuture<Optional<Object>> getLatestValue(ChannelAddress channelAddress)

Description copied from interface: Timedata

Gets the latest known value for the given ChannelAddress.

Specified by:

getLatestValue in interface Timedata

Parameters:

channelAddress - the ChannelAddress to be queried

Returns:

the latest known value or Empty

getResendTimeranges

public Timeranges getResendTimeranges(ChannelAddress notSendChannel,
 long lastResendTimestamp)
                               throws OpenemsError.OpenemsNamedException

Description copied from interface: Timedata

Gets the Timeranges to data which got not send. The not send data gets determined with the notSendChannel and the lastResendTimestamp.

Specified by:

getResendTimeranges in interface Timedata

Parameters:

notSendChannel - the channel with the timestamps where the data got not send

lastResendTimestamp - the timestamp of the last resend; negativ if there is no lastResendTimestamp

Returns:

the Timeranges

Throws:

OpenemsError.OpenemsNamedException - on error