ClickHouse/src/Interpreters/MetricLog.cpp

133 lines
4.5 KiB
C++
Raw Normal View History

2019-08-13 14:31:46 +00:00
#include <Interpreters/MetricLog.h>
#include <Common/ThreadPool.h>
2019-08-13 14:31:46 +00:00
#include <DataTypes/DataTypesNumber.h>
#include <DataTypes/DataTypeDate.h>
#include <DataTypes/DataTypeDateTime.h>
#include <DataTypes/DataTypeDateTime64.h>
2019-08-13 14:31:46 +00:00
2019-08-18 00:04:58 +00:00
2019-08-13 14:31:46 +00:00
namespace DB
{
NamesAndTypesList MetricLogElement::getNamesAndTypes()
2019-08-13 14:31:46 +00:00
{
NamesAndTypesList columns_with_type_and_name;
2019-08-13 14:31:46 +00:00
columns_with_type_and_name.emplace_back("event_date", std::make_shared<DataTypeDate>());
columns_with_type_and_name.emplace_back("event_time", std::make_shared<DataTypeDateTime>());
columns_with_type_and_name.emplace_back("event_time_microseconds", std::make_shared<DataTypeDateTime64>(6));
columns_with_type_and_name.emplace_back("milliseconds", std::make_shared<DataTypeUInt64>());
2019-08-13 14:31:46 +00:00
for (size_t i = 0, end = ProfileEvents::end(); i < end; ++i)
{
std::string name;
name += "ProfileEvent_";
name += ProfileEvents::getName(ProfileEvents::Event(i));
columns_with_type_and_name.emplace_back(std::move(name), std::make_shared<DataTypeUInt64>());
2019-08-13 14:31:46 +00:00
}
for (size_t i = 0, end = CurrentMetrics::end(); i < end; ++i)
{
std::string name;
name += "CurrentMetric_";
name += CurrentMetrics::getName(CurrentMetrics::Metric(i));
columns_with_type_and_name.emplace_back(std::move(name), std::make_shared<DataTypeInt64>());
2019-08-13 14:31:46 +00:00
}
return columns_with_type_and_name;
2019-08-13 14:31:46 +00:00
}
2019-08-18 00:04:58 +00:00
void MetricLogElement::appendToBlock(MutableColumns & columns) const
2019-08-13 14:31:46 +00:00
{
2019-08-18 00:04:58 +00:00
size_t column_idx = 0;
2019-08-13 14:31:46 +00:00
Extended range of DateTime64 to years 1925 - 2238 The Year 1925 is a starting point because most of the timezones switched to saner (mostly 15-minutes based) offsets somewhere during 1924 or before. And that significantly simplifies implementation. 2238 is to simplify arithmetics for sanitizing LUT index access; there are less than 0x1ffff days from 1925. * Extended DateLUTImpl internal LUT to 0x1ffff items, some of which represent negative (pre-1970) time values. As a collateral benefit, Date now correctly supports dates up to 2149 (instead of 2106). * Added a new strong typedef ExtendedDayNum, which represents dates pre-1970 and post 2149. * Functions that used to return DayNum now return ExtendedDayNum. * Refactored DateLUTImpl to untie DayNum from the dual role of being a value and an index (due to negative time). Index is now a different type LUTIndex with explicit conversion functions from DatNum, time_t, and ExtendedDayNum. * Updated DateLUTImpl to properly support values close to epoch start (1970-01-01 00:00), including negative ones. * Reduced resolution of DateLUTImpl::Values::time_at_offset_change to multiple of 15-minutes to allow storing 64-bits of time_t in DateLUTImpl::Value while keeping same size. * Minor performance updates to DateLUTImpl when building month LUT by skipping non-start-of-month days. * Fixed extractTimeZoneFromFunctionArguments to work correctly with DateTime64. * New unit-tests and stateless integration tests for both DateTime and DateTime64.
2020-04-17 13:26:44 +00:00
columns[column_idx++]->insert(DateLUT::instance().toDayNum(event_time).toUnderType());
2019-08-18 00:04:58 +00:00
columns[column_idx++]->insert(event_time);
columns[column_idx++]->insert(event_time_microseconds);
2019-08-18 00:04:58 +00:00
columns[column_idx++]->insert(milliseconds);
2019-08-13 14:31:46 +00:00
for (size_t i = 0, end = ProfileEvents::end(); i < end; ++i)
2019-08-18 00:04:58 +00:00
columns[column_idx++]->insert(profile_events[i]);
2019-08-13 14:31:46 +00:00
for (size_t i = 0, end = CurrentMetrics::end(); i < end; ++i)
columns[column_idx++]->insert(current_metrics[i].toUnderType());
2019-08-13 14:31:46 +00:00
}
2019-08-18 00:04:58 +00:00
2019-08-13 16:47:12 +00:00
void MetricLog::startCollectMetric(size_t collect_interval_milliseconds_)
{
collect_interval_milliseconds = collect_interval_milliseconds_;
is_shutdown_metric_thread = false;
metric_flush_thread = std::make_unique<ThreadFromGlobalPool>([this] { metricThreadFunction(); });
2019-08-13 16:47:12 +00:00
}
2019-08-18 00:04:58 +00:00
2019-08-13 16:47:12 +00:00
void MetricLog::stopCollectMetric()
{
bool old_val = false;
if (!is_shutdown_metric_thread.compare_exchange_strong(old_val, true))
return;
if (metric_flush_thread)
metric_flush_thread->join();
2019-08-13 16:47:12 +00:00
}
2019-08-18 00:04:58 +00:00
2020-04-13 01:33:05 +00:00
void MetricLog::shutdown()
{
stopCollectMetric();
stopFlushThread();
}
2019-08-13 16:47:12 +00:00
void MetricLog::metricThreadFunction()
{
2019-08-14 12:54:41 +00:00
auto desired_timepoint = std::chrono::system_clock::now();
/// For differentiation of ProfileEvents counters.
std::vector<ProfileEvents::Count> prev_profile_events(ProfileEvents::end());
2019-08-18 00:04:58 +00:00
2019-08-15 23:35:54 +00:00
while (!is_shutdown_metric_thread)
2019-08-13 16:47:12 +00:00
{
try
{
2019-08-15 23:35:54 +00:00
const auto current_time = std::chrono::system_clock::now();
2019-08-18 00:04:58 +00:00
MetricLogElement elem;
2019-08-15 23:35:54 +00:00
elem.event_time = std::chrono::system_clock::to_time_t(current_time);
elem.event_time_microseconds = timeInMicroseconds(current_time);
elem.milliseconds = timeInMilliseconds(current_time) - timeInSeconds(current_time) * 1000;
2019-08-15 16:39:18 +00:00
2019-08-18 00:25:58 +00:00
elem.profile_events.resize(ProfileEvents::end());
for (ProfileEvents::Event i = ProfileEvents::Event(0), end = ProfileEvents::end(); i < end; ++i)
2019-08-18 00:04:58 +00:00
{
const ProfileEvents::Count new_value = ProfileEvents::global_counters[i].load(std::memory_order_relaxed);
2019-09-21 18:30:01 +00:00
auto & old_value = prev_profile_events[i];
2019-08-18 00:04:58 +00:00
elem.profile_events[i] = new_value - old_value;
old_value = new_value;
}
2019-08-18 00:25:58 +00:00
elem.current_metrics.resize(CurrentMetrics::end());
2019-08-18 00:04:58 +00:00
for (size_t i = 0, end = CurrentMetrics::end(); i < end; ++i)
{
elem.current_metrics[i] = CurrentMetrics::values[i];
}
2019-08-13 16:47:12 +00:00
this->add(elem);
2019-08-15 23:35:54 +00:00
/// We will record current time into table but align it to regular time intervals to avoid time drift.
/// We may drop some time points if the server is overloaded and recording took too much time.
while (desired_timepoint <= current_time)
2019-08-15 16:09:43 +00:00
desired_timepoint += std::chrono::milliseconds(collect_interval_milliseconds);
2019-08-15 23:35:54 +00:00
2019-08-14 12:54:41 +00:00
std::this_thread::sleep_until(desired_timepoint);
2019-08-13 16:47:12 +00:00
}
catch (...)
{
tryLogCurrentException(__PRETTY_FUNCTION__);
}
}
}
2019-08-13 14:31:46 +00:00
}