有一个问题，一个项目简单的 Node js 应用程序从用户添加和获取数据并保存到 mongo(使用 3..ver)，一切正常(保存，获取等)，示例是

var express = require('express');
var router = express.Router();
var mongo = require('mongodb').MongoClient;
var objectID = require('mongodb').ObjectID;
var assert = require('assert');

const url = 'mongodb://localhost:27017';
const dbName = 'ldex';
const tblOffers = 'offers';

router.post('/insert', function (req, res, next) {
    var order = {
        type: 'Sell',
        ..............
        max: req.body.max,
        protection: req.body.protection,
        comment: req.body.comment,
        date: new Date().toDateString()
    };

    mongo.connect(url, function (err, client) {
        assert.equal(null, err);

        const db = client.db(dbName);

        db.collection(tblOffers).insertOne(order, function (err, res) {
            assert.equal(null, err);
            console.log('Offer placed');
            client.close();
        })
    });

    res.redirect('/exchange')
});

但这是另一个应用程序，解析器，具有相同的 mongo 连接，它从其他网站添加一些数据(当不使用 mongo 时一切正常，我收到数据很好)，这是代码的一部分:

...
let assert = require('assert');
let mongo = require('mongodb').MongoClient;
let router = express.Router();

const url = 'mongodb://localhost:27017/';
const dbName = 'ceramo';
const tblOffers = 'items';

...

/*
 *  Get items from specific group
 */

function getGroupItems(url, callback) {
    request({uri: url}, function (error, response, body) {
        let list = [];
        let $ = cheerio.load(body);
        $('#tovar').find('a.cat_item_disc_a').each(function(i, elem) {
            list[i] = 'https://plitkazavr.ru' + $(this).attr('href');
        });
        callback(list);
    });
}

/*
 *  Parse one item from specific link
 */

function getItem(url) {
    request({uri: url}, function (error, response, body) {
        let list = {};
        let $ = cheerio.load(body);
        $('#item_border').find('> #item_prop > ul').find('li.item_list').each(function(i, elem) {
            list[$(this).find('.item_cell').first().text()] = $(this).find('div.item_cell.item_val').text();
        });
        list.price = (parseFloat($('#item_price').text()));
        list.img = ('https://plitkazavr.ru' + $('#item_img').attr('src'));
        list.meta = ($('#item_wrap').find('meta[itemprop="description"]').attr("content"));

        mongo.connect(url, function (err, client) {
            assert.equal(null, err);

            const db = client.db(dbName);

            db.collection(tblOffers).insertOne(order, function (err, res) {
                assert.equal(null, err);
                console.log('Offer placed');
                client.close();
            })
        });

    });
}

router.get('/parse', function (req, res, next) {

    getGroupItems('https://plitkazavr.ru/Naxos/Clio', function (items) {
        items.forEach(function(item, i, arr) {
            setTimeout(function() {
                getItem(item);
            }, 1000);
        });
    });

    res.end('ok');
});

连接断开并给出

`Error: Invalid schema, expected `mongodb` or `mongodb+srv

不明白哪里有问题，求助...

最佳答案

您的 MongoDB URL 似乎不完整，它应该包含您的 dbName，然后再像这样传递到 mongoose 连接中

const url = 'mongodb://localhost:27017/';
const fullUrl = url + dbName; // which should evaluate to this 'mongodb://localhost:27017/ceramo'


mongo.connect(fullUrl, function (err, client) {...}

关于node.js - 架构无效，应为 `mongodb` 或 `mongodb+srv`，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/48605217/