Использование нескольких баз данных Mongodb с Meteor.js

Обновить

Теперь можно подключаться к удаленным/нескольким базам данных:

var database = new MongoInternals.RemoteCollectionDriver("<mongo url>");
MyCollection = new Mongo.Collection("collection_name", { _driver: database });

Где <mongo_url> — это URL-адрес mongodb, например mongodb://127.0.0.1:27017/meteor (с именем базы данных)

На данный момент у этого есть один недостаток: нет Oplog.

Старый ответ

На данный момент это невозможно. Каждое метеорное приложение привязано к одной базе данных.

Есть несколько способов обойти это, но это может быть сложнее, чем стоит:

Один из вариантов — использовать отдельное приложение Meteor.

В другом вашем метеорном приложении (пример работы на порту 6000 на той же машине). У вас все еще может быть реактивность, но вам нужно прокси вставлять, удалять и обновлять через вызов метода

Сервер:

Cats = Meteor.Collection('cats')

Meteor.publish("cats", function() {
    return Cats.find();
});

Meteor.methods('updateCat, function(id, changes) {
    Cats.update({_id: id}, {$set:changes});
});

Ваше текущее приложение Meteor:

var connection = DDP.connect("http://localhost:6000");

connection.subscribe("cats");
Cats = Meteor.Collection('cats', {connection: connection});

//To update a collection
Cats.call("updateCat", <cat_id>, <changes);

Другой вариант - пользовательское соединение mongodb

При этом используется собственный драйвер node js mongodb.

Это подключение к базе данных, как если бы вы делали это в любом другом приложении node js.

Доступной реактивности нет, и вы не можете использовать наборы типов new Meteor.Collection.

var mongodb = Npm.require("mongodb"); //or var mongodb = Meteor.require("mongodb") //if you use npm package on atmosphere

var db = mongodb.Db;
var mongoclient = mongodb.MongoClient;
var Server = mongodb.Server;

var db_connection = new Db('cats', new Server("127.0.0.1", 27017, {auto_reconnect: false, poolSize: 4}), {w:0, native_parser: false});

db.open(function(err, db) {
    //Connected to db 'cats'

    db.authenticate('<db username>', '<db password>', function(err, result) {
      //Can do queries here
      db.close();
   });
});

На самом деле это возможно, используя внутренний интерфейс:

var d = new MongoInternals.RemoteCollectionDriver("<mongo url>");
C = new Mongo.Collection("<collection name>", { _driver: d });

Ответ ДА: можно настроить несколько Meteor.Collections для получения данных с разных серверов базы данных mongdb.

Как ответ от @Akshat, вы можете инициализировать свой собственный экземпляр MongoInternals.RemoteCollectionDriver, с помощью которого можно создать Mongo.Collection.

Но вот еще о чем поговорить. Вопреки ответу @Akshat, я считаю, что поддержка Oplog по-прежнему доступна при таких обстоятельствах.

При инициализации пользовательского MongoInternals.RemoteCollectionDriver НЕ ЗАБУДЬТЕ указать URL Oplog:

var driver = new MongoInternals.RemoteCollectionDriver(
    "mongodb://localhost:27017/db", 
    {
      oplogUrl: "mongodb://localhost:27017/local"
    });
var collection = new Mongo.Collection("Coll", {_driver: driver});

Под капотом

Как описано выше, активировать поддержку Oplog достаточно просто. Если вы хотите узнать, что скрывается за этими двумя строками кода, вы можете продолжить чтение поста до конца.

В конструкторе RemoteCollectionDriver будет создан базовый MongoConnection:

MongoInternals.RemoteCollectionDriver = function (
  mongo_url, options) {
  var self = this;
  self.mongo = new MongoConnection(mongo_url, options);
}; 

Хитрость заключается в следующем: если MongoConnection создается с предоставленным oplogUrl, будет инициализирован OplogHandle, и он начнет отслеживать Oplog (исходный код):

if (options.oplogUrl && ! Package['disable-oplog']) {  
  self._oplogHandle = new OplogHandle(options.oplogUrl, self.db.databaseName);
  self._docFetcher = new DocFetcher(self);
}

Как описано в этом блоге: Meteor.publish внутренне вызывает Cursor.observeChanges для создания экземпляра ObserveHandle. , который автоматически отслеживает любые будущие изменения, происходящие в базе данных.

В настоящее время существует два типа драйверов-наблюдателей: устаревший PollingObserveDriver, использующий стратегию опроса и сравнения, и OplogObseveDriver, эффективно использующий Oplog-хвост для отслеживания изменений данных. Чтобы решить, какой из них применить, observeChanges выполняет следующую процедуру (исходный код):

var driverClass = canUseOplog ? OplogObserveDriver : PollingObserveDriver;
observeDriver = new driverClass({
  cursorDescription: cursorDescription,
  mongoHandle: self,
  multiplexer: multiplexer,
  ordered: ordered,
  matcher: matcher,  // ignored by polling
  sorter: sorter,  // ignored by polling
  _testOnlyPollCallback: callbacks._testOnlyPollCallback
});

Чтобы сделать canUseOplog истинным, необходимо выполнить несколько требований. Самый минимальный: базовый экземпляр MongoConnection должен иметь действительный OplogHandle. Именно по этой причине нам нужно указать oplogUrl при создании MongoConnection