storage_plugin.py 文件源码

def update(self, stat_name, stat_properties, stat_data):
        from chroma_core.lib.storage_plugin.api import statistics

        if isinstance(stat_properties, statistics.BytesHistogram):
            # Histograms
            for dp in stat_data:
                ts = dp['timestamp']
                bin_vals = dp['value']
                from django.db import transaction
                with transaction.commit_on_success():
                    time = SimpleHistoStoreTime.objects.create(time = ts, storage_resource_statistic = self)
                    for i in range(0, len(stat_properties.bins)):
                        SimpleHistoStoreBin.objects.create(bin_idx = i, value = bin_vals[i], histo_store_time = time)
                    # Only keep latest time
                    SimpleHistoStoreTime.objects.filter(~Q(id = time.id), storage_resource_statistic = self).delete()
            return []
        for i in stat_data:
            i['value'] = float(i['value'])
        return self.metrics.serialize(stat_name, stat_properties, stat_data)