From dfeca5cbace4b0c49958dd991ec9c5d26b5d79d4 Mon Sep 17 00:00:00 2001
From: Christian Pointner <equinox@spreadspace.org>
Date: Thu, 27 Nov 2014 20:49:16 +0100
Subject: added es5 (elasticsearch integration for sfive)

---
 src/es5/create-index-es    |  8 +++++++
 src/es5/es-query.json      | 18 +++++++++++++++
 src/es5/sfive-mapping.json | 56 ++++++++++++++++++++++++++++++++++++++++++++++
 src/es5/test-query-es      |  8 +++++++
 4 files changed, 90 insertions(+)
 create mode 100755 src/es5/create-index-es
 create mode 100644 src/es5/es-query.json
 create mode 100644 src/es5/sfive-mapping.json
 create mode 100755 src/es5/test-query-es

(limited to 'src')

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
-- 
cgit v1.2.3