使用 body-parser 和 express 解析嵌套 JSON

Question

我有一个 iOS 应用程序正在向网络服务器发送 JSON 数据包。网络服务器代码如下所示：

var express = require('express');
var bodyParser = require('body-parser');
var mongoose = require('mongoose');
var app = express();
mongoose.connect('mongodb://localhost/test');

var db = mongoose.connection;
db.on('error', console.error.bind(console, 'connection error:'));
db.once('open', function (callback) {
  console.log("MongoDB connection is open.");
});

// Mongoose Schema definition
var Schema = mongoose.Schema;
var LocationSchema = new Schema({
    X: Number,
    Y: Number,
    Orientation: Number,
    UserID: String,
    Time: String
});

// Mongoose Model definition
var LocationsCollection = mongoose.model('locations', LocationSchema);

// create application/json parser
var jsonParser = bodyParser.json();

// URL management
app.get('/', function (req, res) {
    res.sendFile(__dirname + '/index.html');
});

app.post('/update', jsonParser, function (req, res) {
    if (!req.body) return res.sendStatus(400);
    else {
        console.log(req.body);
    }
});

// Start the server
var server = app.listen(3000, function () {
  var host = server.address().address
  var port = server.address().port
  console.log('App listening at %s:%s',host, port)
});

关键部分是 app.post 方法，它处理从我的 iOS 应用程序发送的传入 http 请求。目前，将 req.body 打印到控制台的方法如下所示：

{ 
  datapoint_1:
   { timestamp: '2015-02-06T13:02:40:361Z',
     x: 0.6164286615466197,
     y: -0.6234909703424794,
     id: 'B296DF8B-6489-420A-97B4-6F0F48052758',
     orientation: 271.3345946652066 },
  datapoint_2:
   { timestamp: '2015-02-06T13:02:40:961Z',
     x: 0.6164286615466197,
     y: -0.6234909703424794,
     id: 'B296DF8B-6489-420A-97B4-6F0F48052758',
     orientation: 273.6719055175781 }
}

因此，您可以看到请求是一个嵌套的 JSON 对象。理想情况下，我想遍历请求对象（即数据点）并将它们插入 mongoDB 数据库（通过 mongoose）。但是，我似乎无法弄清楚如何使用 req.body 做很多事情。我似乎无法创建一个循环来遍历请求或如何正确解析嵌套的 JSON 文件以使其与 mongoose 模式匹配。谁能提供一些关于如何将这些数据点插入猫鼬数据库的指导？

Answer 1

尝试这样的事情。

var app = express();
var bodyParser   = require('body-parser');
app.use(bodyParser.json({limit:1024*1024, verify: function(req, res, buf){
    try {
        JSON.parse(buf);
    } catch(e) {
        res.send({
            error: 'BROKEN_JSON'
        });
    }
}}));

Answer 2

回答我自己的问题。但是，在弄清楚如何访问嵌套 JSON 对象内的 key/value 对之后……弄清楚其余部分就变得相对容易了。更新后的 app.post 函数现在如下所示：

app.post('/update', jsonParser, function (req, res) {
    if (!req.body) return res.sendStatus(400);
    else {
        for(var datapoint in req.body){
            //create new instance of LocationCollection document
            var point = new LocationsCollection({
                X:Number(req.body[datapoint]["x"]),
                Y:Number(req.body[datapoint]["y"]),
                Orientation:Number(req.body[datapoint]["orientation"]),
                Time:req.body[datapoint]["timestamp"],
                UserID:req.body[datapoint]["id"]
            });
            //insert the newly constructed document into the database
            point.save(function(err, point){
                if(err) return console.error(err);
                else console.dir(point);
            });
        }
    }
});

一旦 mongodb 连接首次建立，我可以通过将以下方法放入回调函数来测试这是否有效：

//Find all location points and print to the console.
console.log("Searching for all documents in Location Points Collection");
LocationsCollection.find(function(err,data){
    if(err) console.error(err);
    else console.dir(data);
});

这将打印之前添加到数据库中的任何文档。希望这对您有所帮助。

Answer 3

应该是一个简单的for (var key in obj)循环：

app.post('/update', jsonParser, function (req, res) {

    var locationObject = req.body(),
        insertObjects = [],
        key;

    for (key in locationObject) { // loop through each object and insert them into our array of object to insert.
        insertObjects.push(locationObject[key]); 
    }
    if (!insertObjects.length) { // if we don't have any object to insert we still return a 200, we just don't insert anything.
        return res.status(200).send({
            success: true,
            message: 'Nothing inserted, 0 locations in POST body',
            count: 0;
        });
    }
    LocationsCollection.create(insertObjects, function (err, res) {
        if (err) {
            return res.status(400).send({
                success: false,
                message: err.message
            });
        }
        // we have successfully inserted our objects. let's tell the client.
        res.status(200).send({ 
            success: true,
            message: 'successfully inserted locations',
            count: insertObjects.length;
        });
    });
});

Mongo 允许通过单个回调插入多个文档，这使这变得容易得多。

这还会检查架构以确保只创建正确的文档。

Answer 4

将 body-parser's extended 属性设置为 true 以允许解析嵌套对象。

var express = require('express');
var app = express()
var bodyParser = require('body-parser');

app.use(bodyParser.urlencoded({
    extended: true
}));

使用 body-parser 和 express 解析嵌套 JSON

Parsing nested JSON using body-parser and express

javascript

mongoose

mongodb

node.js

body-parser