diff --git a/extensions/core-ionos-s3/src/main/java/com/ionos/edc/extension/s3/schema/IonosBucketSchema.java b/extensions/core-ionos-s3/src/main/java/com/ionos/edc/extension/s3/schema/IonosBucketSchema.java
index 306d463..39e1af8 100644
--- a/extensions/core-ionos-s3/src/main/java/com/ionos/edc/extension/s3/schema/IonosBucketSchema.java
+++ b/extensions/core-ionos-s3/src/main/java/com/ionos/edc/extension/s3/schema/IonosBucketSchema.java
@@ -21,6 +21,7 @@ public interface IonosBucketSchema {
     String STORAGE_NAME = EDC_NAMESPACE + "storage";
     String BUCKET_NAME = EDC_NAMESPACE + "bucketName";
     String BLOB_NAME = EDC_NAMESPACE + "blobName";
+    String PATH = EDC_NAMESPACE + "path";
     String FILTER_INCLUDES = EDC_NAMESPACE + "filter.includes";
     String FILTER_EXCLUDES = EDC_NAMESPACE + "filter.excludes";
     String ACCESS_KEY_ID = EDC_NAMESPACE + "accessKey";
diff --git a/extensions/data-plane-ionos-s3/src/main/java/com/ionos/edc/dataplane/ionos/s3/IonosDataSink.java b/extensions/data-plane-ionos-s3/src/main/java/com/ionos/edc/dataplane/ionos/s3/IonosDataSink.java
index 377aa16..259645c 100644
--- a/extensions/data-plane-ionos-s3/src/main/java/com/ionos/edc/dataplane/ionos/s3/IonosDataSink.java
+++ b/extensions/data-plane-ionos-s3/src/main/java/com/ionos/edc/dataplane/ionos/s3/IonosDataSink.java
@@ -32,7 +32,7 @@ public class IonosDataSink extends ParallelSink {
 
     private S3ConnectorApi s3Api;
     private String bucketName;
-    private String blobName;
+    private String path;
 
     private IonosDataSink() {}
 
@@ -41,8 +41,8 @@ protected StreamResult<Object> transferParts(List<DataSource.Part> parts) {
 
         for (DataSource.Part part : parts) {
             String blobName;
-            if (this.blobName != null) {
-                blobName = this.blobName;
+            if (this.path != null) {
+                blobName = this.path + part.name();
             } else {
                 blobName = part.name();
             }
@@ -53,6 +53,8 @@ protected StreamResult<Object> transferParts(List<DataSource.Part> parts) {
                 streamsOutput = new ByteArrayOutputStream();
                 stream = part.openStream();
 
+
+                // TODO Make this more configurable
                 if (part instanceof IonosDataSource.S3Part) {
                     // Multiple fetches
                     while (stream != null) {
@@ -130,8 +132,8 @@ public Builder bucketName(String bucketName) {
             return this;
         }
 
-        public Builder blobName(String blobName) {
-            sink.blobName = blobName;
+        public Builder path(String path) {
+            sink.path = path;
             return this;
         }
 
diff --git a/extensions/data-plane-ionos-s3/src/main/java/com/ionos/edc/dataplane/ionos/s3/IonosDataSinkFactory.java b/extensions/data-plane-ionos-s3/src/main/java/com/ionos/edc/dataplane/ionos/s3/IonosDataSinkFactory.java
index c8bb747..747a4ec 100644
--- a/extensions/data-plane-ionos-s3/src/main/java/com/ionos/edc/dataplane/ionos/s3/IonosDataSinkFactory.java
+++ b/extensions/data-plane-ionos-s3/src/main/java/com/ionos/edc/dataplane/ionos/s3/IonosDataSinkFactory.java
@@ -90,7 +90,7 @@ public DataSink createSink(DataFlowRequest request) {
                         maxFiles);
                 return IonosDataSink.Builder.newInstance()
                         .bucketName(destination.getStringProperty(IonosBucketSchema.BUCKET_NAME))
-                        .blobName(destination.getStringProperty(IonosBucketSchema.BLOB_NAME))
+                        .path(destination.getStringProperty(IonosBucketSchema.PATH))
                         .requestId(request.getId())
                         .executorService(executorService)
                         .monitor(monitor)
@@ -104,7 +104,7 @@ public DataSink createSink(DataFlowRequest request) {
                         maxFiles);
                 return IonosDataSink.Builder.newInstance()
                         .bucketName(destination.getStringProperty(IonosBucketSchema.BUCKET_NAME))
-                        .blobName(destination.getStringProperty(IonosBucketSchema.BLOB_NAME))
+                        .path(destination.getStringProperty(IonosBucketSchema.PATH))
                         .requestId(request.getId())
                         .executorService(executorService)
                         .monitor(monitor)
@@ -115,7 +115,7 @@ public DataSink createSink(DataFlowRequest request) {
 
         return IonosDataSink.Builder.newInstance()
                 .bucketName(destination.getStringProperty(IonosBucketSchema.BUCKET_NAME))
-                .blobName(destination.getStringProperty(IonosBucketSchema.BLOB_NAME))
+                .path(destination.getStringProperty(IonosBucketSchema.PATH))
                 .requestId(request.getId()).executorService(executorService)
                 .monitor(monitor)
                 .s3Api(s3Api)
diff --git a/extensions/provision-ionos-s3/src/main/java/com/ionos/edc/provision/s3/IonosProvisionExtension.java b/extensions/provision-ionos-s3/src/main/java/com/ionos/edc/provision/s3/IonosProvisionExtension.java
index 19b8b4c..bc01d2c 100644
--- a/extensions/provision-ionos-s3/src/main/java/com/ionos/edc/provision/s3/IonosProvisionExtension.java
+++ b/extensions/provision-ionos-s3/src/main/java/com/ionos/edc/provision/s3/IonosProvisionExtension.java
@@ -59,7 +59,7 @@ public void initialize(ServiceExtensionContext context) {
         monitor.debug("IonosProvisionExtension" + "retryPolicy");
         var retryPolicy = (RetryPolicy<Object>) context.getService(RetryPolicy.class);
         monitor.debug("IonosProvisionExtension" + "s3BucketProvisioner");
-        var s3BucketProvisioner = new IonosS3Provisioner(retryPolicy, monitor, clientApi);
+        var s3BucketProvisioner = new IonosS3Provisioner(retryPolicy, clientApi);
         provisionManager.register(s3BucketProvisioner);
 
         // register the generator
diff --git a/extensions/provision-ionos-s3/src/main/java/com/ionos/edc/provision/s3/bucket/IonosS3ConsumerResourceDefinitionGenerator.java b/extensions/provision-ionos-s3/src/main/java/com/ionos/edc/provision/s3/bucket/IonosS3ConsumerResourceDefinitionGenerator.java
index b5a8dd4..9c27e1e 100644
--- a/extensions/provision-ionos-s3/src/main/java/com/ionos/edc/provision/s3/bucket/IonosS3ConsumerResourceDefinitionGenerator.java
+++ b/extensions/provision-ionos-s3/src/main/java/com/ionos/edc/provision/s3/bucket/IonosS3ConsumerResourceDefinitionGenerator.java
@@ -24,6 +24,7 @@
 import org.eclipse.edc.policy.model.Policy;
 
 import com.ionos.edc.extension.s3.schema.IonosBucketSchema;
+import org.eclipse.edc.spi.EdcException;
 
 public class IonosS3ConsumerResourceDefinitionGenerator implements ConsumerResourceDefinitionGenerator {
 
@@ -33,11 +34,16 @@ public ResourceDefinition generate(DataRequest dataRequest, Policy policy) {
         Objects.requireNonNull(policy, "policy must always be provided");
 
         var destination = dataRequest.getDataDestination();
+
+        var path = destination.getStringProperty(IonosBucketSchema.PATH);
+        if ((path != null) && !path.endsWith("/")) {
+            throw new EdcException("path must be a directory");
+        }
+
         var id = randomUUID().toString();
         var keyName = destination.getKeyName();
         var storage = destination.getStringProperty(IonosBucketSchema.STORAGE_NAME);
         var bucketName = destination.getStringProperty(IonosBucketSchema.BUCKET_NAME);
-        var blobName = destination.getStringProperty(IonosBucketSchema.BLOB_NAME);
         var accessKey = destination.getStringProperty(IonosBucketSchema.ACCESS_KEY_ID);
         var secretKey = destination.getStringProperty(IonosBucketSchema.SECRET_ACCESS_KEY);
 
@@ -46,8 +52,9 @@ public ResourceDefinition generate(DataRequest dataRequest, Policy policy) {
                 .keyName(keyName)
                 .storage(storage)
                 .bucketName(bucketName)
-                .blobName(blobName)
+                .path(path)
                 .accessKey(accessKey)
+                .secretKey(secretKey)
                 .build();
     }
 
diff --git a/extensions/provision-ionos-s3/src/main/java/com/ionos/edc/provision/s3/bucket/IonosS3ProvisionedResource.java b/extensions/provision-ionos-s3/src/main/java/com/ionos/edc/provision/s3/bucket/IonosS3ProvisionedResource.java
index 8fbde96..7edef32 100644
--- a/extensions/provision-ionos-s3/src/main/java/com/ionos/edc/provision/s3/bucket/IonosS3ProvisionedResource.java
+++ b/extensions/provision-ionos-s3/src/main/java/com/ionos/edc/provision/s3/bucket/IonosS3ProvisionedResource.java
@@ -29,15 +29,6 @@ public class IonosS3ProvisionedResource extends ProvisionedDataDestinationResour
 
     private String accessKey;
 
-    public String getStorage() {
-        return getDataAddress().getStringProperty(STORAGE_NAME);
-    }
-    public String getBucketName() {
-        return getDataAddress().getStringProperty(BUCKET_NAME);
-    }
-    public String getBlobName() {
-        return getDataAddress().getStringProperty(BLOB_NAME);
-    }
     public String getAccessKey() {
         return accessKey;
     }
@@ -69,8 +60,8 @@ public Builder bucketName(String bucketName) {
             return this;
         }
 
-        public Builder blobName(String blobName) {
-            dataAddressBuilder.property(BLOB_NAME, blobName);
+        public Builder path(String path) {
+            dataAddressBuilder.property(PATH, path);
             return this;
         }
 
diff --git a/extensions/provision-ionos-s3/src/main/java/com/ionos/edc/provision/s3/bucket/IonosS3Provisioner.java b/extensions/provision-ionos-s3/src/main/java/com/ionos/edc/provision/s3/bucket/IonosS3Provisioner.java
index a9725de..e4fd8b8 100644
--- a/extensions/provision-ionos-s3/src/main/java/com/ionos/edc/provision/s3/bucket/IonosS3Provisioner.java
+++ b/extensions/provision-ionos-s3/src/main/java/com/ionos/edc/provision/s3/bucket/IonosS3Provisioner.java
@@ -16,7 +16,6 @@
 
 import com.ionos.edc.extension.s3.api.S3ConnectorApi;
 import com.ionos.edc.extension.s3.configuration.IonosToken;
-import com.ionos.edc.extension.s3.connector.ionosapi.TemporaryKey;
 
 import dev.failsafe.RetryPolicy;
 import org.eclipse.edc.connector.transfer.spi.provision.Provisioner;
@@ -24,24 +23,19 @@
 import org.eclipse.edc.connector.transfer.spi.types.ProvisionResponse;
 import org.eclipse.edc.connector.transfer.spi.types.ProvisionedResource;
 import org.eclipse.edc.connector.transfer.spi.types.ResourceDefinition;
-import org.eclipse.edc.spi.monitor.Monitor;
 import org.eclipse.edc.spi.response.StatusResult;
-import org.jetbrains.annotations.NotNull;
 
 import java.time.OffsetDateTime;
 import java.util.concurrent.CompletableFuture;
 import static dev.failsafe.Failsafe.with;
-import static java.lang.String.format;
 
 public class IonosS3Provisioner implements Provisioner<IonosS3ResourceDefinition, IonosS3ProvisionedResource> {
     private final RetryPolicy<Object> retryPolicy;
-    private final Monitor monitor;
     private final S3ConnectorApi s3Api;
 
-    public IonosS3Provisioner(RetryPolicy<Object> retryPolicy, Monitor monitor, S3ConnectorApi s3Api) {
+    public IonosS3Provisioner(RetryPolicy<Object> retryPolicy, S3ConnectorApi s3Api) {
 
         this.retryPolicy = retryPolicy;
-        this.monitor = monitor;
         this.s3Api = s3Api;
     }
 
@@ -79,8 +73,8 @@ public CompletableFuture<StatusResult<ProvisionResponse>> provision(IonosS3Resou
         if (resourceDefinition.getStorage() != null) {
             resourceBuilder = resourceBuilder.storage(resourceDefinition.getStorage());
         }
-        if (resourceDefinition.getBlobName() != null) {
-            resourceBuilder = resourceBuilder.blobName(resourceDefinition.getBlobName());
+        if (resourceDefinition.getPath() != null) {
+            resourceBuilder = resourceBuilder.path(resourceDefinition.getPath());
         }
         var resource = resourceBuilder.build();
 
@@ -99,12 +93,9 @@ public CompletableFuture<StatusResult<DeprovisionedResource>> deprovision(
                         StatusResult.success(DeprovisionedResource.Builder.newInstance().provisionedResourceId(provisionedResource.getId()).build())
                 );
     }
-    
-    @NotNull
-    private CompletableFuture<Void> createBucket(String bucketName) {
-        return with(retryPolicy).runAsync(() -> {
-            s3Api.createBucket(bucketName);
-        });
+
+    private void createBucket(String bucketName) {
+        s3Api.createBucket(bucketName);
     }
 
 }
diff --git a/extensions/provision-ionos-s3/src/main/java/com/ionos/edc/provision/s3/bucket/IonosS3ResourceDefinition.java b/extensions/provision-ionos-s3/src/main/java/com/ionos/edc/provision/s3/bucket/IonosS3ResourceDefinition.java
index 22fab18..4d407d8 100644
--- a/extensions/provision-ionos-s3/src/main/java/com/ionos/edc/provision/s3/bucket/IonosS3ResourceDefinition.java
+++ b/extensions/provision-ionos-s3/src/main/java/com/ionos/edc/provision/s3/bucket/IonosS3ResourceDefinition.java
@@ -17,7 +17,6 @@
 import java.util.Objects;
 
 import com.fasterxml.jackson.annotation.JsonCreator;
-import com.fasterxml.jackson.annotation.JsonTypeName;
 import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
 import org.eclipse.edc.connector.transfer.spi.types.ResourceDefinition;
 
@@ -25,11 +24,10 @@
 public class IonosS3ResourceDefinition extends ResourceDefinition {
     private String keyName;
     private String storage;
-
     private String bucketName;
-    private String blobName;
-    private String accessKey = "DEFAULT";
-
+    private String path;
+    private String accessKey;
+    private String secretKey;
 
     public IonosS3ResourceDefinition() {
 
@@ -40,30 +38,27 @@ public String getKeyName() {
     public String getStorage() {
         return storage;
     }
-
 	public String getBucketName() {
         return bucketName;
     }
-    public String getBlobName() {
-        return blobName;
-    }
-    public String getAccessKey() {
-        return accessKey;
+    public String getPath() {
+        return path;
     }
+
     @Override
     public Builder toBuilder() {
         return initializeBuilder(new Builder())
                 .keyName(keyName)
                 .storage(storage)
-                .accessKey(accessKey)
                 .bucketName(bucketName)
-                .blobName(blobName);
+                .path(path)
+                .accessKey(accessKey)
+                .secretKey(secretKey);
     }
 
     public static class Builder extends ResourceDefinition.Builder<IonosS3ResourceDefinition, Builder> {
 
         private Builder() {
-
             super(new IonosS3ResourceDefinition());
         }
         @JsonCreator
@@ -75,26 +70,26 @@ public Builder keyName(String keyName) {
             resourceDefinition.keyName = keyName;
             return this;
         }
-
         public Builder storage(String storage) {
             resourceDefinition.storage = storage;
             return this;
         }
-
-        
         public Builder bucketName(String bucketName) {
             resourceDefinition.bucketName = bucketName;
             return this;
         }
-
-        public Builder blobName(String blobName) {
-            resourceDefinition.blobName = blobName;
+        public Builder path(String path) {
+            resourceDefinition.path = path;
             return this;
         }
         public Builder accessKey(String accessKey) {
             resourceDefinition.accessKey = accessKey;
             return this;
         }
+        public Builder secretKey(String secretKey) {
+            resourceDefinition.secretKey = secretKey;
+            return this;
+        }
 
         @Override
         protected void verify() {