forked from qiniu/java-sdk
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathResourcesCensor.java
More file actions
137 lines (110 loc) · 4.69 KB
/
Copy pathResourcesCensor.java
File metadata and controls
137 lines (110 loc) · 4.69 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
package com.examples;
import com.google.gson.Gson;
import com.qiniu.common.QiniuException;
import com.qiniu.http.Client;
import com.qiniu.util.Auth;
import com.qiniu.util.StringMap;
import java.util.HashMap;
import java.util.Map;
/**
* 内容安全审核 demo
* ImageCensor 图片内容安全审核，同步处理，不需要查询处理结果
* VideoCensor 视频内容安全审核，异步处理，需要查询处理结果，返回处理任务ID
* getVideoCensorResultByJobID 根据视频内容审核任务ID，查询审核结果
*/
public class ResourcesCensor {
//设置好账号的ACCESS_KEY和SECRET_KEY
private static final String ACCESS_KEY = "填写你们自己的ak";
private static final String SECRET_KEY = "填写你们自己的sk";
private final Auth auth = Auth.create(ACCESS_KEY, SECRET_KEY);
private final Client client = new Client();
public static void main(String args[]) {
ResourcesCensor resourcesCensor = new ResourcesCensor();
String result;
try {
//result = resourcesCensor.ImageCensor();
result = resourcesCensor.VideoCensor();
System.out.println(result);
/* 只有视频审核才会返回jobID */
Gson gson = new Gson();
Map<String, String> jobMap = new HashMap();
String jobID = (String) gson.fromJson(result, jobMap.getClass()).get("job");
String videoCensorResult = resourcesCensor.getVideoCensorResultByJobID(jobID);
System.out.println(videoCensorResult);
} catch (QiniuException e) {
e.printStackTrace();
}
}
//参考api文档 https://developer.qiniu.com/dora/manual/4252/image-review
//图片审核
public String ImageCensor() throws QiniuException {
// 构造post请求body
Gson gson = new Gson();
Map<String, Object> uri = new HashMap<>();
uri.put("uri", "http://oayjpradp.bkt.clouddn.com/Audrey_Hepburn.jpg");
Map<String, Object> scenes = new HashMap<>();
//pulp 黄 terror 恐 politician 敏感人物
String[] types = {"pulp", "terror", "politician", "ads"};
scenes.put("scenes", types);
Map params = new HashMap();
params.put("data", uri);
params.put("params", scenes);
String paraR = gson.toJson(params);
byte[] bodyByte = paraR.getBytes();
// 接口请求地址
String url = "http://ai.qiniuapi.com/v3/image/censor";
return post(url, bodyByte);
}
//参考api文档 https://developer.qiniu.com/dora/manual/4258/video-pulp
//视频审核
public String VideoCensor() throws QiniuException {
// 构造post请求body
Gson gson = new Gson();
Map bodyData = new HashMap();
Map<String, Object> uri = new HashMap<>();
uri.put("uri", "https://mars-assets.qnssl.com/scene.mp4");
Map<String, Object> params = new HashMap<>();
Map<String, Object> scenes = new HashMap<>();
//pulp 黄 terror 恐 politician 敏感人物
String[] types = {"pulp", "terror", "politician"};
Map<String, Object> cut_param = new HashMap<>();
cut_param.put("interval_msecs", 500);
params.put("scenes", types);
params.put("cut_param", cut_param);
bodyData.put("data", uri);
bodyData.put("params", params);
String paraR = gson.toJson(bodyData);
byte[] bodyByte = paraR.getBytes();
// 接口请求地址
String url = "http://ai.qiniuapi.com/v3/video/censor";
return post(url, bodyByte);
}
/**
* 查询视频审核内容结果
* 参考
* https://developer.qiniu.com/censor/api/5620/video-censor#4
* @param ID : 视频审核返回的 job ID
*
*/
public String getVideoCensorResultByJobID(String ID){
String url = "http://ai.qiniuapi.com/v3/jobs/video/".concat(ID);
String accessToken = (String) auth.authorizationV2(url).get("Authorization");
StringMap headers = new StringMap();
headers.put("Authorization", accessToken);
try {
com.qiniu.http.Response resp = client.get(url,headers);
return resp.bodyString();
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
private String post(String url, byte[] body) throws QiniuException {
String accessToken = (String) auth.authorizationV2(url, "POST", body, "application/json")
.get("Authorization");
StringMap headers = new StringMap();
headers.put("Authorization", accessToken);
com.qiniu.http.Response resp = client.post(url, body, headers, Client.JsonMime);
return resp.bodyString();
}
}