8

我通过他们的 API 从 Wundground 提取 JSON 格式的天气数据，没有任何问题。我正在尝试将该数据存储在 MongoDB 中以备后用。我实际上得到了数据，并且能够将其写入 Mongo 的集合中。但是，当我执行 db.collection.find() 时，几乎看起来每个单独的字符都是单独保存的，而不是 JSON 格式。这是获取数据并应保存到 Mongo 的代码片段：

// Define the Wunderground method.
var method = "/api/" + apiKey + "/conditions/q/" + state + "/" + city + ".json";

// Define the HTTP post properties.
var options = {
  host: 'api.wunderground.com',
  path: method,
  method: 'GET',
  port: 80
};

// Create the HTTP POST.
var request = http.request(options, function (response) {
  var str = '';

  // Create the listener for data being returned.
  response.on('data', function (chunk) {
    str += chunk;


    // Create the listener for the end of the POST.
    response.on('end', function (){
      db.collection('weathercollection').save(str, function(err, records) {
        if (err) throw err;
        console.log("record added");
      });
    });

JSON 格式的天气数据的一小段摘录：

{ "current_observation": {
    "image": {
    "url": "http://icons-ak.com/graphics/logo.png",
    "title": "Weather Underground"
    },
    "display_location": {
    "full":"My City, State",
    "city":"My City",

我不应该在保存到 Mongo 之前解析数据吗？所以我错过了什么。正如我所说，如果我将所有天气数据输出到控制台，我似乎只是在 Node.JS 和 MongoDB 之间做错了事。

谢谢。

更新***

我确实尝试用这种方式解析“str”

// Create the listener for data being returned.
response.on('data', function (chunk) {
str += chunk;

var jsonResult = JSON.parse(str);

// Create the listener for the end of the POST.
response.on('end', function (){
  db.collection('weathercollection').save(jsonResult, function(err, records) {
    if (err) throw err;
    console.log("record added");`

那似乎也不起作用。我会再看一遍。

4

2 回答 2

13

是的，您需要为您的send函数提供一个 JavaScript 对象（参见MongoDB 本机驱动程序文档，看起来您正在使用它），但是您向它发送了一个字符串（这就是您可以在每个data事件上连接它的原因）。您必须使用JSON.parse(str).

如果您想确定正在处理的数据类型，请打印typeof strand的结果typeof JSON.parse(str)。

编辑：您的代码中有第二个问题。该response对象实际上是一个流，这意味着它在接收到数据时会发出数据。这也意味着您可以data多次接收该事件。这就是为什么您需要：

  1. 创建一个空字符串
  2. 在每个data事件上，将您刚刚收到的块连接到字符串
  3. 仅当您确定不会再收到任何数据时，才尝试解析它。

在您提供的更新代码片段中，您尝试解析第一个数据事件的字符串，但这可能是一个不完整的字符串。

这是实现此目的的正确方法：

var str = '';
response.on('data', function(chunk) {
  str += chunk;
});
response.on('end', function() {
  var myObject = JSON.parse(str);
  // Send the Mongo query here
});

与此问题相关，您还为该事件注册了一个侦听器end，这很好，但是您为每个data事件添加了一个新侦听器！这意味着如果您收到 5 个数据事件，您将调用 5 次将对象添加到 MongoDB 的函数……在上面的代码片段中，请注意我已将回调response.on('end', function() {…})的外部移动。response.on('data')

于 2013-11-07T21:03:10.740 回答
0 
var MongoClient = require('mongodb').MongoClient, format = require('util').format;

MongoClient.connect('mongodb://127.0.0.1:27017/test', function(err,db) {

    if (err) throw err;
    console.log("Connected to Database");
    var document = {name:"David", title:"About MongoDB"};

    // insert record
    db.collection('test').insert(document, function(err, records) {
        if (err) throw err;
        console.log("Record added as " + records[0]._id);
    });
});

参考来自： http ://code.runnable.com/UW3ef2Tkq498AABE/insert-a-record-in-mongodb-using-mongodb-native-for-node-js

于 2016-07-21T09:36:39.200 回答