使用Elasticsearch和Kibana，将Arduino传感器信息可视化

2 年 ago

清, 扬

1 minute

Elasticsearch和Kibana是什么？

以下是查找Elasticsearch的相关文章。

从零开始，学会实际运用Elasticsearch！- $shibayu36->博客

这次我们不是用于全文搜索，而是用于传感器数据的存储。
原因是因为可以通过HTTP请求轻松地注册数据，还可以非常简单地获取复杂条件的查询。

Kibana是一款用于可视化Elasticsearch搜索结果的工具，可以展示各种图表。如果想了解可以进行哪些可视化操作，可以在Kibana中进行Google图像搜索来参考。

kibana – 谷歌搜索

我计划使用Elasticsearch和Kibana来可视化传感器信息。

准备

针对macOS环境进行操作。
对于其他操作系统，请适当调整。

Elasticsearch和Kibana可以使用brew进行安装，但由于版本差异等问题可能会浪费很多时间，所以我会迅速使用docker来准备。

准备docker-compose.yml文件。

elasticsearch:
  image: elasticsearch
  ports:
    - "9200:9200"
    - "9300:9300"
  hostname: elasticsearch
  container_name: elasticsearch
kibana:
  image: kibana
  ports:
    - "5601:5601"
  links:
    - elasticsearch
  container_name: kibana

开始。

$ docker-compose up -d

這樣Elasticsearch和Kibana就準備好了。
很簡單吧。
這次沒有使用插件，但如果要作為全文搜索引擎，需要寫入安裝kuromoji等插件的處理。

映射

需要告诉Elasticsearch飞行的是什么样的数据。
由于这次是一个简单的传感器，所以只需要一个时间信息和一个值用于时间序列显示即可。
因此，我们准备了以下的json。

{
    "mappings": {
        "test": {
            "properties": {
                "date": {
                    "type": "date",
                    "format": "date_time"
                },
                "value": {
                    "type": "integer"
                }
            }
        }
    }
}

$ curl -XPOST localhost:9200/test -d @map.json
{"acknowledged":true}

Elasticsearch的准备工作已经完成。

从传感器输入

请参考以下文章，将Arduino连接至Mac并接收传感器信息。
使用Node.js来操作Arduino。
有关Arduino环境的设置和获取传感器信息的指南，请阅读以下文章。

【Jonny-Five】使用Node.js来操作Arduino。从LED闪烁到传感器输入——Qiita。

为了将数据发送到Elasticsearch，还可以使用客户端库。

$ npm install --save elasticsearch

执行以下代码。

const five = require('johnny-five');
const elasticsearch = require('elasticsearch');

const client = new elasticsearch.Client({
    host: 'localhost:9200',
    log: 'trace'
});

const board = new five.Board();

const esIndex = 'test';
const esType = 'test';

board.on('ready', () => {
    const sensor = new five.Sensor('A0');

    sensor.on('change', v => {
        client.create({
            index: esIndex,
            type: esType,
            body: {
                value: Number(v),
                date: new Date()
            }
        });
    });
});