x/stacktach-notigen
Code Issues Proposed changes

now generates string datetimes as openstack would

Browse Source
This commit is contained in:
Sandy Walsh 2014-05-21 13:31:31 +00:00
parent 6e01a84104
commit 978aafe4dd
2 changed files with 12 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
bin/event_pump.py
View File

@ -1,16 +1,19 @@
import datetime
from notabene import kombu_driver as driver
import notigen
"""Pump simulated OpenStack notificationss into RabbitMQ.
You need to install rabbitqm-server and
pip install librabbitmq
pip install notabene
pip install --pre notabene
pip install --pre notification_utils
"""
import datetime
from notabene import kombu_driver as driver
import notification_utils
import notigen
connection = driver.create_connection("localhost", 5672, 'guest', 'guest',
"librabbitmq", "/")
exchange = driver.create_exchange("monitor", "topic")

6
notigen/__init__.py
View File

@ -269,13 +269,13 @@ class EventGenerator(object):
results = []
if event[-1] == '*':
event = event[0:-1]
extra = {'when': now, 'node': node}
extra = {'when': str(now), 'node': node}
results.append(self._pkg(base, extra, {'event': event + "start"}))
now = self._bump_time(now, 0.25, 60.0 * 15.0) # In compute node
extra = {'when': now, 'node': node}
extra = {'when': str(now), 'node': node}
results.append(self._pkg(base, extra, {'event': event + "end"}))
else:
extra = {'when': now, 'node': node}
extra = {'when': str(now), 'node': node}
results.append(self._pkg(base, extra, {'event': event}))
return results