Class InfluxTimedataImpl

    • Constructor Detail

      • InfluxTimedataImpl

        public InfluxTimedataImpl()
    • Method Detail

      • handleEvent

        public void handleEvent​(org.osgi.service.event.Event event)
        Specified by:
        handleEvent in interface org.osgi.service.event.EventHandler
      • collectAndWriteChannelValues

        protected void collectAndWriteChannelValues()
      • queryHistoricEnergyPerPeriod

        public java.util.SortedMap<java.time.ZonedDateTime,​java.util.SortedMap<ChannelAddress,​>> queryHistoricEnergyPerPeriod​(java.lang.String edgeId,
                                                                                                                                                                     java.time.ZonedDateTime fromDate,
                                                                                                                                                                     java.time.ZonedDateTime toDate,
                                                                                                                                                                     java.util.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
        edgeId - the Edge-ID; or null query all
        fromDate - the From-Date
        toDate - the To-Date
        channels - the Channels
        resolution - the Resolution
        the query result
      • getLatestValue

        public java.util.concurrent.CompletableFuture<java.util.Optional<java.lang.Object>> getLatestValue​(ChannelAddress channelAddress)
        Description copied from interface: Timedata
        Gets the latest known value for the given ChannelAddress.
        Specified by:
        getLatestValue in interface Timedata
        channelAddress - the ChannelAddress to be queried
        the latest known value or Empty