1 files changed, 70 insertions, 0 deletions
diff --git a/tests/onap-demo/blueprints/tosca-vnfd-onap-demo/infsetup.py b/tests/onap-demo/blueprints/tosca-vnfd-onap-demo/infsetup.py
new file mode 100644
index 0000000..fb8cbdc
--- /dev/null
+++ b/tests/onap-demo/blueprints/tosca-vnfd-onap-demo/infsetup.py
@@ -0,0 +1,70 @@
+#!/usr/bin/python3
+import argparse
+import json
+
+from influxdb import InfluxDBClient
+
+
+def main(host='localhost', port=8086):
+    user = 'root'
+    password = 'root'
+    dbname = 'veseventsdb'
+    dbuser = 'root'
+    dbuser_password = 'my_secret_password'
+    query = 'select value from cpu_load_short;'
+    json_body = [
+        {
+            "measurement": "cpu_load_short",
+            "tags": {
+                "host": "server01",
+                "region": "us-west"
+            },
+            "time": "2009-11-10T23:00:00Z",
+            "fields": {
+                "Float_value": 0.64,
+                "Int_value": 3,
+                "String_value": "Text",
+                "Bool_value": True
+            }
+        }
+    ]
+
+    client = InfluxDBClient(host, port, user, password, dbname)
+
+    print("Create database: " + dbname)
+    client.create_database(dbname)
+
+    print("Create a retention policy")
+    client.create_retention_policy('awesome_policy', '6h', 3, default=True)
+
+#    print("Switch user: " + dbuser)
+#    client.switch_user(dbuser, dbuser_password)
+#
+#    print("Write points: {0}".format(json_body))
+#    client.write_points(json_body)
+#
+#    print("Queying data: " + query)
+#    result = client.query(query)
+#
+#    print("Result: {0}".format(result))
+#
+#    print("Switch user: " + user)
+#    client.switch_user(user, password)
+#
+#    print("Drop database: " + dbname)
+#    client.drop_database(dbname)
+#
+
+def parse_args():
+    parser = argparse.ArgumentParser(
+        description='example code to play with InfluxDB')
+    parser.add_argument('--host', type=str, required=False, default='localhost',
+                        help='hostname of InfluxDB http API')
+    parser.add_argument('--port', type=int, required=False, default=8086,
+                        help='port of InfluxDB http API')
+    return parser.parse_args()
+
+
+if __name__ == '__main__':
+    args = parse_args()
+    main(host=args.host, port=args.port)