ci: push test results to elasticsearch instance

Move away from opensearch and switch to elasticsearch for reporting.
The results will be available at https://kibana.zephyrproject.io/

Signed-off-by: Anas Nashif <anas.nashif@intel.com>

.github/workflows/twister.yaml

@@ -291,11 +291,11 @@ jobs:
       - if: github.event_name == 'push' || github.event_name == 'schedule'
         name: Upload to opensearch
         run: |
-          pip3 install opensearch-py
+          pip3 install elasticsearch
           if [ "${{github.event_name}}" = "push" ]; then
-            python3 ./scripts/ci/upload_test_results.py --index zephyr-main-2 artifacts/*/*/twister.json
+            python3 ./scripts/ci/upload_test_results_es.py --index zephyr-main-ci-push-1 artifacts/*/*/twister.json
           elif [ "${{github.event_name}}" = "schedule" ]; then
-            python3 ./scripts/ci/upload_test_results.py --index zephyr-weekly artifacts/*/*/twister.json
+            python3 ./scripts/ci/upload_test_results_es.py --index zephyr-main-ci-weekly-1 artifacts/*/*/twister.json
           fi
 
       - name: Merge Test Results

scripts/ci/upload_test_results_es.py

@@ -0,0 +1,91 @@
+#!/usr/bin/env python3
+
+# Copyright (c) 2022 Intel Corporation
+# SPDX-License-Identifier: Apache-2.0
+
+
+# This script upload test ci results to the zephyr ES instance for reporting and analysis.
+# see https://kibana.zephyrproject.io/
+
+from elasticsearch import Elasticsearch
+from elasticsearch.helpers import bulk
+import sys
+import os
+import json
+import argparse
+
+host = "https://elasticsearch.zephyrproject.io:443"
+
+def gendata(f, index):
+    with open(f, "r") as j:
+        data = json.load(j)
+        for t in data['testsuites']:
+            name = t['name']
+            _grouping = name.split("/")[-1]
+            main_group = _grouping.split(".")[0]
+            sub_group = _grouping.split(".")[1]
+            t['environment'] = data['environment']
+            t['component'] = main_group
+            t['sub_component'] = sub_group
+            yield {
+                    "_index": index,
+                    "_id": t['run_id'],
+                    "_source": t
+                    }
+
+def main():
+    args = parse_args()
+
+    if args.index:
+        index_name = args.index
+    else:
+        index_name = 'tests-zephyr-1'
+
+    settings = {
+            "index": {
+                "number_of_shards": 4
+                }
+            }
+    mappings = {
+            "properties": {
+                "execution_time": {"type": "float"},
+                "retries": {"type": "integer"},
+                "testcases.execution_time": {"type": "float"},
+                }
+            }
+
+    if args.dry_run:
+        xx = None
+        for f in args.files:
+            xx = gendata(f, index_name)
+        for x in xx:
+            print(x)
+        sys.exit(0)
+
+    es = Elasticsearch(
+        [host],
+        api_key=os.environ['ELASTICSEARCH_KEY'],
+        verify_certs=False
+        )
+
+    if args.create_index:
+        es.indices.create(index=index_name, mappings=mappings, settings=settings)
+    else:
+        for f in args.files:
+            bulk(es, gendata(f, index_name))
+
+
+def parse_args():
+    parser = argparse.ArgumentParser(allow_abbrev=False)
+    parser.add_argument('-y','--dry-run', action="store_true", help='Dry run.')
+    parser.add_argument('-c','--create-index', action="store_true", help='Create index.')
+    parser.add_argument('-i', '--index', help='index to push to.', required=True)
+    parser.add_argument('files', metavar='FILE', nargs='+', help='file with test data.')
+
+    args = parser.parse_args()
+
+    return args
+
+
+if __name__ == '__main__':
+    main()