added example yaml open file

func_test/api_func_test.py

@@ -17,10 +17,10 @@ import json
 import time
 
 import requests
+import yaml
 
 from monascaclient import ksclient
 
-
 events_url = "http://192.168.10.4:8082"
 
 
@@ -42,6 +42,7 @@ headers = {
     'User-Agent': 'python-monascaclient',
     'Content-Type': 'application/json'}
 
+
 def test_events_get():
 
     body = {}
@@ -142,13 +143,18 @@ def test_stream_definition_delete():
     print("DELETE /stream-definitions success")
 
 
-def test_transforms(yml):
+def test_transforms():
 
     print("Test POST /transforms")
+
+    # Open example yaml file and post to DB
+    fh = open('transform_definitions.yaml', 'r')
+    specification_data = yaml.load(fh)
+
     body = {
         "name": 'func test',
-        "description": 'a yaml file that echos test',
-        "specification": yml
+        "description": 'an example definition',
+        "specification": str(specification_data)
     }
     response = requests.post(
         url=events_url + "/v2.0/transforms",
@@ -187,14 +193,4 @@ test_stream_definition_post()
 test_stream_definition_get()
 test_stream_definition_delete()
 test_events_get_all()
-yml = """
----
-- host: mini-mon
-  vars:
-    test_var: "{{mini-mon}}"
-  tasks:
-    - name: Test Task
-      command: echo test
-"""
-test_transforms(yml)
-
+test_transforms()

func_test/transform_definitions.yaml

@@ -0,0 +1,63 @@
+---
+- event_type: compute.instance.*
+  traits: &instance_traits
+    tenant_id:
+      fields: payload.tenant_id
+    user_id:
+      fields: payload.user_id
+    instance_id:
+      fields: payload.instance_id
+    host:
+      fields: publisher_id
+      plugin:
+        name: split
+        parameters:
+          segment: 1
+          max_split: 1
+    service:
+      fields: publisher_id
+      plugin: split
+    memory_mb:
+      type: int
+      fields: payload.memory_mb
+    disk_gb:
+      type: int
+      fields: payload.disk_gb
+    root_gb:
+      type: int
+      fields: payload.root_gb
+    ephemeral_gb:
+      type: int
+      fields: payload.ephemeral_gb
+    vcpus:
+      type: int
+      fields: payload.vcpus
+    instance_type_id:
+      type: int
+      fields: payload.instance_type_id
+    instance_type:
+      fields: payload.instance_type
+    state:
+      fields: payload.state
+    os_architecture:
+      fields: payload.image_meta.'org.openstack__1__architecture'
+    os_version:
+      fields: payload.image_meta.'org.openstack__1__os_version'
+    os_distro:
+      fields: payload.image_meta.'org.openstack__1__os_distro'
+    launched_at:
+      type: datetime
+      fields: payload.launched_at
+    deleted_at:
+      type: datetime
+      fields: payload.deleted_at
+- event_type: compute.instance.exists
+  traits:
+    <<: *instance_traits
+    audit_period_beginning:
+      type: datetime
+      fields: payload.audit_period_beginning
+    audit_period_ending:
+      type: datetime
+      fields: payload.audit_period_ending
+

monasca_events_api/v2/transforms.py

@@ -13,8 +13,8 @@
 # under the License.
 
 import ast
-import json
 import datetime
+import json
 from time import mktime
 import yaml