def emit(self, eventDict):
        if eventDict.get('type') == 'accounting':
            acc_type = eventDict.get('acc_type')
            if acc_type != 'blob_total_size':
                self.aggregated_operations += eventDict.get('amount')
            else:
                timeStr = datetime.datetime.fromtimestamp(eventDict['time']).isoformat()
                avatar = eventDict.get('avatar')
                amount = eventDict.get('amount')
                acc_type = eventDict.get('acc_type')
                start_time = datetime.datetime.fromtimestamp(eventDict.get('start_time', 0)).isoformat()
                end_time = datetime.datetime.fromtimestamp(eventDict.get('end_time', 0)).isoformat()

                msg = "%s %s %s %s %s %s\n" % (timeStr, start_time, end_time, avatar, amount, self.aggregated_operations)
                if conf.getboolean('general', 'send_accounting_to_ur'):
                    send_ogf_ur_accounting(start_time, end_time, avatar, amount, self.aggregated_operations)
                util.untilConcludes(self.write, msg)
                util.untilConcludes(self.flush)
                self.aggregated_operations = 0
dataset/ETHPy150Open livenson/vcdm/src/vcdm/utils.py/AccountingLogObserver.emit/original