valitydev/salt
14
0
Fork 0
mirror of https://github.com/valitydev/salt.git synced 2024-11-07 08:58:59 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #34326 from Inveracity/add-feature-mongodb-events

Browse Source 
feature mongodb return events
This commit is contained in:
Mike Place 2016-06-28 11:43:15 -07:00 committed by GitHub
commit cd35e73ef6
1 changed files with 19 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
salt/returners/mongo_future_return.py
View File

@ -157,10 +157,12 @@ def _get_conn(ret):
mdb.saltReturns.create_index('minion')
mdb.saltReturns.create_index('jid')
mdb.jobs.create_index('jid')
mdb.events.create_index('tag')
else:
mdb.saltReturns.ensure_index('minion')
mdb.saltReturns.ensure_index('jid')
mdb.jobs.ensure_index('jid')
mdb.events.ensure_index('tag')
return conn, mdb
@ -284,3 +286,20 @@ def prep_jid(nocache=False, passed_jid=None): # pylint: disable=unused-argument
Do any work necessary to prepare a JID, including sending a custom id
'''
return passed_jid if passed_jid is not None else salt.utils.jid.gen_jid()
def event_return(events):
"""
Return events to Mongodb server
"""
conn, mdb = _get_conn(ret=None)
if isinstance(events, list):
events = events[0]
if isinstance(events, dict):
log.debug(events)
if float(version) > 2.3:
mdb.events.insert_one(events.copy())
else:
mdb.events.insert(events.copy())