diff options
| author | Christian Pointner <equinox@spreadspace.org> | 2014-11-27 20:49:16 +0100 |
|---|---|---|
| committer | Christian Pointner <equinox@spreadspace.org> | 2014-11-27 20:49:16 +0100 |
| commit | dfeca5cbace4b0c49958dd991ec9c5d26b5d79d4 (patch) | |
| tree | dd2207fd88e265a3e1dc7316e95cf89f3f68a2a1 /src | |
| parent | untabify (diff) | |
added es5 (elasticsearch integration for sfive)
Diffstat (limited to 'src')
| -rwxr-xr-x | src/es5/create-index-es | 8 | ||||
| -rw-r--r-- | src/es5/es-query.json | 18 | ||||
| -rw-r--r-- | src/es5/sfive-mapping.json | 56 | ||||
| -rwxr-xr-x | src/es5/test-query-es | 8 |
4 files changed, 90 insertions, 0 deletions
diff --git a/src/es5/create-index-es b/src/es5/create-index-es new file mode 100755 index 0000000..b3a10bf --- /dev/null +++ b/src/es5/create-index-es @@ -0,0 +1,8 @@ +#!/bin/sh + +if [ -z "$1" ]; then + echo "Usage $0 <index>" + exit 1 +fi + +curl -XPOST 'http://stream.elevate.at:9200/'"$1"'?pretty' -d @sfive-mapping.json diff --git a/src/es5/es-query.json b/src/es5/es-query.json new file mode 100644 index 0000000..c73d079 --- /dev/null +++ b/src/es5/es-query.json @@ -0,0 +1,18 @@ +{ + "aggregations": + { + "by_hostname": + { + "terms": { "script": "doc['source-id'].value" } + }, + "the_total_time": + { + "sum": { "field": "duration-ms" } + }, + "da_klaient_do": + { + "sum": { "field": "data.client-count" } + } + } +} + diff --git a/src/es5/sfive-mapping.json b/src/es5/sfive-mapping.json new file mode 100644 index 0000000..6ed1772 --- /dev/null +++ b/src/es5/sfive-mapping.json @@ -0,0 +1,56 @@ +{ + "mappings" : { + "dataupdate" : { + "properties" : { + "source-id": { "type": "string" }, + "SourceHubDataUpdateId" : { + "type" : "long" + }, + "SourceHubUuid" : { + "type" : "string" + }, + "data" : { + "properties" : { + "bytes-received" : { + "type" : "long" + }, + "bytes-sent" : { + "type" : "long" + }, + "client-count" : { + "type" : "long" + } + } + }, + "duration-ms" : { + "type" : "long" + }, + "hostname" : { + "type" : "string", + "copy_to": "source-id" + }, + "start-time" : { + "type" : "date", + "format" : "dateOptionalTime" + }, + "streamer-id" : { + "properties" : { + "content-id" : { + "type" : "string", + "copy_to": "source-id" + }, + "format" : { + "type" : "string" + }, + "quality" : { + "type" : "string" + } + } + }, + "version" : { + "type" : "long" + } + } + } + } +} diff --git a/src/es5/test-query-es b/src/es5/test-query-es new file mode 100755 index 0000000..2782cec --- /dev/null +++ b/src/es5/test-query-es @@ -0,0 +1,8 @@ +#!/bin/sh + +if [ -z "$1" ]; then + echo "Usage $0 <index>" + exit 1 +fi + +curl -XGET 'http://stream.elevate.at:9200/'"$1"'/dataupdate/_search?pretty' -d @es-query.json |