Creating a Bucket¶
Scenarios¶
A bucket is a container that stores objects in OBS. You need to create a bucket before storing data in OBS.
The following describes how to call the API for creating a bucket in a specified region. For details about how to call an API, see Calling APIs.
Prerequisites¶
You have obtained the AK and SK. For details about how to obtain the AK and SK, see Obtaining Access Keys (AK/SK).
You have planned the region where you want to create a bucket and obtained the endpoint required for API calls. For details, see Regions and Endpoints.
Once a region is determined, it cannot be modified after the bucket is created.
Creating a Bucket Named bucket001 in the a1 Region¶
In this example, an Apache HttpClient is used.
package com.obsclient;
import java.io.*;
import org.apache.http.Header;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPut;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
public class TestMain {
/* Hard-coded or plaintext AK and SK are risky. For security purposes, encrypt your AK and SK and store them in the configuration file or environment variables.
In this example, the AK and SK are stored in environment variables for identity authentication. Before running the code in this example, configure environment variables OTCCLOUD_SDK_AK and OTCCLOUD_SDK_SK. */
public static String accessKey = System.getenv("OTCCLOUD_SDK_AK"); //The value is the AK obtained.
public static String securityKey = System.getenv("OTCCLOUD_SDK_SK"); //The value is the SK obtained.
public static String region = "a1"; // The value is the region where the planned bucket resides.
public static String createBucketTemplate =
"<CreateBucketConfiguration " +
"xmlns=\"http://obs.a1.example.com/doc/2015-06-30/\">\n" +
"<Location>" + region + "</Location>\n" +
"</CreateBucketConfiguration>";
public static void main(String[] str) {
createBucket();
}
private static void createBucket() {
CloseableHttpClient httpClient = HttpClients.createDefault();
String requesttime = DateUtils.formatDate(System.currentTimeMillis());
String contentType = "application/xml";
HttpPut httpPut = new HttpPut("http://bucket001.obs.a1.example.com");
httpPut.addHeader("Date", requesttime);
httpPut.addHeader("Content-Type", contentType);
/**Calculate the signature based on the request.**/
String contentMD5 = "";
String canonicalizedHeaders = "";
String canonicalizedResource = "/bucket001/";
// Content-MD5 and Content-Type fields do not contain line breaks. The data format is RFC 1123, which is the same as the time in the request.
String canonicalString = "PUT" + "\n" + contentMD5 + "\n" + contentType + "\n" + requesttime + "\n" + canonicalizedHeaders + canonicalizedResource;
System.out.println("StringToSign:[" + canonicalString + "]");
String signature = null;
CloseableHttpResponse httpResponse = null;
try {
signature = Signature.signWithHmacSha1(securityKey, canonicalString);
// Added the Authorization: OBS AccessKeyID:signature field to the header.
httpPut.addHeader("Authorization", "OBS " + accessKey + ":" + signature);
// Add a body.
httpPut.setEntity(new StringEntity(createBucketTemplate));
httpResponse = httpClient.execute(httpPut);
// Prints the sending request information and the received response message.
System.out.println("Request Message:");
System.out.println(httpPut.getRequestLine());
for (Header header : httpPut.getAllHeaders()) {
System.out.println(header.getName() + ":" + header.getValue());
}
System.out.println("Response Message:");
System.out.println(httpResponse.getStatusLine());
for (Header header : httpResponse.getAllHeaders()) {
System.out.println(header.getName() + ":" + header.getValue());
}
BufferedReader reader = new BufferedReader(new InputStreamReader(
httpResponse.getEntity().getContent()));
String inputLine;
StringBuffer response = new StringBuffer();
while ((inputLine = reader.readLine()) != null) {
response.append(inputLine);
}
reader.close();
// print result
System.out.println(response.toString());
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
httpClient.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
The format of the Date header field DateUtils is as follows:
package com.obsclient;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Locale;
import java.util.TimeZone;
public class DateUtils {
public static String formatDate(long time)
{
DateFormat serverDateFormat = new SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss z", Locale.ENGLISH);
serverDateFormat.setTimeZone(TimeZone.getTimeZone("GMT"));
return serverDateFormat.format(time);
}
}
The method of calculating the signature character string is as follows:
package com.obsclient;
import javax.crypto.Mac;
import javax.crypto.spec.SecretKeySpec;
import java.io.UnsupportedEncodingException;
import java.security.NoSuchAlgorithmException;
import java.security.InvalidKeyException;
import java.util.Base64;
public class Signature {
public static String signWithHmacSha1(String sk, String canonicalString) throws UnsupportedEncodingException {
try {
SecretKeySpec signingKey = new SecretKeySpec(sk.getBytes("UTF-8"), "HmacSHA1");
Mac mac = Mac.getInstance("HmacSHA1");
mac.init(signingKey);
return Base64.getEncoder().encodeToString(mac.doFinal(canonicalString.getBytes("UTF-8")));
} catch (NoSuchAlgorithmException | InvalidKeyException | UnsupportedEncodingException e) {
e.printStackTrace();
}
return null;
}
}