mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-12-16 11:22:12 +00:00
272 lines
9.2 KiB
C++
272 lines
9.2 KiB
C++
#include "DisksApp.h"
|
|
#include "ICommand.h"
|
|
|
|
#include <Disks/registerDisks.h>
|
|
|
|
#include <Common/TerminalSize.h>
|
|
#include <Formats/registerFormats.h>
|
|
|
|
|
|
namespace DB
|
|
{
|
|
|
|
namespace ErrorCodes
|
|
{
|
|
extern const int BAD_ARGUMENTS;
|
|
}
|
|
|
|
size_t DisksApp::findCommandPos(std::vector<String> & common_arguments)
|
|
{
|
|
for (size_t i = 0; i < common_arguments.size(); i++)
|
|
if (supported_commands.contains(common_arguments[i]))
|
|
return i + 1;
|
|
return common_arguments.size();
|
|
}
|
|
|
|
void DisksApp::printHelpMessage(ProgramOptionsDescription & command_option_description)
|
|
{
|
|
std::optional<ProgramOptionsDescription> help_description =
|
|
createOptionsDescription("Help Message for clickhouse-disks", getTerminalWidth());
|
|
|
|
help_description->add(command_option_description);
|
|
|
|
std::cout << "ClickHouse disk management tool\n";
|
|
std::cout << "Usage: ./clickhouse-disks [OPTION]\n";
|
|
std::cout << "clickhouse-disks\n\n";
|
|
|
|
for (const auto & current_command : supported_commands)
|
|
std::cout << command_descriptions[current_command]->command_name
|
|
<< "\t"
|
|
<< command_descriptions[current_command]->description
|
|
<< "\n\n";
|
|
|
|
std::cout << command_option_description << '\n';
|
|
}
|
|
|
|
String DisksApp::getDefaultConfigFileName()
|
|
{
|
|
return "/etc/clickhouse-server/config.xml";
|
|
}
|
|
|
|
void DisksApp::addOptions(
|
|
ProgramOptionsDescription & options_description_,
|
|
boost::program_options::positional_options_description & positional_options_description
|
|
)
|
|
{
|
|
options_description_.add_options()
|
|
("help,h", "Print common help message")
|
|
("config-file,C", po::value<String>(), "Set config file")
|
|
("disk", po::value<String>(), "Set disk name")
|
|
("command_name", po::value<String>(), "Name for command to do")
|
|
("save-logs", "Save logs to a file")
|
|
("log-level", po::value<String>(), "Logging level")
|
|
;
|
|
|
|
positional_options_description.add("command_name", 1);
|
|
|
|
supported_commands = {"list-disks", "list", "move", "remove", "link", "copy", "write", "read", "mkdir"};
|
|
|
|
command_descriptions.emplace("list-disks", makeCommandListDisks());
|
|
command_descriptions.emplace("list", makeCommandList());
|
|
command_descriptions.emplace("move", makeCommandMove());
|
|
command_descriptions.emplace("remove", makeCommandRemove());
|
|
command_descriptions.emplace("link", makeCommandLink());
|
|
command_descriptions.emplace("copy", makeCommandCopy());
|
|
command_descriptions.emplace("write", makeCommandWrite());
|
|
command_descriptions.emplace("read", makeCommandRead());
|
|
command_descriptions.emplace("mkdir", makeCommandMkDir());
|
|
}
|
|
|
|
void DisksApp::processOptions()
|
|
{
|
|
if (options.count("config-file"))
|
|
config().setString("config-file", options["config-file"].as<String>());
|
|
if (options.count("disk"))
|
|
config().setString("disk", options["disk"].as<String>());
|
|
if (options.count("save-logs"))
|
|
config().setBool("save-logs", true);
|
|
if (options.count("log-level"))
|
|
config().setString("log-level", options["log-level"].as<String>());
|
|
}
|
|
|
|
void DisksApp::init(std::vector<String> & common_arguments)
|
|
{
|
|
stopOptionsProcessing();
|
|
|
|
ProgramOptionsDescription options_description{createOptionsDescription("clickhouse-disks", getTerminalWidth())};
|
|
|
|
po::positional_options_description positional_options_description;
|
|
|
|
addOptions(options_description, positional_options_description);
|
|
|
|
size_t command_pos = findCommandPos(common_arguments);
|
|
std::vector<String> global_flags(command_pos);
|
|
command_arguments.resize(common_arguments.size() - command_pos);
|
|
copy(common_arguments.begin(), common_arguments.begin() + command_pos, global_flags.begin());
|
|
copy(common_arguments.begin() + command_pos, common_arguments.end(), command_arguments.begin());
|
|
|
|
parseAndCheckOptions(options_description, positional_options_description, global_flags);
|
|
|
|
po::notify(options);
|
|
|
|
if (options.count("help"))
|
|
{
|
|
printHelpMessage(options_description);
|
|
exit(0); // NOLINT(concurrency-mt-unsafe)
|
|
}
|
|
|
|
if (!supported_commands.contains(command_name))
|
|
{
|
|
std::cerr << "Unknown command name: " << command_name << "\n";
|
|
printHelpMessage(options_description);
|
|
throw DB::Exception(DB::ErrorCodes::BAD_ARGUMENTS, "Bad Arguments");
|
|
}
|
|
|
|
processOptions();
|
|
}
|
|
|
|
void DisksApp::parseAndCheckOptions(
|
|
ProgramOptionsDescription & options_description_,
|
|
boost::program_options::positional_options_description & positional_options_description,
|
|
std::vector<String> & arguments)
|
|
{
|
|
auto parser = po::command_line_parser(arguments)
|
|
.options(options_description_)
|
|
.positional(positional_options_description)
|
|
.allow_unregistered();
|
|
po::parsed_options parsed = parser.run();
|
|
po::store(parsed, options);
|
|
|
|
auto positional_arguments = po::collect_unrecognized(parsed.options, po::collect_unrecognized_mode::include_positional);
|
|
for (const auto & arg : positional_arguments)
|
|
{
|
|
if (command_descriptions.contains(arg))
|
|
{
|
|
command_name = arg;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
int DisksApp::main(const std::vector<String> & /*args*/)
|
|
{
|
|
if (config().has("config-file") || fs::exists(getDefaultConfigFileName()))
|
|
{
|
|
String config_path = config().getString("config-file", getDefaultConfigFileName());
|
|
ConfigProcessor config_processor(config_path, false, false);
|
|
config_processor.setConfigPath(fs::path(config_path).parent_path());
|
|
auto loaded_config = config_processor.loadConfig();
|
|
config().add(loaded_config.configuration.duplicate(), false, false);
|
|
}
|
|
else
|
|
{
|
|
throw Exception(ErrorCodes::BAD_ARGUMENTS, "No config-file specifiged");
|
|
}
|
|
|
|
if (config().has("save-logs"))
|
|
{
|
|
auto log_level = config().getString("log-level", "trace");
|
|
Poco::Logger::root().setLevel(Poco::Logger::parseLevel(log_level));
|
|
|
|
auto log_path = config().getString("logger.clickhouse-disks", "/var/log/clickhouse-server/clickhouse-disks.log");
|
|
Poco::Logger::root().setChannel(Poco::AutoPtr<Poco::FileChannel>(new Poco::FileChannel(log_path)));
|
|
}
|
|
else
|
|
{
|
|
auto log_level = config().getString("log-level", "none");
|
|
Poco::Logger::root().setLevel(Poco::Logger::parseLevel(log_level));
|
|
}
|
|
|
|
registerDisks(/* global_skip_access_check= */ true);
|
|
registerFormats();
|
|
|
|
shared_context = Context::createShared();
|
|
global_context = Context::createGlobal(shared_context.get());
|
|
|
|
global_context->makeGlobalContext();
|
|
global_context->setApplicationType(Context::ApplicationType::DISKS);
|
|
|
|
String path = config().getString("path", DBMS_DEFAULT_PATH);
|
|
global_context->setPath(path);
|
|
|
|
auto & command = command_descriptions[command_name];
|
|
|
|
auto command_options = command->getCommandOptions();
|
|
std::vector<String> args;
|
|
if (command_options)
|
|
{
|
|
auto parser = po::command_line_parser(command_arguments).options(*command_options).allow_unregistered();
|
|
po::parsed_options parsed = parser.run();
|
|
po::store(parsed, options);
|
|
po::notify(options);
|
|
args = po::collect_unrecognized(parsed.options, po::collect_unrecognized_mode::include_positional);
|
|
|
|
command->processOptions(config(), options);
|
|
}
|
|
else
|
|
{
|
|
auto parser = po::command_line_parser(command_arguments).options({}).allow_unregistered();
|
|
po::parsed_options parsed = parser.run();
|
|
args = po::collect_unrecognized(parsed.options, po::collect_unrecognized_mode::include_positional);
|
|
}
|
|
|
|
std::unordered_set<std::string> disks
|
|
{
|
|
config().getString("disk", "default"),
|
|
config().getString("disk-from", config().getString("disk", "default")),
|
|
config().getString("disk-to", config().getString("disk", "default")),
|
|
};
|
|
|
|
auto validator = [&disks](
|
|
const Poco::Util::AbstractConfiguration & config,
|
|
const std::string & disk_config_prefix,
|
|
const std::string & disk_name)
|
|
{
|
|
if (!disks.contains(disk_name))
|
|
return false;
|
|
|
|
const auto disk_type = config.getString(disk_config_prefix + ".type", "local");
|
|
|
|
if (disk_type == "cache")
|
|
throw Exception(ErrorCodes::BAD_ARGUMENTS, "Disk type 'cache' of disk {} is not supported by clickhouse-disks", disk_name);
|
|
|
|
return true;
|
|
};
|
|
|
|
constexpr auto config_prefix = "storage_configuration.disks";
|
|
auto disk_selector = std::make_shared<DiskSelector>();
|
|
disk_selector->initialize(config(), config_prefix, global_context, validator);
|
|
|
|
command->execute(args, disk_selector, config());
|
|
|
|
return Application::EXIT_OK;
|
|
}
|
|
|
|
}
|
|
|
|
int mainEntryClickHouseDisks(int argc, char ** argv)
|
|
{
|
|
try
|
|
{
|
|
DB::DisksApp app;
|
|
std::vector<String> common_arguments{argv + 1, argv + argc};
|
|
app.init(common_arguments);
|
|
return app.run();
|
|
}
|
|
catch (const DB::Exception & e)
|
|
{
|
|
std::cerr << DB::getExceptionMessage(e, false) << std::endl;
|
|
return 1;
|
|
}
|
|
catch (const boost::program_options::error & e)
|
|
{
|
|
std::cerr << "Bad arguments: " << e.what() << std::endl;
|
|
return DB::ErrorCodes::BAD_ARGUMENTS;
|
|
}
|
|
catch (...)
|
|
{
|
|
std::cerr << DB::getCurrentExceptionMessage(true) << std::endl;
|
|
return 1;
|
|
}
|
|
}
|