:mod:`quartic_sdk.core.entities.edge_connector`
===============================================

.. py:module:: quartic_sdk.core.entities.edge_connector


Module Contents
---------------

Classes
~~~~~~~

.. autoapisummary::

   quartic_sdk.core.entities.edge_connector.EdgeConnector



.. class:: EdgeConnector

   Bases: :class:`quartic_sdk.core.entities.base.Base`

   The given class refers to the data source entity which is created based upon the
   data source object returned from the API

   .. attribute:: mapping
      

      

   .. method:: __repr__(self)

      Override the method to return the data source name


   .. method:: get_tags(self, query_params={})

      The given method returns the list of tags for the given asset
      :param query_params: Dictionary of filter conditions


   .. method:: historical_data(self, start_time, stop_time, batch_size=Constants.DEFAULT_BATCH_SIZE, max_records=None, tags=None, return_type=Constants.RETURN_PANDAS)

      Fetch historical data for the given OPCUA edge connector


   .. method:: data(self, start_time, stop_time, sampling_ratio=1, return_type=Constants.RETURN_PANDAS, batch_size=Constants.DEFAULT_PAGE_LIMIT_ROWS, transformations=[])

      Get the data of all tags in the edge connector between the given start_time and
      stop_time for the given sampling_ratio
      :param start_time: (epoch) Start_time for getting data
      :param stop_time: (epoch) Stop_time for getting data
      :param sampling_ratio: sampling_ratio of the data
      :param return_type: The param decides whether the data after querying will be
          json(when value is "json") or pandas dataframe(when value is "pd"). By default,
          it takes the value as "json"
      :param transformations: Refers to the list of transformations. It supports either
          interpolation or aggregation, depending upon which, we pass the value of this
          dictionary. If `transformation_type` is "aggregation", an optional key can be
          passed called `aggregation_timestamp`, which determines how the timestamp information
          will be retained after aggregation. Valid options are "first", "last" or "discard". By
          default, the last timestamp in each group will be retained.
          An example value here is:
          [{
              "transformation_type": "interpolation",
              "column": "3",
              "method": "linear"
          }, {
              "transformation_type": "aggregation",
              "aggregation_column": "4",
              "aggregation_dict": {"3": "max"},
              "aggregation_timestamp": "last",
          }]
      :return: (DataIterator) DataIterator object which can be iterated to get the data
          between the given duration


   .. method:: __getattribute__(self, name)

      This method overrides the python's object __getattribute__ method. This is used to
      map some constant value of an object to some meaningful string constants for better
      readability
      :param name: name of the object attribute we want to access for example edge_connector.connector_protocol
      :return: Either mapped value or raw value with respect to the object attribute