~~~ const Movie = mongoose.model('Movie'); child.on('message',data=>{ let result = data.result; result.forEach(async item=>{ var doubanId = item.doubanId; let movie = await Movie.findOne({ doubanId }) if(!movie){ movie = new Movie(item); await movie.save() } }) }) ~~~