linspector/linspector-old
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

fixed mongodb task; writes just a timestamp and the response message for now

Browse source
This commit is contained in:
Johannes Findeisen 2013-11-22 19:32:05 +01:00
commit 5785340a55
1 changed files with 7 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

12
linspector/tasks/storage/mongodb.py
View file

@ -19,6 +19,7 @@ You should have received a copy of the GNU Affero General Public License
along with this program. If not, see <http://www.gnu.org/licenses/>. along with this program. If not, see <http://www.gnu.org/licenses/>.
""" """
import datetime
from logging import getLogger from logging import getLogger
from pymongo import MongoClient from pymongo import MongoClient
@ -50,13 +51,14 @@ class MongodbTask(Task):
if "port" in args: if "port" in args:
self.port = args["port"] self.port = args["port"]
#self.mongo_client = MongoClient(self.host, self.port) self.mongo_client = MongoClient(self.host, self.port)
#self.mongo_db = self.mongo_client[self.database] self.mongo_db = self.mongo_client[self.database]
#self.mongo_db_collection = self.mongo_db[self.collection] self.mongo_db_collection = self.mongo_db[self.collection]
def execute(self, job_information): def execute(self, job_information):
#self.mongo_db_collection.insert(job_information.__dict__) data = {"timestamp": str(datetime.datetime.now()),
pass "msg": job_information.get_response_message()}
self.mongo_db_collection.insert(data)
def create(kwargs): def create(kwargs):