p4km9y/flink Docker 镜像 - 轩辕镜像 | Docker 镜像高效稳定拉取服务

run separated, referencing hadoop

bash
docker run --name flnk --volumes-from hdp --link hdp flink

run composed

external networking is used because of [***] workaround. docker uses underscores in network and host naming ...

bash
docker network create --driver overlay iot.net
docker-compose -p iot up

elastic

bash
# docker-compose -p iot exec elastic /bin/bash

1. Vytorenie indexu

bash
curl -XPUT 'http://localhost:9200/iot-kura/' -d '{
    "settings": {
        "index": {
            "number_of_shards": 5,
            "number_of_replicas": 1
        }
    },
    "_all": {
        "enabled": false
    },
    "mappings": {
        "kura-entry": {
            "properties": {
                "device_id": {
                    "type": "string"
                },
                "unit": {
                    "type": "string"
                },
                "value": {
                    "type": "double"
                },
                "count": {
                    "type": "long"
                },
                "timestamp": {
                    "type": "date",
                    "format": "epoch_millis"
                },
                "location": {
                    "type": "geo_point"
                }
            }
        }
    }
}'

2. Kontrola, či index existuje:

curl 'localhost:9200/_cat/indices?v'

3. Pridanie zaznamu:

bash
curl -XPOST 'http://localhost:9200/iot-kura/kura-entry?pretty' -d '{
    "timestamp": "1466079132988",
    "location": {
        "lat": 48.***,
        "lon": 17.***
    },
    "unit": "C",
    "count": "120",
    "value": "2.3313523654E10",
    "device_id": "kura.device.name"
}'