获取在线解压策略(Java SDK)
功能介绍
桶拥有者或拥有获取在线解压策略权限的用户可通过本接口查询指定桶的文件解压策略。如果策略存在,则返回成功,status code返回值为200。了解更多在线解压相关信息,请参见在线解压。
融合桶不支持在线解压。
开发过程中,您有任何问题可以在github上提交issue,或者在华为云对象存储服务论坛中发帖求助。
方法定义
obsClient.getBucketCompressPolicy(GetBucketCompressPolicyRequest request)
请求参数说明
| 参数名称 | 参数类型 | 是否必选 | 描述 |
|---|---|---|---|
| request | 必选 | 参数解释: |
| 参数名称 | 参数类型 | 是否必选 | 描述 |
|---|---|---|---|
| bucketName | String | 必选 | 参数解释: 桶名。 约束限制:
默认取值: 无 |
返回结果说明
| 参数名称 | 参数类型 | 描述 |
|---|---|---|
| statusCode | int | 参数解释: HTTP状态码。 取值范围: 状态码是一组从2xx(成功)到4xx或5xx(错误)的数字代码,状态码表示了请求响应的状态。 完整的状态码列表请参见状态码。 默认取值: 无 |
| responseHeaders | Map<String, Object> | 参数解释: HTTP响应消息头列表,由多个元组构成。元组中String代表响应消息头的名称,Object代表响应消息头的值。 默认取值: 无 |
| compressPolicyConfiguration | 参数解释: 策略规则数组。详见表4。 |
| 参数名称 | 参数类型 | 描述 |
|---|---|---|
| rules | List<表5> | 参数解释: 策略规则数组。详见表5。 约束限制: 同一个桶下的不同策略前缀不能重复和起始包含,委托建议使用同一个。 取值范围: 数组大小[1, 10]。 默认取值: 无 |
| 参数名称 | 参数类型 | 描述 |
|---|---|---|
| id | String | 参数解释: 解压策略名称。当前桶上配置的解压规则的唯一标识。例如:event_0001。 |
| project | String | 参数解释: 项目ID。 |
| agency | String | 参数解释: IAM委托名。 |
| events | List<String> | 参数解释: 触发事件类型。 取值范围: ["ObjectCreated:*"] ["ObjectCreated:Put"] ["ObjectCreated:Post"] ["ObjectCreated:Copy"] ["ObjectCreated:CompleteMultipartUpload"] |
| suffix | String | 参数解释: 匹配规则后缀。 |
| prefix | String | 参数解释: 匹配规则前缀。 |
| overwrite | int | 参数解释: 解压后同名文件的处理方式。 取值范围:
|
| decompresspath | String | 参数解释: 文件解压后存放的路径。 |
| policytype | String | 参数解释: 文件解压策略类型。 取值范围: decompress:执行解压操作。 |
代码示例
import com.obs.services.ObsClient;
import com.obs.services.exception.ObsException;
import com.obs.services.model.compress.CompressPolicyRule;
import com.obs.services.model.compress.GetBucketCompressPolicyRequest;
import com.obs.services.model.compress.GetBucketCompressPolicyResult;
public class GetBucketCompressPolicy {
public static void main(String[] args) {
// 您可以通过环境变量获取访问密钥AK/SK,也可以使用其他外部引入方式传入。如果使用硬编码可能会存在泄露风险。
// 您可以登录访问管理控制台获取访问密钥AK/SK
String ak = System.getenv("ACCESS_KEY_ID");
String sk = System.getenv("SECRET_ACCESS_KEY_ID");
// 【可选】如果使用临时AK/SK和SecurityToken访问OBS,同样建议您尽量避免使用硬编码,以降低信息泄露风险。
// 您可以通过环境变量获取访问密钥AK/SK/SecurityToken,也可以使用其他外部引入方式传入。
String securityToken = System.getenv("SECURITY_TOKEN");
// endpoint填写桶所在的endpoint, 此处以华北-北京四为例,其他地区请按实际情况填写。
// 您可以通过环境变量获取endPoint,也可以使用其他外部引入方式传入。
String endPoint = System.getenv("ENDPOINT");
ObsConfiguration obsConfiguration = new ObsConfiguration();
obsConfiguration.setEndPoint(endPoint);
ObsClient obsClient = new ObsClient(ak, sk, securityToken, obsConfiguration);
try {
String exampleBucket = "exampleBucket";
GetBucketCompressPolicyResult result =
obsClient.getBucketCompressPolicy(new GetBucketCompressPolicyRequest(exampleBucket));
System.out.println("GetBucketCompressPolicy successfully");
for (CompressPolicyRule rule : result.getCompressPolicyConfiguration().getRules()) {
System.out.println("Rule Id:"+ rule.getId());
System.out.println("Project Id:"+ rule.getProject());
System.out.println("Agency:"+ rule.getAgency());
System.out.println("Events:"+ rule.getEvents());
System.out.println("Prefix:"+ rule.getPrefix());
System.out.println("Suffix:"+ rule.getSuffix());
System.out.println("Overwrite:"+ rule.getOverwrite());
System.out.println("Decompress Path:"+ rule.getDecompresspath());
System.out.println("Policy Type:"+ rule.getPolicytype());
}
} catch (ObsException e) {
System.out.println("GetBucketCompressPolicy failed");
// 请求失败,打印http状态码
System.out.println("HTTP Code:" + e.getResponseCode());
// 请求失败,打印服务端错误码
System.out.println("Error Code:" + e.getErrorCode());
// 请求失败,打印详细错误信息
System.out.println("Error Message:" + e.getErrorMessage());
// 请求失败,打印请求id
System.out.println("Request ID:" + e.getErrorRequestId());
System.out.println("Host ID:" + e.getErrorHostId());
e.printStackTrace();
} catch (Exception e) {
System.out.println("GetBucketCompressPolicy failed");
// 其他异常信息打印
e.printStackTrace();
}
}
}