Skip to content

Commit 5d8da3a

Browse files
jemygrawjemygraw
committed
add rs batch examples
1 parent 71508d5 commit 5d8da3a

File tree

7 files changed

+247
-24
lines changed

7 files changed

+247
-24
lines changed

‎examples/rs_batch_change_type.js‎

Lines changed: 39 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,39 @@
1+
const qiniu = require("../index.js");
2+
const proc = require("process");
3+
4+
var accessKey = proc.env.QINIU_ACCESS_KEY;
5+
var secretKey = proc.env.QINIU_SECRET_KEY;
6+
var mac = new qiniu.auth.digest.Mac(accessKey, secretKey);
7+
var config = new qiniu.conf.Config();
8+
var bucketManager = new qiniu.rs.BucketManager(mac, config);
9+
10+
var srcBucket = 'if-pbl';
11+
12+
//每个operations的数量不可以超过1000个，如果总数量超过1000，需要分批发送
13+
var changeTypeOperations = [
14+
qiniu.rs.changeTypeOp(srcBucket, 'qiniu1.mp4', 1),
15+
qiniu.rs.changeTypeOp(srcBucket, 'qiniu2.mp4', 1),
16+
qiniu.rs.changeTypeOp(srcBucket, 'qiniu3.mp4', 1),
17+
qiniu.rs.changeTypeOp(srcBucket, 'qiniu4.mp4', 1),
18+
];
19+
20+
bucketManager.batch(changeTypeOperations, function(err, respBody, respInfo) {
21+
if (err) {
22+
console.log(err);
23+
//throw err;
24+
} else {
25+
// 200 is success, 298 is part success
26+
if (parseInt(respInfo.statusCode / 100) == 2) {
27+
respBody.forEach(function(item) {
28+
if (item.code == 200) {
29+
console.log("success");
30+
} else {
31+
console.log(item.code + "\t" + item.data.error);
32+
}
33+
});
34+
} else {
35+
console.log(respInfo.statusCode);
36+
console.log(respBody);
37+
}
38+
}
39+
});

‎examples/rs_batch_chgm.js‎

Lines changed: 39 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,39 @@
1+
const qiniu = require("../index.js");
2+
const proc = require("process");
3+
4+
var accessKey = proc.env.QINIU_ACCESS_KEY;
5+
var secretKey = proc.env.QINIU_SECRET_KEY;
6+
var mac = new qiniu.auth.digest.Mac(accessKey, secretKey);
7+
var config = new qiniu.conf.Config();
8+
var bucketManager = new qiniu.rs.BucketManager(mac, config);
9+
10+
var srcBucket = 'if-pbl';
11+
12+
//每个operations的数量不可以超过1000个，如果总数量超过1000，需要分批发送
13+
var chgmOperations = [
14+
qiniu.rs.changeMimeOp(srcBucket, 'qiniu1.mp4', 'video/x-mp4'),
15+
qiniu.rs.changeMimeOp(srcBucket, 'qiniu2.mp4', 'video/x-mp4'),
16+
qiniu.rs.changeMimeOp(srcBucket, 'qiniu3.mp4', 'video/x-mp4'),
17+
qiniu.rs.changeMimeOp(srcBucket, 'qiniu4.mp4', 'video/x-mp4'),
18+
];
19+
20+
bucketManager.batch(chgmOperations, function(err, respBody, respInfo) {
21+
if (err) {
22+
console.log(err);
23+
//throw err;
24+
} else {
25+
// 200 is success, 298 is part success
26+
if (parseInt(respInfo.statusCode / 100) == 2) {
27+
respBody.forEach(function(item) {
28+
if (item.code == 200) {
29+
console.log("success");
30+
} else {
31+
console.log(item.code + "\t" + item.data.error);
32+
}
33+
});
34+
} else {
35+
console.log(respInfo.statusCode);
36+
console.log(respBody);
37+
}
38+
}
39+
});

‎examples/rs_batch.js‎ renamed to ‎examples/rs_batch_copy.js‎

