From c7cb519435aeb8a8e6fe6a51e98d042c29ec159b Mon Sep 17 00:00:00 2001 From: Joe Keen Date: Wed, 5 Aug 2015 12:00:10 -0600 Subject: [PATCH] Now with 100% more demo --- demo/post_webhook.py | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/demo/post_webhook.py b/demo/post_webhook.py index 4a38d68..83dded7 100644 --- a/demo/post_webhook.py +++ b/demo/post_webhook.py @@ -1,5 +1,6 @@ import datetime import json +import random import requests import kafka.client @@ -30,7 +31,12 @@ for raw_event in consumer: end = datetime.datetime.strptime(times['compute.instance.create.end'], time_format) duration = ((end - start).total_seconds() * microseconds_per_second) - except Exception: + + duration = min(100, duration) + + duration += random.uniform(5, 10) + + except Exception as e: continue body = {'VM Create time': '{}'.format(duration),