获取DIS通知策略(Java SDK)
功能介绍
本接口用于查询指定桶的DIS通知策略信息。如果策略存在，则返回成功，status code返回值为200。
融合桶不支持设置DIS通知策略。
开发过程中，您有任何问题可以在github上提交issue，或者在华为云对象存储服务论坛中发帖求助。
接口约束
- 您必须是桶拥有者或者拥有Tenant Administrator权限，才能调用本接口。配置Tenant Administrator权限，需要使用角色与策略授权（旧版IAM，即IAM v3接口），授权操作请参考使用IAM授权。
- OBS支持的region以及region与endPoint的对应关系，详细信息请参见地区与终端节点。
方法定义
obsClient.getBucketDisPolicy(GetBucketDisPolicyRequest request)
请求参数说明
| 参数名称 | 参数类型 | 是否必选 | 描述 |
|---|---|---|---|
| request | 必选 | 参数解释： 请求参数，详见表2 GetBucketDisPolicyRequest。 |
| 参数名称 | 参数类型 | 是否必选 | 描述 |
|---|---|---|---|
| bucketName | String | 必选 | 参数解释： 桶名。 约束限制：
默认取值： 无 |
返回结果说明
| 参数名称 | 参数类型 | 描述 |
|---|---|---|
| statusCode | int | 参数解释： HTTP状态码。 取值范围： 状态码是一组从2xx（成功）到4xx或5xx（错误）的数字代码，状态码表示了请求响应的状态。 完整的状态码列表请参见状态码。 默认取值： 无 |
| responseHeaders | Map<String, Object> | 参数解释： HTTP响应消息头列表，由多个元组构成。元组中String代表响应消息头的名称，Object代表响应消息头的值。 默认取值： 无 |
| disPolicyConfiguration | 参数解释： DIS通知规则，详见表4 DisPolicyConfiguration。 |
| 参数名称 | 参数类型 | 描述 |
|---|---|---|
| rules | List<表5 DisPolicyRule> | 参数解释： DIS通知规则列表，详见表5 DisPolicyRule。 |
| 参数名称 | 参数类型 | 描述 |
|---|---|---|
| id | String | 参数解释： 规则ID。当前桶上配置的DIS策略规则的唯一标识。 |
| stream | String | 参数解释： DIS服务通道名称。 |
| project | String | 参数解释： DIS服务通道所属的项目ID。 |
| events | List<String> | 参数解释： OBS事件列表。 取值范围： 有效值：长度[0, 1023]，值允许为任意字符，支持如下事件类型：
|
| prefix | String | 参数解释： 对象名前缀，用于指定的对象名关键字，根据定义的前缀，输入需要过滤的对象的关键字信息，字符越长匹配精度越高。 |
| suffix | String | 参数解释： 对象名后缀。用于指定的对象名关键字，根据定义的后缀，输入需要过滤的对象的关键字信息，字符越长匹配精度越高。 |
| agency | String | 参数解释： IAM委托名。 |
代码示例
import com.obs.services.ObsClient;
import com.obs.services.exception.ObsException;
import com.obs.services.model.dis.DisPolicyRule;
import com.obs.services.model.dis.GetBucketDisPolicyRequest;
import com.obs.services.model.dis.GetBucketDisPolicyResult;
public class GetBucketDisPolicy {
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";
GetBucketDisPolicyResult result =
obsClient.getBucketDisPolicy(new GetBucketDisPolicyRequest(exampleBucket));
System.out.println("GetBucketDisPolicy successfully");
for (DisPolicyRule rule : result.getDisPolicyConfiguration().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());
}
} catch (ObsException e) {
System.out.println("GetBucketDisPolicy 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("GetBucketDisPolicy failed");
// 其他异常信息打印
e.printStackTrace();
}
}
} 