Lines changed: 10 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -24,31 +24,17 @@ bucketManager.batch(copyOperations, function(err, respBody, respInfo) {
2424
console.log(err);
2525
//throw err;
2626
} else {
27-
if (respInfo.statusCode == 200) {
28-
console.log(respBody);
29-
} else {
30-
console.log(respInfo.statusCode);
31-
console.log(respBody);
32-
}
33-
}
34-
});
35-
36-
var statOperations = [
37-
qiniu.rs.statOp(srcBucket, 'qiniu1.mp4'),
38-
qiniu.rs.statOp(srcBucket, 'qiniu2.mp4'),
39-
qiniu.rs.statOp(srcBucket, 'qiniu3.mp4'),
40-
qiniu.rs.statOp(srcBucket, 'qiniu4.mp4'),
41-
];
42-
43-
bucketManager.batch(statOperations, function(err, respBody, respInfo) {
44-
if (err) {
45-
console.log(err);
46-
//throw err;
47-
} else {
48-
if (respInfo.statusCode == 200) {
49-
console.log(respBody);
27+
// 200 is success, 298 is part success
28+
if (parseInt(respInfo.statusCode / 100) == 2) {
29+
respBody.forEach(function(item) {
30+
if (item.code == 200) {
31+
console.log(item.code + "\tsuccess");
32+
} else {
33+
console.log(item.code + "\t" + item.data.error);
34+
}
35+
});
5036
} else {
51-
console.log(respInfo.statusCode);
37+
console.log(respInfo.deleteusCode);
5238
console.log(respBody);
5339
}
5440
}

‎examples/rs_batch_delete.js‎

Lines changed: 39 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,39 @@
1+
const qiniu = require("../index.js");
2+
const proc = require("process");
3+
4+
var accessKey = proc.env.QINIU_ACCESS_KEY;
5+
var secretKey = proc.env.QINIU_SECRET_KEY;
6+
var mac = new qiniu.auth.digest.Mac(accessKey, secretKey);
7+
var config = new qiniu.conf.Config();
8+
var bucketManager = new qiniu.rs.BucketManager(mac, config);
9+
10+
var srcBucket = 'if-pbl';
11+
12+
//每个operations的数量不可以超过1000个，如果总数量超过1000，需要分批发送
13+
var deleteOperations = [
14+
qiniu.rs.deleteOp(srcBucket, 'qiniu1.mp4'),
15+
qiniu.rs.deleteOp(srcBucket, 'qiniu2.mp4'),
16+
qiniu.rs.deleteOp(srcBucket, 'qiniu3.mp4'),
17+
qiniu.rs.deleteOp(srcBucket, 'qiniu4x.mp4'),
18+
];
19+
20+
bucketManager.batch(deleteOperations, function(err, respBody, respInfo) {
21+
if (err) {
22+
console.log(err);
23+
//throw err;
24+
} else {
25+
// 200 is success, 298 is part success
26+
if (parseInt(respInfo.statusCode / 100) == 2) {
27+
respBody.forEach(function(item) {
28+
if (item.code == 200) {
29+
console.log(item.code + "\tsuccess");
30+
} else {
31+
console.log(item.code + "\t" + item.data.error);
32+
}
33+
});
34+
} else {
35+
console.log(respInfo.deleteusCode);
36+
console.log(respBody);
37+
}
38+
}
39+
});

‎examples/rs_batch_delete_after_days.js‎

Lines changed: 39 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,39 @@
1+
const qiniu = require("../index.js");
2+
const proc = require("process");
3+
4+
var accessKey = proc.env.QINIU_ACCESS_KEY;
5+
var secretKey = proc.env.QINIU_SECRET_KEY;
6+
var mac = new qiniu.auth.digest.Mac(accessKey, secretKey);
7+
var config = new qiniu.conf.Config();
8+
var bucketManager = new qiniu.rs.BucketManager(mac, config);
9+
10+
var srcBucket = 'if-pbl';
11+
12+
//每个operations的数量不可以超过1000个，如果总数量超过1000，需要分批发送
13+
var deleteAfterDaysOperations = [
14+
qiniu.rs.deleteAfterDaysOp(srcBucket, 'qiniu1.mp4', 10),
15+
qiniu.rs.deleteAfterDaysOp(srcBucket, 'qiniu2.mp4', 10),
16+
qiniu.rs.deleteAfterDaysOp(srcBucket, 'qiniu3.mp4', 10),
17+
qiniu.rs.deleteAfterDaysOp(srcBucket, 'qiniu4.mp4', 10),
18+
];
19+
20+
bucketManager.batch(deleteAfterDaysOperations, function(err, respBody, respInfo) {
21+
if (err) {
22+
console.log(err);
23+
//throw err;
24+
} else {
25+
// 200 is success, 298 is part success
26+
if (parseInt(respInfo.statusCode / 100) == 2) {
27+
respBody.forEach(function(item) {
28+
if (item.code == 200) {
29+
console.log("success");
30+
} else {
31+
console.log(item.code + "\t" + item.data.error);
32+
}
33+
});
34+
} else {
35+
console.log(respInfo.statusCode);
36+
console.log(respBody);
37+
}
38+
}
39+
});

‎examples/rs_batch_move.js‎

Lines changed: 40 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,40 @@
1+
const qiniu = require("../index.js");
2+
const proc = require("process");
3+
4+
var accessKey = proc.env.QINIU_ACCESS_KEY;
5+
var secretKey = proc.env.QINIU_SECRET_KEY;
6+
var mac = new qiniu.auth.digest.Mac(accessKey, secretKey);
7+
var config = new qiniu.conf.Config();
8+
var bucketManager = new qiniu.rs.BucketManager(mac, config);
9+
10+
var srcBucket = 'if-pbl';
11+
var destBucket = srcBucket;
12+
13+
//每个operations的数量不可以超过1000个，如果总数量超过1000，需要分批发送
14+
var moveOperations = [
15+
qiniu.rs.moveOp(srcBucket, 'qiniu1.mp4', destBucket, 'qiniu1_move.mp4'),
16+
qiniu.rs.moveOp(srcBucket, 'qiniu2.mp4', destBucket, 'qiniu2_move.mp4'),
17+
qiniu.rs.moveOp(srcBucket, 'qiniu3.mp4', destBucket, 'qiniu3_move.mp4'),
18+
qiniu.rs.moveOp(srcBucket, 'qiniu4.mp4', destBucket, 'qiniu4_move.mp4'),
19+
];
20+
21+
bucketManager.batch(moveOperations, function(err, respBody, respInfo) {
22+
if (err) {
23+
console.log(err);
24+
//throw err;
25+
} else {
26+
// 200 is success, 298 is part success
27+
if (parseInt(respInfo.statusCode / 100) == 2) {
28+
respBody.forEach(function(item) {
29+
if (item.code == 200) {
30+
console.log(item.code + "\tsuccess");
31+
} else {
32+
console.log(item.code + "\t" + item.data.error);
33+
}
34+
});
35+
} else {
36+
console.log(respInfo.deleteusCode);
37+
console.log(respBody);
38+
}
39+
}
40+
});

‎examples/rs_batch_stat.js‎

Lines changed: 41 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,41 @@
1+
const qiniu = require("../index.js");
2+
const proc = require("process");
3+
4+
var accessKey = proc.env.QINIU_ACCESS_KEY;
5+
var secretKey = proc.env.QINIU_SECRET_KEY;
6+
var mac = new qiniu.auth.digest.Mac(accessKey, secretKey);
7+
var config = new qiniu.conf.Config();
8+
var bucketManager = new qiniu.rs.BucketManager(mac, config);
9+
10+
var srcBucket = 'if-pbl';
11+
12+
//每个operations的数量不可以超过1000个，如果总数量超过1000，需要分批发送
13+
var statOperations = [
14+
qiniu.rs.statOp(srcBucket, 'qiniu1.mp4'),
15+
qiniu.rs.statOp(srcBucket, 'qiniu2.mp4'),
16+
qiniu.rs.statOp(srcBucket, 'qiniu3.mp4'),
17+
qiniu.rs.statOp(srcBucket, 'qiniu4x.mp4'),
18+
];
19+
20+
bucketManager.batch(statOperations, function(err, respBody, respInfo) {
21+
if (err) {
22+
console.log(err);
23+
//throw err;
24+
} else {
25+
// 200 is success, 298 is part success
26+
if (parseInt(respInfo.statusCode / 100) == 2) {
27+
respBody.forEach(function(item) {
28+
if (item.code == 200) {
29+
console.log(item.data.fsize + "\t" + item.data.hash + "\t" +
30+
item.data.mimeType + "\t" + item.data.putTime + "\t" +
31+
item.data.type);
32+
} else {
33+
console.log(item.code + "\t" + item.data.error);
34+
}
35+
});
36+
} else {
37+
console.log(respInfo.statusCode);
38+
console.log(respBody);
39+
}
40+
}
41+
});

0 commit comments

Comments
 (0)