[C++] Use custom endpoint for s3 using AWS_ENDPOINT

apache · Jul 20, 2023 · 7e0db12 · 7e0db12
1 parent f9d8edd
commit 7e0db12
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/cpp/src/arrow/filesystem/s3fs.cc b/cpp/src/arrow/filesystem/s3fs.cc
@@ -127,6 +127,7 @@ using internal::ToAwsString;
 using internal::ToURLEncodedAwsString;
 
 static const char kSep = '/';
+constexpr char kDefaultEndpointEnvVar[] = "AWS_ENDPOINT";
 
 // -----------------------------------------------------------------------
 // S3ProxyOptions implementation
@@ -337,6 +338,10 @@ Result<S3Options> S3Options::FromUri(const Uri& uri, std::string* out_path) {
   } else {
     options.ConfigureDefaultCredentials();
   }
+  auto endpoint_env = arrow::internal::GetEnvVar(kDefaultEndpointEnvVar);
+  if(endpoint_env.ok()) {
+    options.endpoint_override = endpoint_env.MoveValueUnsafe();
+  }
 
   bool region_set = false;
   for (const auto& kv : options_map) {