argos-streamer
v0.0.6
Published
Stream server for ARGOS
Downloads
24
Readme
Overview
Server application for streaming MQTT packets. Take specific topics and keep them in files for a certain period of time under a specific folder.
- Can add or delete topics that are in service
- Can control how topics are stored in time, number and capacity
- Added / deleted details of the previous operation are managed when the service is restarted.
- Can check the amount of storage per topic in the managed folder
- Each topic can view the last time the message was received
- Can print a list of topics currently working on
Installation
$ npm install argos-streamer
Usage
Standalone
$ npm install argos-streamer
$ cd node_modules/argos-streamer
$ npm run server
Quick Start
var config = {
"argos-home":"./var",
"mqtt":{"host":"argos.winm2m.com","port":1883}
};
var streamer = new (require("./streamer"))(config);
streamer.start();
HTTP Service
var config = {
"argos-home":"./var",
"http-port":5080,
"websocket-port":5090,
"mqtt":{"host":"argos.winm2m.com","port":1883}
};
var streamer = new (require("./streamer"))(config);
var express = require('express');
var bodyParser = require('body-parser');
var app = express();
app.use(bodyParser.json(), bodyParser.urlencoded({extended: true}));
streamer.setupHTTP("/argos/streamer", app, {sendResult:function(req, res, r) { res.send(r); }});
streamer.start();
app.listen(config["http-port"]);