thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-15 20:24:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Insert into table function s3 respect query settings

Browse Source
This commit is contained in:
vdimir 2024-10-15 14:46:10 +00:00
parent 4f3c9c3ee8
commit 4812159545
No known key found for this signature in database
GPG Key ID: 6EE4CE2BEDC51862
1 changed files with 17 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/Disks/ObjectStorages/S3/diskSettings.cpp
View File

@ -92,12 +92,26 @@ std::unique_ptr<S3::Client> getClient(
"Region should be explicitly specified for directory buckets");
}
const Settings & local_settings = context->getSettingsRef();
int s3_max_redirects = static_cast<int>(global_settings[Setting::s3_max_redirects]);
if (!for_disk_s3 && local_settings.isChanged("s3_max_redirects"))
s3_max_redirects = static_cast<int>(local_settings[Setting::s3_max_redirects]);
int s3_retry_attempts = static_cast<int>(global_settings[Setting::s3_retry_attempts]);
if (!for_disk_s3 && local_settings.isChanged("s3_retry_attempts"))
s3_retry_attempts = static_cast<int>(local_settings[Setting::s3_retry_attempts]);
bool enable_s3_requests_logging = global_settings[Setting::enable_s3_requests_logging];
if (!for_disk_s3 && local_settings.isChanged("enable_s3_requests_logging"))
enable_s3_requests_logging = local_settings[Setting::enable_s3_requests_logging];
S3::PocoHTTPClientConfiguration client_configuration = S3::ClientFactory::instance().createClientConfiguration(
auth_settings.region,
context->getRemoteHostFilter(),
static_cast<int>(global_settings[Setting::s3_max_redirects]),
static_cast<int>(global_settings[Setting::s3_retry_attempts]),
global_settings[Setting::enable_s3_requests_logging],
s3_max_redirects,
s3_retry_attempts,
enable_s3_requests_logging,
for_disk_s3,
request_settings.get_request_throttler,
request_settings.put_request_throttler,