将实时传感器数据流式传输到 rethinkdb

韩联社

我已使用 jquery 连接到传感器 json 提要,目前正在使用冰沙图表实时绘制它。我正在考虑将此流通过管道传输到 Moongodb 或 rethinkdb 表中,以便滚动 30 天 ttl 以进行报告、映射和仅流式传输到冰沙。有没有人有任何示例代码可以用作将 json 流导入 nosql 的模板?TTL 选项是一个好主意,使用 dynamodb 这是我能够设置的东西,但我明白在这方面有一些限制需要重新思考,所以目前,我只是尝试将数据流式传输到表中。希望有人有一些实时 json 流到 nosql db 的好例子

这将它从 mongodb 中取出并放入冰沙中,但首先我需要将 json 提要放入 mongo

https://blog.codecentric.de/en/2014/01/realtime-analytics-mongodb-nodejs-smoothiecharts/

阿蒂什

MongoDB 3.6有一个名为更改流的全新功能,允许您实时监听集合上发生的更改。

用于侦听集合上发生的选定更改的示例代码如下:

var MongoClient = require('mongodb').MongoClient
, assert = require('assert');
MongoClient.connect("mongodb://172.16.0.110:27017/myproject?readConcern=majority").then(function(client){
  var db = client.db('myproject')
  var changeStreams =  db.collection('documents').watch()
  changeStreams.on('change', function(change){
    console.log(change)  
  })

}) 如果您使用的是 node.js,则需要使用以下 node 模块来使其工作:

"dependencies": {
    "mongodb": "mongodb/node-mongodb-native#3.0.0"
  }

本文收集自互联网,转载请注明来源。

如有侵权,请联系[email protected] 删除。

编辑于
0

我来说两句

0条评论
登录后参与评论

相关文章

来自分类Dev

将数据流式传输到Druid服务器

来自分类Dev

RethinkDB数据结构

来自分类Dev

获取Rethinkdb索引元数据

来自分类Dev

在Phoenix Framework中实时显示rethinkDB表

来自分类Dev

RethinkDB插入具有关系的数据

来自分类Dev

Rethinkdb从文档中删除数据

来自分类Dev

RethinkDB中的表与数据库性能

来自分类Dev

从列表 rethinkdb ~python 更新特定数据

来自分类Dev

将新列追加到rethinkdb表?

来自分类Dev

如何将MongoDB迁移到RethinkDB?

来自分类Dev

RethinkDB重新启动服务器后丢失数据

来自分类Dev

将二进制数据从mongoDB移至rethinkDB

来自分类Dev

将数据流式传输到Google BigQuery的架构是什么

来自分类Dev

如何将扳手表数据流式传输到Bigquery

来自分类Dev

Spring Cloud 数据流将文件流式传输到 HDFS

来自分类Dev

Python 将数据流式传输到 S3 但出现 104 错误是最好的方法

来自分类Dev

Google Apps Script - 如何将 JSON 数据流式传输到 BigQuery?

来自分类Dev

RethinkDb中的唯一整数计数器

来自分类Dev

限制RethinkDB中查询的服务器资源

来自分类Dev

具有外部服务器的RethinkDB集群

来自分类Dev

如何在RethinkDB中重命名数据库

来自分类Dev

聚合数据并仍在rethinkDB中使用changefeed

来自分类Dev

在RethinkDB数据库中,文档ID是否唯一?

来自分类Dev

如果需要在rethinkdb中创建数据库

来自分类Dev

从命令行创建RethinkDB数据库

来自分类Dev

RethinkDB-如何在分组数据上返回滑动窗口

来自分类Dev

Rethinkdb查询两个日期之间的数据

来自分类Dev

复制/复制RethinkDB数据库的最简单方法?

来自分类Dev

使用Tornado websockets和RethinkDB的非阻塞式数据获取