通过nodejs将推文插入mongodb

本文介绍了通过nodejs将推文插入mongodb的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！ 问题描述

这是使用nodejs从Twitter提取数据的代码.现在我想将其存储在mongodb中.谁能指导我该怎么做.无法做.

Here is the code using nodejs which fetches data from twitter. Now i want to store it in mongodb. Can anyone please guide me the steps how to do. Unable to do.

var app = require('express').createServer(), twitter = require('ntwitter'); app.listen(3000); var a = 'love'; var b = 'hate'; var watchList = [a, b]; var twit = new twitter({ consumer_key: 'FtRTll97RNnYksFDMGMyCkMwF', consumer_secret: 'laazWFm8p9nV6rx2H3PohRqwaB1jK1mUBus8BjEZfJlMW9gXwK', access_token_key: '194952208-QMGEHqeY03XUSVLHa0pPueVVMLRICVtMCLSsu6m9', access_token_secret: 'KivtwgKZ45rSdkEExVsYG8Ows9kPoRKl692PomUFSZ3Mp' }); twit.stream('statuses/filter', { track: watchList }, function (stream) { stream.on('data', function (data) { console.log(data.user.screen_name + ': ' + data.text); }); });

推荐答案

使用以下代码片段在推文文档中插入.

use following snippet to insert in tweets document.

stream.on('data', function (data) { console.log(data); console.log("\n\n\n\n"); db.tweets.findAndModify({ query: {'id': 'data.id'}, update: { $set: data}, upsert: true, new: true }) });

在上面的代码中，如果已经存在tweet ID，它将被更新，否则插入新记录.

In above code if tweet id already present it will be update otherwise insert new record.

upsert:如果设置为true，则在没有文档符合查询条件时创建一个新文档.默认值为false，如果找不到匹配项，则不会插入新文档.

谢谢