public
/
ottertune
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

accelerate calculation; default per session

This commit is contained in:
yangdsh 2020-04-10 17:59:32 -04:00 committed by Dana Van Aken
parent d09489e8b6
commit 9fe6ded36c
2 changed files with 14 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
server/website/website/db/oracle/target_objective.py
View File

@ -46,13 +46,16 @@ class NormalizedDBTime(BaseTargetObjective):
def __init__(self):
super().__init__(name='db_time', pprint='Normalized DB Time', unit='seconds',
short_unit='s', improvement=LESS_IS_BETTER)
# This target objective is designed for Oracle v12.2.0.1.0
dbms = DBMSCatalog.objects.get(type=DBMSType.ORACLE, version='12.2.0.1.0')
self.default_values = {}
for metric in MetricCatalog.objects.filter(dbms=dbms):
self.default_values[metric.name] = metric.default
def compute(self, metrics, observation_time):
extra_io_metrics = ["log file sync"]
not_io_metrics = ["read by other session"]
total_wait_time = 0.
# This target objective is designed for Oracle v12.2.0.1.0
dbms = DBMSCatalog.objects.get(type=DBMSType.ORACLE, version='12.2.0.1.0')
has_dba_hist = metrics['global.dba_hist_sys_time_model.db time'] > 0
for name, value in metrics.items():
if has_dba_hist and 'dba_hist_' not in name:
@ -60,11 +63,11 @@ class NormalizedDBTime(BaseTargetObjective):
if 'db cpu' in name:
total_wait_time += float(value)
elif 'time_waited_micro_fg' in name:
default_wait_time = float(MetricCatalog.objects.get(dbms=dbms, name=name).default)
default_wait_time = float(self.default_values[name])
wait_time = float(value)
elif 'total_waits_fg' in name:
default_total_waits = int(MetricCatalog.objects.get(dbms=dbms, name=name).default)
total_waits = int(value)
default_total_waits = float(self.default_values[name])
total_waits = float(value)
elif name.endswith('wait_class'):
if value == 'Idle':
wait_time = 0

8
server/website/website/views.py
View File

@ -653,10 +653,14 @@ def handle_result_files(session, files, execution_times=None):
metric_data.name = 'range_test_' + metric_data.name + '*'
metric_data.save()
if 'status' in summary and summary['status'] == "default":
# The metric should not be used for learning because the driver did not run workload
# We tag the metric as invalid, so later they will be set to the worst result
# The metric should not be used for learning because the knob value is not real
metric_data.name = 'default_' + metric_data.name
metric_data.save()
for name in numeric_metric_dict.keys():
if 'time_waited_micro_fg' in name or 'total_waits_fg' in name:
metric = MetricCatalog.objects.get(dbms=dbms, name=name)
metric.default = numeric_metric_dict[name]
metric.save()
if 'transaction_counter' in numeric_metric_dict.keys():
# Normalize metrics by the amount of work
first_metric = MetricData.objects.filter(session=session).first()