#include <Interpreters/TextLog.h> #include <Common/ClickHouseRevision.h> #include <DataTypes/DataTypeDate.h> #include <DataTypes/DataTypeDateTime.h> #include <DataTypes/DataTypeDateTime64.h> #include <DataTypes/DataTypeEnum.h> #include <DataTypes/DataTypeLowCardinality.h> #include <DataTypes/DataTypeString.h> #include <DataTypes/DataTypesNumber.h> #include <Common/logger_useful.h> #include <array> namespace DB { NamesAndTypesList TextLogElement::getNamesAndTypes() { auto priority_datatype = std::make_shared<DataTypeEnum8>( DataTypeEnum8::Values { {"Fatal", static_cast<Int8>(Message::PRIO_FATAL)}, {"Critical", static_cast<Int8>(Message::PRIO_CRITICAL)}, {"Error", static_cast<Int8>(Message::PRIO_ERROR)}, {"Warning", static_cast<Int8>(Message::PRIO_WARNING)}, {"Notice", static_cast<Int8>(Message::PRIO_NOTICE)}, {"Information", static_cast<Int8>(Message::PRIO_INFORMATION)}, {"Debug", static_cast<Int8>(Message::PRIO_DEBUG)}, {"Trace", static_cast<Int8>(Message::PRIO_TRACE)}, {"Test", static_cast<Int8>(Message::PRIO_TEST)}, }); return { {"event_date", std::make_shared<DataTypeDate>()}, {"event_time", std::make_shared<DataTypeDateTime>()}, {"event_time_microseconds", std::make_shared<DataTypeDateTime64>(6)}, {"thread_name", std::make_shared<DataTypeLowCardinality>(std::make_shared<DataTypeString>())}, {"thread_id", std::make_shared<DataTypeUInt64>()}, {"level", std::move(priority_datatype)}, {"query_id", std::make_shared<DataTypeString>()}, {"logger_name", std::make_shared<DataTypeLowCardinality>(std::make_shared<DataTypeString>())}, {"message", std::make_shared<DataTypeString>()}, {"revision", std::make_shared<DataTypeUInt32>()}, {"source_file", std::make_shared<DataTypeLowCardinality>(std::make_shared<DataTypeString>())}, {"source_line", std::make_shared<DataTypeUInt64>()}, {"message_format_string", std::make_shared<DataTypeLowCardinality>(std::make_shared<DataTypeString>())}, }; } void TextLogElement::appendToBlock(MutableColumns & columns) const { size_t i = 0; columns[i++]->insert(DateLUT::instance().toDayNum(event_time).toUnderType()); columns[i++]->insert(event_time); columns[i++]->insert(event_time_microseconds); columns[i++]->insertData(thread_name.data(), thread_name.size()); columns[i++]->insert(thread_id); columns[i++]->insert(level); columns[i++]->insert(query_id); columns[i++]->insert(logger_name); columns[i++]->insert(message); columns[i++]->insert(ClickHouseRevision::getVersionRevision()); columns[i++]->insert(source_file); columns[i++]->insert(source_line); columns[i++]->insert(message_format_string); } TextLog::TextLog(ContextPtr context_, const SystemLogSettings & settings) : SystemLog<TextLogElement>(context_, settings, getLogQueue(settings.queue_settings)) { } }