Skip to content

WekanCompany/mqemitter-realm

Repository files navigation

mqemitter-realm

MongoDB Realm powered MQEmitter.

Install

$ npm install mqemitter-realm

Example

const realmEmitter = require('mqemitter-realm');

const aedes = require('aedes')({
  mq: realmEmitter({
    appId: process.env.AEDES_REALM_APP_ID,
    email: process.env.AEDES_REALM_EMAIL,
    password: process.env.AEDES_REALM_PASSWORD,
    schema: sensorSchema,
    compactionThreshold: 20,
    topics: [
      {
        name: 'temp/sensor-1',
        transformer: utils.transformers.temperature,
        partitionValue: 'temperature',
      },
      {
        name: 'humid/sensor-1',
        transformer: utils.transformers.humidity,
        partitionValue: 'humidity',
      },
    ],
  }),
});

The examples/broker folder provides a simple broker that uses mqemitter-realm to sync messages to a MongoDB cluster on Atlas

API

realmEmitter(opts)

Create a new instance of mqemitter-mongodb.

Options

  • appId: a realm app id

  • email: the realm app user's email

  • password: the realm app user's password

We currently only support Email / Password authentication, but we will be adding the remaining authentication providers in the future.

  • schema: an object schema defining the model to which the messages are saved

Take a look at SensorSchema to see an example of an object schema

  • compactionThreshold: 50

The size is defined in MB. Defaults to 100 MB if not provided.

  • topics: An array of objects representing the data to save and where to save it.
    • name: a topic to listen to for incoming messages
    • transformer: Optional callback used to transform the message payload before saving it into realm
    • partitionValue: Value used to partition and group data with the same value into a separate realm

License

MIT

About

MongoDB Realm based MQEmitter

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published