eta_utility.connectors package

Submodules

• eta_utility.connectors.base_classes module
  • SubscriptionHandler
    • SubscriptionHandler.push()
  • Connection
    • Connection.selected_nodes
    • Connection.usr
    • Connection.pwd
    • Connection.from_node()
    • Connection.read()
    • Connection.write()
    • Connection.subscribe()
    • Connection.close_sub()
    • Connection.url
  • BaseConnection
  • BaseSeriesConnection
    • BaseSeriesConnection.read_series()
    • BaseSeriesConnection.subscribe_series()
• 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.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.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.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
  • NodeOpcUa
    • NodeOpcUa.opc_id
    • NodeOpcUa.opc_path_str
    • NodeOpcUa.opc_ns
    • NodeOpcUa.opc_id_type
    • NodeOpcUa.opc_name
    • NodeOpcUa.opc_path
  • NodeEnEffCo
    • NodeEnEffCo.eneffco_code
  • NodeEntsoE
    • NodeEntsoE.endpoint
    • NodeEntsoE.bidding_zone
  • NodeCumulocity
    • NodeCumulocity.device_id
    • NodeCumulocity.measurement
    • NodeCumulocity.fragment
• 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()