|
@@ -88,7 +88,11 @@ async function run() {
|
|
|
.sort({ publishTime: 'desc' })
|
|
.sort({ publishTime: 'desc' })
|
|
|
.cursor()
|
|
.cursor()
|
|
|
.eachAsync(job)
|
|
.eachAsync(job)
|
|
|
- .catch(err => console.error(err.message))
|
|
|
|
|
|
|
+ .catch(err => {
|
|
|
|
|
+ console.error(err.message);
|
|
|
|
|
+ // 出错重试
|
|
|
|
|
+ run();
|
|
|
|
|
+ })
|
|
|
.then(() => require('process').exit(0))
|
|
.then(() => require('process').exit(0))
|
|
|
|
|
|
|
|
async function job(doc) {
|
|
async function job(doc) {
|
