This is an automated email from the ASF dual-hosted git repository.
xuanwo pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-opendal.git
The following commit(s) were added to refs/heads/main by this push:
new 3e42fef3 feat(services/oss): Add Copy Support (#1874)
3e42fef3 is described below
commit 3e42fef35d3ffd0236a98f030e62c4c7ec098c28
Author: Suyan <[email protected]>
AuthorDate: Sat Apr 8 11:30:26 2023 +0800
feat(services/oss): Add Copy Support (#1874)
* feat(oss): support copy
Signed-off-by: suyanhanx <[email protected]>
* try fix
Signed-off-by: suyanhanx <[email protected]>
---------
Signed-off-by: suyanhanx <[email protected]>
---
core/src/services/oss/backend.rs | 36 +++++++++++++++++++++++++++++++++++-
1 file changed, 35 insertions(+), 1 deletion(-)
diff --git a/core/src/services/oss/backend.rs b/core/src/services/oss/backend.rs
index a1bfeacf..1e141519 100644
--- a/core/src/services/oss/backend.rs
+++ b/core/src/services/oss/backend.rs
@@ -53,6 +53,7 @@ use crate::*;
///
/// - [x] read
/// - [x] write
+/// - [x] copy
/// - [x] list
/// - [x] scan
/// - [ ] presign
@@ -417,7 +418,7 @@ impl Accessor for OssBackend {
.set_root(&self.root)
.set_name(&self.bucket)
.set_max_batch_operations(1000)
- .set_capabilities(Read | Write | List | Scan | Presign | Batch)
+ .set_capabilities(Read | Write | Copy | List | Scan | Presign |
Batch)
.set_hints(ReadStreamable);
am
@@ -475,6 +476,19 @@ impl Accessor for OssBackend {
))
}
+ async fn copy(&self, from: &str, to: &str, _args: OpCopy) ->
Result<RpCopy> {
+ let resp = self.oss_copy_object(from, to).await?;
+ let status = resp.status();
+
+ match status {
+ StatusCode::OK => {
+ resp.into_body().consume().await?;
+ Ok(RpCopy::default())
+ }
+ _ => Err(parse_error(resp).await?),
+ }
+ }
+
async fn stat(&self, path: &str, _: OpStat) -> Result<RpStat> {
if path == "/" {
let m = Metadata::new(EntryMode::DIR);
@@ -756,6 +770,26 @@ impl OssBackend {
self.client.send_async(req).await
}
+ async fn oss_copy_object(&self, from: &str, to: &str) ->
Result<Response<IncomingAsyncBody>> {
+ let source = build_abs_path(&self.root, from);
+ let target = build_abs_path(&self.root, to);
+
+ let url = format!(
+ "{}/{}",
+ self.get_endpoint(false),
+ percent_encode_path(&target)
+ );
+ let source = format!("/{}/{}", self.bucket,
percent_encode_path(&source));
+
+ let mut req = Request::put(&url)
+ .header("x-oss-copy-source", source)
+ .body(AsyncBody::Empty)
+ .map_err(new_request_build_error)?;
+
+ self.signer.sign(&mut req).map_err(new_request_sign_error)?;
+ self.client.send_async(req).await
+ }
+
pub(super) async fn oss_list_object(
&self,
path: &str,
