yandextank/plugins/InfluxUploader/decoder.py
def decode_monitoring(self, data):
        """
        The reason why we have two separate methods for monitoring
        and aggregates is a strong difference in incoming data.
        """
        points = list()
        for second_data in data:
            for host, host_data in second_data["data"].iteritems():
                points.append(
                    self.__make_points(
                        "monitoring",
                        {"host": host, "comment": host_data.get("comment")},
                        second_data["timestamp"],
                        {
                            metric: value
                            for metric, value in host_data["metrics"].iteritems()
                        }
                    )
                )
        return points
def decode_monitoring(self, data):
        """
        The reason why we have two separate methods for monitoring
        and aggregates is a strong difference in incoming data.
        """
        points = list()
        for second_data in data:
            for host, host_data in second_data["data"].iteritems():
                points.append(
                    self.__make_points(
                        "monitoring",
                        {"host": host, "comment": host_data.get("comment")},
                        second_data["timestamp"],
                        {
                            metric: value
                            for metric, value in host_data["metrics"].iteritems()
                        }
                    )
                )
        return points
The reason why we have two separate methods for monitoring
        and aggregates is a strong difference in incoming data.