eta_utility.connectors package

Submodules

• eta_utility.connectors.base_classes module
  • SubscriptionHandler
    • SubscriptionHandler.push()
  • Connection
    • Connection.usr
    • Connection.pwd
    • Connection.selected_nodes
    • Connection.from_node()
    • Connection.from_nodes()
    • Connection.read()
    • Connection.write()
    • Connection.subscribe()
    • Connection.close_sub()
    • Connection.url
  • BaseConnection
  • SeriesConnection
    • SeriesConnection.read_series()
    • SeriesConnection.subscribe_series()
  • BaseSeriesConnection
• eta_utility.connectors.common module
  • connections_from_nodes()
  • name_map_from_node_sequence()
• eta_utility.connectors.cumulocity module
  • CumulocityConnection
    • CumulocityConnection.read()
    • CumulocityConnection.write()
    • CumulocityConnection.subscribe()
    • CumulocityConnection.read_series()
    • CumulocityConnection.subscribe_series()
    • CumulocityConnection.create_device()
    • CumulocityConnection.get_measurement_ids_by_device()
    • CumulocityConnection.close_sub()
    • CumulocityConnection.timestr_from_datetime()
    • CumulocityConnection.get_auth_header()
• eta_utility.connectors.emonio module
  • EmonioConnection
    • EmonioConnection.read()
    • EmonioConnection.write()
    • EmonioConnection.subscribe()
    • EmonioConnection.close_sub()
    • EmonioConnection.check_warnings_and_errors()
  • NodeModbusFactory
    • NodeModbusFactory.get_default_node()
    • NodeModbusFactory.get_discrete_input_node()
    • NodeModbusFactory.get_warnings_errors_node()
• eta_utility.connectors.eneffco module
  • EnEffCoConnection
    • EnEffCoConnection.API_PATH
    • EnEffCoConnection.from_ids()
    • EnEffCoConnection.read()
    • EnEffCoConnection.write()
    • EnEffCoConnection.read_info()
    • EnEffCoConnection.subscribe()
    • EnEffCoConnection.read_series()
    • EnEffCoConnection.subscribe_series()
    • EnEffCoConnection.close_sub()
    • EnEffCoConnection.id_from_code()
    • EnEffCoConnection.timestr_from_datetime()
• eta_utility.connectors.entso_e module
  • ENTSOEConnection
    • ENTSOEConnection.API_PATH
    • ENTSOEConnection.read()
    • ENTSOEConnection.write()
    • ENTSOEConnection.subscribe()
    • ENTSOEConnection.read_series()
    • ENTSOEConnection.subscribe_series()
    • ENTSOEConnection.close_sub()
• eta_utility.connectors.forecast_solar module
  • ForecastSolarConnection
    • ForecastSolarConnection.url_params
    • ForecastSolarConnection.query_params
    • ForecastSolarConnection.read()
    • ForecastSolarConnection.write()
    • ForecastSolarConnection.subscribe()
    • ForecastSolarConnection.read_series()
    • ForecastSolarConnection.subscribe_series()
    • ForecastSolarConnection.close_sub()
    • ForecastSolarConnection.timestr_from_datetime()
    • ForecastSolarConnection.route_valid()
    • ForecastSolarConnection.calculate_watt_hours_period()
    • ForecastSolarConnection.cumulative_watt_hours_per_day()
    • ForecastSolarConnection.summarize_watt_hours_per_day()
• eta_utility.connectors.live_connect module
  • LiveConnect
    • LiveConnect.name
    • LiveConnect.start_time
    • LiveConnect.step_size
    • LiveConnect.steps_counter
    • LiveConnect.max_error_count
    • LiveConnect.error_count
    • LiveConnect.from_json()
    • LiveConnect.from_dict()
    • LiveConnect.nodes
    • LiveConnect.step()
    • LiveConnect.write()
    • LiveConnect.read()
    • LiveConnect.activate()
    • LiveConnect.deactivate()
    • LiveConnect.close()
• eta_utility.connectors.modbus module
  • ModbusConnection
    • ModbusConnection.read()
    • ModbusConnection.write()
    • ModbusConnection.subscribe()
    • ModbusConnection.close_sub()
