Servicio de Windows escrito en python, que no detecta los eventos de apagado y se detiene con gracia

winapi service

Question

He escrito un servicio para Windows XP + en python usando el código de ejemplo Con notificaciones de servicio extendido . Funciona muy bien para detectar la pantalla de bloqueo de inicio / cierre de sesión del usuario y otros eventos. El problema es que nunca ejecuta eventos de apagado y detiene con gracia el servicio al reiniciar / apagar. Permanece activo a través de los eventos de inicio / cierre de sesión, y también se reinicia después del reinicio. Cualquier ayuda sería apreciada.

No quiero usar RegisterServiceCtrlHandlerEx y manejar las señales de la consola si puedo ayudarlo. Los servicios tienen esta funcionalidad incorporada, solo la he destrozado.

Aquí está el código:

from os.path import splitext, abspath
from sys import modules
import win32serviceutil
import win32service
import win32event
import win32api
import win32security
import win32ts
class Service(win32serviceutil.ServiceFramework):
_svc_name_ = ''_unNamed''
_svc_display_name_ = ''_Service Template''
def __init__(self, *args):
win32serviceutil.ServiceFramework.__init__(self, *args)
self.log(''Initializing Service'')
self.stop_event = win32event.CreateEvent(None, 0, 0, None)
self.server = None
def log(self, msg):
import servicemanager
servicemanager.LogInfoMsg(str(msg))
def logErr(self, msg):
import servicemanager
servicemanager.LogErrorMsg(str(msg))
def logWarn(self, msg):
import servicemanager
servicemanager.LogWarningMsg(str(msg))
def sleep(self, sec):
win32api.Sleep(sec*1000, True)
def GetAcceptedControls(self):
# Accept SESSION_CHANGE control
rc = win32serviceutil.ServiceFramework.GetAcceptedControls(self)
rc |= win32service.SERVICE_ACCEPT_SESSIONCHANGE
rc |= win32service.SERVICE_ACCEPT_SHUTDOWN
return rc
def GetUserInfo(self, sess_id):
sessions = win32security.LsaEnumerateLogonSessions()[:-5]
for sn in sessions:
sn_info = win32security.LsaGetLogonSessionData(sn)
if sn_info[''Session''] == sess_id:
return sn_info
def getUserSessionInfo(self, sess_id):
msg = ""
try:
for key, val in self.GetUserInfo(sess_id).items():
msg += ''%s : %s/n''%(key, val)
if key == "UserName":
self.server.username = val
except Exception, e:
msg += ''%s''%e
return msg
# All extra events are sent via SvcOtherEx (SvcOther remains as a
# function taking only the first args for backwards compatability)
def SvcOtherEx(self, control, event_type, data):
# This is only showing a few of the extra events - see the MSDN
# docs for "HandlerEx callback" for more info.
if control == win32service.SERVICE_CONTROL_SESSIONCHANGE:
sess_id = data[0]
msg = ""
if event_type == 5: # logon
msg = "Logon event: type=%s, sessionid=%s/n" % (event_type, sess_id)
# user_token = win32ts.WTSQueryUserToken(int(sess_id))
self.server.status = 1 #logon event
self.getUserSessionInfo(sess_id)
self.sendHeartbeat()
self.server.status = 2 #active user
elif event_type == 6: # logoff
msg = "Logoff event: type=%s, sessionid=%s/n" % (event_type, sess_id)
self.server.status = 3 #logoff event
self.sendHeartbeat()
self.server.username = ""
self.server.status = 0 #no user
elif event_type == 7: # lock
msg = "Lock event: type=%s, sessionid=%s/n" % (event_type, sess_id)
self.server.status = 1 #logon event
self.getUserSessionInfo(sess_id)
self.sendHeartbeat()
self.server.status = 2 #active user
elif event_type == 8: # unlock
self.server.status = 3 #logoff event
self.server.username = ""
self.sendHeartbeat()
self.server.status = 0 #no user
else:
msg = "Other session event: type=%s, sessionid=%s/n" % (event_type, sess_id)
# msg += self.getUserSessionInfo(sess_id)
self.log(msg)
# elif control == win32service.SERVICE_CONTROL_SHUTDOWN:
# msg = "Server being shutdown..."
# self.log(msg)
def SvcDoRun(self):
self.ReportServiceStatus(win32service.SERVICE_START_PENDING)
try:
self.ReportServiceStatus(win32service.SERVICE_RUNNING)
self.log(''Starting Service'')
self.start()
self.log(''Waiting'')
win32event.WaitForSingleObject(self.stop_event, win32event.INFINITE)
self.log(''Done'')
except Exception, x:
self.logErr(''Exception : %s'' % x)
self.SvcStop()
def SvcStop(self):
self.ReportServiceStatus(win32service.SERVICE_STOP_PENDING)
self.log(''Stopping Service'')
self.stop()
self.log(''Stopped'')
win32event.SetEvent(self.stop_event)
self.ReportServiceStatus(win32service.SERVICE_STOPPED)
def sendHeartbeat(self):
# 0 = no user, standard beat (format: 0||hostname)
# 1 = login event (format: 1|username|hostname)
# 2 = active user session
# 3 = logout event (format: 2|username|hostname)
# 4 = Service exception (format 3||hostname)
return self.server.sendHeartbeat(category=self.server.status, username=self.server.username)
def start(self): pass
# to be overridden
def stop(self): pass
# to be overridden
#reboot/halt makes a different call than ''net stop mytestservice''
def SvcShutdown(self):
msg = "Server being shutdown..."
self.log(msg)
self.SvcStop()
def instart(cls, name, display_name=None, stay_alive=True, exe_name="caedmSAM.exe"):
''''''
Install and Start (auto) a Service
cls : the class (derived from Service) that implement the Service
name : Service name
display_name : the name displayed in the service manager
stay_alive : Service will stop on logout if False
''''''
cls._svc_name_ = name
cls._svc_display_name_ = display_name or name
cls._exe_name_ = exe_name
cls._svc_description_ = "CAEDM SAM Server registration and montioring service"
try:
module_path=modules[cls.__module__].__file__
except AttributeError:
# maybe py2exe went by
from sys import executable
module_path=executable
module_file=splitext(abspath(module_path))[0]
cls._svc_reg_class_ = ''%s.%s'' % (module_file, cls.__name__)
if stay_alive: win32api.SetConsoleCtrlHandler(lambda x: True, True)
try:
win32serviceutil.InstallService(
cls._svc_reg_class_,
cls._svc_name_,
cls._svc_display_name_,
startType=win32service.SERVICE_AUTO_START
)
# print ''Install: OK''
win32serviceutil.StartService(
cls._svc_name_
)
# print ''Start: OK''
except Exception, x:
print str(x)

Answer 1

¿Has probado el PRESHUTDOWN? Por lo general, SHUTDOWN es demasiado tarde.

def GetAcceptedControls(self):
# Accept SESSION_CHANGE control
rc = win32serviceutil.ServiceFramework.GetAcceptedControls(self)
rc |= win32service.SERVICE_ACCEPT_SESSIONCHANGE
rc |= win32service.SERVICE_ACCEPT_SHUTDOWN
rc |= win32service.SERVICE_ACCEPT_PRESHUTDOWN
return r

Luego, en SvcOtherEx() intercepte el evento Pre Shutdown y solicite más tiempo.

if win32service.SERVICE_CONTROL_PRESHUTDOWN:
self.ReportServiceStatus(win32service.SERVICE_STOP_PENDING, waitHint=10000)
win32event.SetEvent(self.stop_event)