Changes between Initial Version and Version 1 of Ticket #7

Timestamp:

01/17/18 16:35:36 (8 years ago)

Author:

zhangjr

Comment:

#!/usr/bin/python import sys import time import threading import subprocess class main(threading.Thread):

def init(self):

threading.Thread.init(self) self.lastTimeStamp='---'

from redis.sentinel import Sentinel

try:

sentinel = Sentinel([('10.1.33.141', 9001)], socket_timeout=0.1) self.redisServer=sentinel.master_for('neonmaster', socket_timeout=30, password="sanlie;123")

except:

print "Redis server failed" sys.exit()

def restartCockpit(self):

_cmd="source /home/neon/workspace/cockpit/cockpit" subprocess.Popen(_cmd, shell=True)

def run(self):

#self.redisServer.set("/GPPD/cockpit/log", " ") while True:

_TimeStamp=self.redisServer.get("/GPPD/cockpit/restart") if _TimeStamp!='notset':

self.restartCockpit() self.redisServer.set("/GPPD/cockpit/restart", "notset")

time.sleep(2.0)

if name=="main":

threadDaemon = main() threadDaemon.setDaemon(True) threadDaemon.start() threadDaemon.join() sys.exit()