• eta_utility.connectors.node module
  • NodeMeta
  • Node
    • Node.name
    • Node.url
    • Node.url_parsed
    • Node.protocol
    • Node.usr
    • Node.pwd
    • Node.interval
    • Node.dtype
    • Node.evolve()
    • Node.as_dict()
    • Node.as_tuple()
    • Node.from_dict()
    • Node.from_excel()
    • Node.get_eneffco_nodes_from_codes()
  • NodeLocal
  • NodeModbus
    • NodeModbus.mb_slave
    • NodeModbus.mb_register
    • NodeModbus.mb_channel
    • NodeModbus.mb_bit_length
    • NodeModbus.mb_byteorder
    • NodeModbus.mb_wordorder
  • NodeOpcUa
    • NodeOpcUa.opc_id
    • NodeOpcUa.opc_path_str
    • NodeOpcUa.opc_ns
    • NodeOpcUa.opc_id_type
    • NodeOpcUa.opc_name
    • NodeOpcUa.opc_path
    • NodeOpcUa.evolve()
  • NodeEnEffCo
    • NodeEnEffCo.eneffco_code
  • NodeEntsoE
    • NodeEntsoE.endpoint
    • NodeEntsoE.bidding_zone
  • NodeCumulocity
    • NodeCumulocity.device_id
    • NodeCumulocity.measurement
    • NodeCumulocity.fragment
  • NodeWetterdienst
    • NodeWetterdienst.parameter
    • NodeWetterdienst.station_id
    • NodeWetterdienst.latlon
    • NodeWetterdienst.number_of_stations
  • NodeWetterdienstObservation
    • NodeWetterdienstObservation.interval
    • NodeWetterdienstObservation.convert_interval_to_resolution()
  • NodeWetterdienstPrediction
    • NodeWetterdienstPrediction.mosmix_type
  • EmonioConstants
    • EmonioConstants.PARAMETER_MAP
    • EmonioConstants.UPPER_CASED
    • EmonioConstants.PHASE_MAP
  • NodeEmonio
    • NodeEmonio.address
    • NodeEmonio.phase
  • NodeForecastSolar
    • NodeForecastSolar.api_token
    • NodeForecastSolar.endpoint
    • NodeForecastSolar.data
    • NodeForecastSolar.latitude
    • NodeForecastSolar.longitude
    • NodeForecastSolar.declination
    • NodeForecastSolar.azimuth
    • NodeForecastSolar.kwp
    • NodeForecastSolar.no_sun
    • NodeForecastSolar.damping_morning
    • NodeForecastSolar.damping_evening
    • NodeForecastSolar.horizon
    • NodeForecastSolar.inverter
    • NodeForecastSolar.actual
• eta_utility.connectors.opc_ua module
  • OpcUaConnection
    • OpcUaConnection.from_ids()
    • OpcUaConnection.read()
    • OpcUaConnection.write()
    • OpcUaConnection.create_nodes()
    • OpcUaConnection.delete_nodes()
    • OpcUaConnection.subscribe()
    • OpcUaConnection.close_sub()
• eta_utility.connectors.sub_handlers module
  • MultiSubHandler
    • MultiSubHandler.register()
    • MultiSubHandler.push()
    • MultiSubHandler.close()
  • CsvSubHandler
    • CsvSubHandler.push()
    • CsvSubHandler.close()
  • DFSubHandler
    • DFSubHandler.push()
    • DFSubHandler.get_latest()
    • DFSubHandler.data
    • DFSubHandler.reset()
    • DFSubHandler.close()
• eta_utility.connectors.util module
  • RetryWaiter
    • RetryWaiter.VALUES
    • RetryWaiter.tried()
    • RetryWaiter.success()
    • RetryWaiter.wait_time
    • RetryWaiter.wait()
    • RetryWaiter.wait_async()
  • decode_modbus_value()
  • encode_bits()
  • bitarray_to_registers()
  • all_equal()
  • IntervalChecker
    • IntervalChecker.node_latest_values
    • IntervalChecker.push()
    • IntervalChecker.check_interval_connection()
• eta_utility.connectors.wetterdienst_connection module
  • WetterdienstConnection
    • WetterdienstConnection.read_series()
    • WetterdienstConnection.read()
    • WetterdienstConnection.write()
    • WetterdienstConnection.subscribe()
    • WetterdienstConnection.subscribe_series()
    • WetterdienstConnection.close_sub()
    • WetterdienstConnection.retrieve_stations()
  • WetterdienstObservationConnection
    • WetterdienstObservationConnection.read_series()
  • WetterdienstPredictionConnection
    • WetterdienstPredictionConnection.read_series()