Commit 91ab6c9e authored by Pablo Viñals's avatar Pablo Viñals
Browse files

crossbarHelper code simplification

parent f927b50f
......@@ -42,6 +42,7 @@ import binascii
import sys
import subprocess
import datetime
import n3Helper
......@@ -90,6 +91,7 @@ class AppSession(ApplicationSession):
def uploadToES(kwargs):
self.elasticSearchID = self.elasticSearchID+1
kwargs['eventId'] = self.elasticSearchID
kwargs['time'] = datetime.datetime.now().hour
kwargsJson = json.dumps(kwargs)
self.log.info("Trying to load to elasticsearch: {event}", event = kwargsJson)
res = self.es.index(index='crossbar', doc_type='events', id=self.elasticSearchID, body=kwargsJson)
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment